import org.apache.hadoop.metrics2.MetricsExecutor; //导入依赖的package包/类
public MetricsRegionServerWrapperImpl(final HRegionServer regionServer) {
  this.regionServer = regionServer;
  initBlockCache();

  this.period =
      regionServer.conf.getLong(HConstants.REGIONSERVER_METRICS_PERIOD,
        HConstants.DEFAULT_REGIONSERVER_METRICS_PERIOD);

  this.executor = CompatibilitySingletonFactory.getInstance(MetricsExecutor.class).getExecutor();
  this.runnable = new RegionServerMetricsWrapperRunnable();
  this.executor.scheduleWithFixedDelay(this.runnable, this.period, this.period,
    TimeUnit.MILLISECONDS);

  if (LOG.isInfoEnabled()) {
    LOG.info("Computing regionserver metrics every " + this.period + " milliseconds");
  }
}
 

import org.apache.hadoop.metrics2.MetricsExecutor; //导入依赖的package包/类
public MetricsRegionServerWrapperImpl(final HRegionServer regionServer) {
  this.regionServer = regionServer;
  initBlockCache();
  initMobFileCache();

  this.period =
      regionServer.conf.getLong(HConstants.REGIONSERVER_METRICS_PERIOD,
        HConstants.DEFAULT_REGIONSERVER_METRICS_PERIOD);

  this.executor = CompatibilitySingletonFactory.getInstance(MetricsExecutor.class).getExecutor();
  this.runnable = new RegionServerMetricsWrapperRunnable();
  this.executor.scheduleWithFixedDelay(this.runnable, this.period, this.period,
    TimeUnit.MILLISECONDS);
  this.metricsWALSource = CompatibilitySingletonFactory.getInstance(MetricsWALSource.class);

  try {
    this.dfsHedgedReadMetrics = FSUtils.getDFSHedgedReadMetrics(regionServer.getConfiguration());
  } catch (IOException e) {
    LOG.warn("Failed to get hedged metrics", e);
  }
  if (LOG.isInfoEnabled()) {
    LOG.info("Computing regionserver metrics every " + this.period + " milliseconds");
  }
}
 

import org.apache.hadoop.metrics2.MetricsExecutor; //导入依赖的package包/类
public MetricsRegionWrapperImpl(HRegion region) {
  this.region = region;
  this.executor = CompatibilitySingletonFactory.getInstance(MetricsExecutor.class).getExecutor();
  this.runnable = new HRegionMetricsWrapperRunnable();
  this.regionMetricsUpdateTask = this.executor.scheduleWithFixedDelay(this.runnable, PERIOD,
    PERIOD, TimeUnit.SECONDS);
}
 

import org.apache.hadoop.metrics2.MetricsExecutor; //导入依赖的package包/类
public MetricsRegionWrapperImpl(HRegion region) {
  this.region = region;
  this.executor = CompatibilitySingletonFactory.getInstance(MetricsExecutor.class).getExecutor();
  this.runnable = new HRegionMetricsWrapperRunnable();
  this.regionMetricsUpdateTask = this.executor.scheduleWithFixedDelay(this.runnable, PERIOD,
    PERIOD, TimeUnit.SECONDS);
  this.coprocessorTimes = new HashMap<String, DescriptiveStatistics>();
}
 

import org.apache.hadoop.metrics2.MetricsExecutor; //导入依赖的package包/类
public MetricsTableWrapperAggregateImpl(final HRegionServer regionServer) {
  this.regionServer = regionServer;
  this.period = regionServer.conf.getLong(HConstants.REGIONSERVER_METRICS_PERIOD,
    HConstants.DEFAULT_REGIONSERVER_METRICS_PERIOD) + 1000;
  this.executor = CompatibilitySingletonFactory.getInstance(MetricsExecutor.class).getExecutor();
  this.runnable = new TableMetricsWrapperRunnable();
  this.tableMetricsUpdateTask = this.executor.scheduleWithFixedDelay(this.runnable, period, this.period,
    TimeUnit.MILLISECONDS);
}
 

import org.apache.hadoop.metrics2.MetricsExecutor; //导入依赖的package包/类
public MetricsRegionServerWrapperImpl(final HRegionServer regionServer) {
  this.regionServer = regionServer;
  initBlockCache();

  this.executor = CompatibilitySingletonFactory.getInstance(MetricsExecutor.class).getExecutor();
  this.runnable = new RegionServerMetricsWrapperRunnable();
  this.executor.scheduleWithFixedDelay(this.runnable, PERIOD, PERIOD, TimeUnit.SECONDS);
}