StatsManager.java 文件源码

/**
 * Constructs a {@link StatsManager}.
 * @param storageManager the {@link StorageManager} to be used to fetch the {@link Store}s
 * @param partitionIds a {@link List} of {@link PartitionId}s that are going to be fetched
 * @param registry the {@link MetricRegistry} to be used for {@link StatsManagerMetrics}
 * @param config the {@link StatsManagerConfig} to be used to configure the output file path and publish period
 * @param time the {@link Time} instance to be used for reporting
 * @throws IOException
 */
StatsManager(StorageManager storageManager, List<PartitionId> partitionIds, MetricRegistry registry,
    StatsManagerConfig config, Time time) throws IOException {
  this.storageManager = storageManager;
  totalPartitionIds = partitionIds;
  statsOutputFile = new File(config.outputFilePath);
  publishPeriodInSecs = config.publishPeriodInSecs;
  initialDelayInSecs = config.initialDelayUpperBoundInSecs;
  metrics = new StatsManagerMetrics(registry);
  mapper.setVisibilityChecker(mapper.getVisibilityChecker().withFieldVisibility(JsonAutoDetect.Visibility.ANY));
  this.time = time;
}