Java MetricsExecutor类代码示例

OStack程序员社区-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Java中org.apache.hadoop.metrics2.MetricsExecutor类的典型用法代码示例。如果您正苦于以下问题：Java MetricsExecutor类的具体用法？Java MetricsExecutor怎么用？Java MetricsExecutor使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

MetricsExecutor类属于org.apache.hadoop.metrics2包，在下文中一共展示了MetricsExecutor类的6个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: MetricsRegionServerWrapperImpl

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");
  }
}

开发者ID:fengchen8086，项目名称:ditb，代码行数:18，代码来源:MetricsRegionServerWrapperImpl.java

示例2: MetricsRegionServerWrapperImpl

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");
  }
}

开发者ID:apache，项目名称:hbase，代码行数:25，代码来源:MetricsRegionServerWrapperImpl.java

示例3: MetricsRegionWrapperImpl

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);
}

开发者ID:fengchen8086，项目名称:ditb，代码行数:8，代码来源:MetricsRegionWrapperImpl.java

示例4: MetricsRegionWrapperImpl

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>();
}

开发者ID:grokcoder，项目名称:pbase，代码行数:9，代码来源:MetricsRegionWrapperImpl.java

示例5: MetricsTableWrapperAggregateImpl

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);
}

开发者ID:apache，项目名称:hbase，代码行数:10，代码来源:MetricsTableWrapperAggregateImpl.java

示例6: MetricsRegionServerWrapperImpl

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);
}

开发者ID:daidong，项目名称:DominoHBase，代码行数:9，代码来源:MetricsRegionServerWrapperImpl.java

注：本文中的org.apache.hadoop.metrics2.MetricsExecutor类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。