Java MetricsBuilder类代码示例

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

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

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

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

示例1: getMetrics

import org.apache.hadoop.metrics2.MetricsBuilder; //导入依赖的package包/类
/**
 * Yes this is a get function that doesn't return anything.  Thanks Hadoop for breaking all
 * expectations of java programmers.  Instead of returning anything Hadoop metrics expects
 * getMetrics to push the metrics into the metricsBuilder.
 *
 * @param metricsBuilder Builder to accept metrics
 * @param all            push all or only changed?
 */
@Override
public void getMetrics(MetricsBuilder metricsBuilder, boolean all) {

  MetricsRecordBuilder mrb = metricsBuilder.addRecord(metricsName)
      .setContext(metricsContext);

  if (regionSources != null) {
    lock.readLock().lock();
    try {
      for (MetricsRegionSourceImpl regionMetricSource : regionSources) {
        regionMetricSource.snapshot(mrb, all);
      }
    } finally {
      lock.readLock().unlock();
    }
  }

  metricsRegistry.snapshot(mrb, all);
}

开发者ID:tenggyut，项目名称:HIndex，代码行数:28，代码来源:MetricsRegionAggregateSourceImpl.java

示例2: getMetrics

import org.apache.hadoop.metrics2.MetricsBuilder; //导入依赖的package包/类
@Override
public void getMetrics(MetricsBuilder metricsBuilder, boolean all) {
  MetricsRecordBuilder mrb = metricsBuilder.addRecord(metricsName)
      .setContext(metricsContext);
  if (wrapper != null) {
    mrb.addGauge(QUEUE_SIZE_NAME, QUEUE_SIZE_DESC, wrapper.getTotalQueueSize())
        .addGauge(GENERAL_QUEUE_NAME, GENERAL_QUEUE_DESC, wrapper.getGeneralQueueLength())
        .addGauge(REPLICATION_QUEUE_NAME,
            REPLICATION_QUEUE_DESC, wrapper.getReplicationQueueLength())
        .addGauge(PRIORITY_QUEUE_NAME, PRIORITY_QUEUE_DESC, wrapper.getPriorityQueueLength())
        .addGauge(NUM_OPEN_CONNECTIONS_NAME,
            NUM_OPEN_CONNECTIONS_DESC, wrapper.getNumOpenConnections())
        .addGauge(NUM_ACTIVE_HANDLER_NAME,
            NUM_ACTIVE_HANDLER_DESC, wrapper.getActiveRpcHandlerCount());
  }

  metricsRegistry.snapshot(mrb, all);
}

开发者ID:tenggyut，项目名称:HIndex，代码行数:19，代码来源:MetricsHBaseServerSourceImpl.java

示例3: getMetrics

import org.apache.hadoop.metrics2.MetricsBuilder; //导入依赖的package包/类
@Override
public void getMetrics(MetricsBuilder metricsBuilder, boolean all) {
  MetricsRecordBuilder mrb = metricsBuilder.addRecord(metricsName)
      .setContext(metricsContext);
  if (wrapper != null) {
    mrb.addGauge(QUEUE_SIZE_NAME, QUEUE_SIZE_DESC, wrapper.getTotalQueueSize())
        .addGauge(GENERAL_QUEUE_NAME, GENERAL_QUEUE_DESC, wrapper.getGeneralQueueLength())
        .addGauge(REPLICATION_QUEUE_NAME,
            REPLICATION_QUEUE_DESC, wrapper.getReplicationQueueLength())
        .addGauge(PRIORITY_QUEUE_NAME, PRIORITY_QUEUE_DESC, wrapper.getPriorityQueueLength())
        .addGauge(NUM_OPEN_CONNECTIONS_NAME,
            NUM_OPEN_CONNECTIONS_DESC, wrapper.getNumOpenConnections());
  }

  metricsRegistry.snapshot(mrb, all);
}

开发者ID:cloud-software-foundation，项目名称:c5，代码行数:17，代码来源:MetricsHBaseServerSourceImpl.java

示例4: getMetrics

import org.apache.hadoop.metrics2.MetricsBuilder; //导入依赖的package包/类
/**
 * Call getMetrics on source and get a record builder mock to verify
 * @param source  the metrics source
 * @return the record builder mock to verify
 */
public static MetricsRecordBuilder getMetrics(MetricsSource source) {
  MetricsBuilder mb = mock(MetricsBuilder.class);
  final MetricsRecordBuilder rb = mock(MetricsRecordBuilder.class,
      new Answer<Object>() {
    @Override
    public Object answer(InvocationOnMock invocation) {
      Object[] args = invocation.getArguments();
      StringBuilder sb = new StringBuilder();
      for (Object o : args) {
        if (sb.length() > 0) sb.append(", ");
        sb.append(String.valueOf(o));
      }
      LOG.debug(invocation.getMethod().getName() +": "+ sb);
      return invocation.getMock();
    }
  });
  when(mb.addRecord(anyString())).thenReturn(rb);
  source.getMetrics(mb, true);
  return rb;
}

开发者ID:Seagate，项目名称:hadoop-on-lustre，代码行数:26，代码来源:MetricsAsserts.java

示例5: registerSystemSource

import org.apache.hadoop.metrics2.MetricsBuilder; //导入依赖的package包/类
private void registerSystemSource() {
  sysSource = new MetricsSourceAdapter(prefix, MS_STATS_NAME, MS_STATS_DESC,
      new MetricsSource() {
    @Override
    public void getMetrics(MetricsBuilder builder, boolean all) {
      int numSources, numSinks;
      synchronized(MetricsSystemImpl.this) {
        numSources = sources.size();
        numSinks = sinks.size();
      }
      MetricsRecordBuilder rb = builder.addRecord(MS_NAME)
          .setContext(MS_CONTEXT)
          .addGauge(NUM_SOURCES_KEY, NUM_SOURCES_DESC, numSources)
          .addGauge(NUM_SINKS_KEY, NUM_SINKS_DESC, numSinks);
      synchronized(MetricsSystemImpl.this) {
        for (MetricsSinkAdapter sa : sinks.values()) {
          sa.snapshot(rb, all);
        }
      }
      snapshotStat.snapshot(rb, all);
      publishStat.snapshot(rb, all);
      dropStat.snapshot(rb, all);
    }
  }, injectedTags, null, null, period);
  sysSource.start();
}

开发者ID:Seagate，项目名称:hadoop-on-lustre，代码行数:27，代码来源:MetricsSystemImpl.java

示例6: getMetrics

import org.apache.hadoop.metrics2.MetricsBuilder; //导入依赖的package包/类
@Override
public void getMetrics(MetricsBuilder builder, boolean all) {
  builder.addRecord("FSNamesystem").setContext("dfs")
    .addGauge("FilesTotal", "", getFilesTotal())
    .addGauge("BlocksTotal", "", getBlocksTotal())
    .addGauge("CapacityTotalGB", "",
              roundBytesToGBytes(getCapacityTotal()))
    .addGauge("CapacityUsedGB", "",
              roundBytesToGBytes(getCapacityUsed()))
    .addGauge("CapacityRemainingGB", "",
              roundBytesToGBytes(getCapacityRemaining()))
    .addGauge("TotalLoad", "", getTotalLoad())
    .addGauge("CorruptBlocks", "", getCorruptReplicaBlocks())
    .addGauge("ExcessBlocks", "", getExcessBlocks())
    .addGauge("PendingDeletionBlocks", "", getPendingDeletionBlocks())
    .addGauge("PendingReplicationBlocks", "", getPendingReplicationBlocks())
    .addGauge("UnderReplicatedBlocks", "", getUnderReplicatedBlocks())
    .addGauge("ScheduledReplicationBlocks", "",
              getScheduledReplicationBlocks())
    .addGauge("MissingBlocks", "", getMissingBlocksCount())
    .addGauge("BlockCapacity", "", getBlockCapacity());
}

开发者ID:Seagate，项目名称:hadoop-on-lustre，代码行数:23，代码来源:FSNamesystem.java

示例7: getMetrics

import org.apache.hadoop.metrics2.MetricsBuilder; //导入依赖的package包/类
/**
 * Yes this is a get function that doesn't return anything.  Thanks Hadoop for breaking all
 * expectations of java programmers.  Instead of returning anything Hadoop metrics expects
 * getMetrics to push the metrics into the metricsBuilder.
 *
 * @param metricsBuilder Builder to accept metrics
 * @param all            push all or only changed?
 */
@Override
public void getMetrics(MetricsBuilder metricsBuilder, boolean all) {


  MetricsRecordBuilder mrb = metricsBuilder.addRecord(metricsName)
      .setContext(metricsContext);

  if (regionSources != null) {
    for (MetricsRegionSourceImpl regionMetricSource : regionSources) {
      regionMetricSource.snapshot(mrb, all);
    }
  }


  metricsRegistry.snapshot(mrb, all);
}

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

示例8: getMetrics

import org.apache.hadoop.metrics2.MetricsBuilder; //导入依赖的package包/类
/**
 * Method to export all the metrics.
 *
 * @param metricsBuilder Builder to accept metrics
 * @param all            push all or only changed?
 */
@Override
public void getMetrics(MetricsBuilder metricsBuilder, boolean all) {
  MetricsRecordBuilder mrb = metricsBuilder.addRecord(metricsName)
                                           .setContext(metricsContext);
  metricsRegistry.snapshot(mrb, all);
}

开发者ID:tenggyut，项目名称:HIndex，代码行数:13，代码来源:BaseSourceImpl.java

示例9: getMetrics

import org.apache.hadoop.metrics2.MetricsBuilder; //导入依赖的package包/类
/**
 * Method to export all the metrics.
 *
 * @param metricsBuilder Builder to accept metrics
 * @param all            push all or only changed?
 */
@Override
public void getMetrics(MetricsBuilder metricsBuilder, boolean all) {

  MetricsRecordBuilder metricsRecordBuilder = metricsBuilder.addRecord(metricsName)
      .setContext(metricsContext);

  // masterWrapper can be null because this function is called inside of init.
  if (masterWrapper != null) {
    metricsRecordBuilder
        .addGauge(MASTER_ACTIVE_TIME_NAME,
            MASTER_ACTIVE_TIME_DESC, masterWrapper.getActiveTime())
        .addGauge(MASTER_START_TIME_NAME,
            MASTER_START_TIME_DESC, masterWrapper.getStartTime())
        .addGauge(AVERAGE_LOAD_NAME, AVERAGE_LOAD_DESC, masterWrapper.getAverageLoad())
        .tag(LIVE_REGION_SERVERS_NAME, LIVE_REGION_SERVERS_DESC,
              masterWrapper.getRegionServers())
        .addGauge(NUM_REGION_SERVERS_NAME,
            NUMBER_OF_REGION_SERVERS_DESC, masterWrapper.getNumRegionServers())
        .tag(DEAD_REGION_SERVERS_NAME, DEAD_REGION_SERVERS_DESC,
              masterWrapper.getDeadRegionServers())
        .addGauge(NUM_DEAD_REGION_SERVERS_NAME,
            NUMBER_OF_DEAD_REGION_SERVERS_DESC,
            masterWrapper.getNumDeadRegionServers())
        .tag(ZOOKEEPER_QUORUM_NAME, ZOOKEEPER_QUORUM_DESC, masterWrapper.getZookeeperQuorum())
        .tag(SERVER_NAME_NAME, SERVER_NAME_DESC, masterWrapper.getServerName())
        .tag(CLUSTER_ID_NAME, CLUSTER_ID_DESC, masterWrapper.getClusterId())
        .tag(IS_ACTIVE_MASTER_NAME,
            IS_ACTIVE_MASTER_DESC,
            String.valueOf(masterWrapper.getIsActiveMaster()));
  }

  metricsRegistry.snapshot(metricsRecordBuilder, all);
}

开发者ID:tenggyut，项目名称:HIndex，代码行数:40，代码来源:MetricsMasterSourceImpl.java

示例10: getMetrics

import org.apache.hadoop.metrics2.MetricsBuilder; //导入依赖的package包/类
/**
 * Method to export all the metrics.
 *
 * @param metricsBuilder Builder to accept metrics
 * @param all            push all or only changed?
 */
@Override
public void getMetrics(MetricsBuilder metricsBuilder, boolean all) {

  MetricsRecordBuilder metricsRecordBuilder = metricsBuilder.addRecord(metricsName)
      .setContext(metricsContext);

  // masterWrapper can be null because this function is called inside of init.
  if (masterWrapper != null) {
    metricsRecordBuilder
        .addGauge(MASTER_ACTIVE_TIME_NAME,
            MASTER_ACTIVE_TIME_DESC, masterWrapper.getActiveTime())
        .addGauge(MASTER_START_TIME_NAME,
            MASTER_START_TIME_DESC, masterWrapper.getStartTime())
        .addGauge(AVERAGE_LOAD_NAME, AVERAGE_LOAD_DESC, masterWrapper.getAverageLoad())
        .addGauge(NUM_REGION_SERVERS_NAME,
            NUMBER_OF_REGION_SERVERS_DESC, masterWrapper.getRegionServers())
        .addGauge(NUM_DEAD_REGION_SERVERS_NAME,
            NUMBER_OF_DEAD_REGION_SERVERS_DESC,
            masterWrapper.getDeadRegionServers())
        .tag(ZOOKEEPER_QUORUM_NAME, ZOOKEEPER_QUORUM_DESC, masterWrapper.getZookeeperQuorum())
        .tag(SERVER_NAME_NAME, SERVER_NAME_DESC, masterWrapper.getServerName())
        .tag(CLUSTER_ID_NAME, CLUSTER_ID_DESC, masterWrapper.getClusterId())
        .tag(IS_ACTIVE_MASTER_NAME,
            IS_ACTIVE_MASTER_DESC,
            String.valueOf(masterWrapper.getIsActiveMaster()));
  }

  metricsRegistry.snapshot(metricsRecordBuilder, all);
}

开发者ID:cloud-software-foundation，项目名称:c5，代码行数:36，代码来源:MetricsMasterSourceImpl.java

示例11: getMetrics

import org.apache.hadoop.metrics2.MetricsBuilder; //导入依赖的package包/类
@Override
public void getMetrics(MetricsBuilder builder, boolean all) {
  mapsRunning.set(tt.mapTotal);
  redsRunning.set(tt.reduceTotal);
  mapSlots.set(tt.getMaxCurrentMapTasks());
  redSlots.set(tt.getMaxCurrentReduceTasks());
  registry.snapshot(builder.addRecord(registry.name()), all);
}

开发者ID:Seagate，项目名称:hadoop-on-lustre，代码行数:9，代码来源:TaskTrackerMetricsSource.java

示例12: getMetrics

import org.apache.hadoop.metrics2.MetricsBuilder; //导入依赖的package包/类
@Override
public void getMetrics(MetricsBuilder builder, boolean all) {
  MetricsRecordBuilder rb = builder.addRecord(registry.name());
  rb.addGauge("shuffle_handler_busy_percent", "", ttWorkerThreads == 0 ? 0
      : 100. * serverHandlerBusy / ttWorkerThreads);
  registry.snapshot(rb, all);
}

开发者ID:Seagate，项目名称:hadoop-on-lustre，代码行数:8，代码来源:ShuffleServerInstrumentation.java

示例13: getMetrics

import org.apache.hadoop.metrics2.MetricsBuilder; //导入依赖的package包/类
@Override
public void getMetrics(MetricsBuilder builder, boolean all) {
  MetricsRecordBuilder rb = builder.addRecord(registry.name());
  rb.addGauge("shuffle_fetchers_busy_percent", "", numCopiers == 0 ? 0
      : 100. * threadsBusy / numCopiers);
  registry.snapshot(rb, all);
}

开发者ID:Seagate，项目名称:hadoop-on-lustre，代码行数:8，代码来源:ReduceTask.java

示例14: getMetrics

import org.apache.hadoop.metrics2.MetricsBuilder; //导入依赖的package包/类
@Override
public void getMetrics(MetricsBuilder builder, boolean all) {
  MetricsRecordBuilder rb = builder.addRecord(RECORD_NAME)
      .setContext(CONTEXT)
      .tag(PROCESSNAME_KEY, PROCESSNAME_DESC, processName)
      .tag(SESSIONID_KEY, SESSIONID_DESC, sessionId);
  getMemoryUsage(rb);
  getGcUsage(rb);
  getThreadUsage(rb);
  getEventCounters(rb);
}

开发者ID:Seagate，项目名称:hadoop-on-lustre，代码行数:12，代码来源:JvmMetricsSource.java

示例15: getMetrics

import org.apache.hadoop.metrics2.MetricsBuilder; //导入依赖的package包/类
/**
 * Yes this is a get function that doesn't return anything.  Thanks Hadoop for breaking all
 * expectations of java programmers.  Instead of returning anything Hadoop metrics expects
 * getMetrics to push the metrics into the metricsBuilder.
 *
 * @param metricsBuilder Builder to accept metrics
 * @param all            push all or only changed?
 */
@Override
public void getMetrics(MetricsBuilder metricsBuilder, boolean all) {

  MetricsRecordBuilder mrb = metricsBuilder.addRecord(metricsName)
      .setContext(metricsContext);

  // rsWrap can be null because this function is called inside of init.
  if (rsWrap != null) {
    mrb.addGauge(REGION_COUNT, REGION_COUNT_DESC, rsWrap.getNumOnlineRegions())
        .addGauge(STORE_COUNT, STORE_COUNT_DESC, rsWrap.getNumStores())
        .addGauge(HLOGFILE_COUNT, HLOGFILE_COUNT_DESC, rsWrap.getNumHLogFiles())
        .addGauge(HLOGFILE_SIZE, HLOGFILE_SIZE_DESC, rsWrap.getHLogFileSize())
        .addGauge(STOREFILE_COUNT, STOREFILE_COUNT_DESC, rsWrap.getNumStoreFiles())
        .addGauge(MEMSTORE_SIZE, MEMSTORE_SIZE_DESC, rsWrap.getMemstoreSize())
        .addGauge(STOREFILE_SIZE, STOREFILE_SIZE_DESC, rsWrap.getStoreFileSize())
        .addGauge(RS_START_TIME_NAME, RS_START_TIME_DESC, rsWrap.getStartCode())
        .addCounter(TOTAL_REQUEST_COUNT, TOTAL_REQUEST_COUNT_DESC, rsWrap.getTotalRequestCount())
        .addCounter(READ_REQUEST_COUNT, READ_REQUEST_COUNT_DESC, rsWrap.getReadRequestsCount())
        .addCounter(WRITE_REQUEST_COUNT, WRITE_REQUEST_COUNT_DESC, rsWrap.getWriteRequestsCount())
        .addCounter(CHECK_MUTATE_FAILED_COUNT,
            CHECK_MUTATE_FAILED_COUNT_DESC,
            rsWrap.getCheckAndMutateChecksFailed())
        .addCounter(CHECK_MUTATE_PASSED_COUNT,
            CHECK_MUTATE_PASSED_COUNT_DESC,
            rsWrap.getCheckAndMutateChecksPassed())
        .addGauge(STOREFILE_INDEX_SIZE, STOREFILE_INDEX_SIZE_DESC, rsWrap.getStoreFileIndexSize())
        .addGauge(STATIC_INDEX_SIZE, STATIC_INDEX_SIZE_DESC, rsWrap.getTotalStaticIndexSize())
        .addGauge(STATIC_BLOOM_SIZE, STATIC_BLOOM_SIZE_DESC, rsWrap.getTotalStaticBloomSize())
        .addGauge(NUMBER_OF_MUTATIONS_WITHOUT_WAL,
            NUMBER_OF_MUTATIONS_WITHOUT_WAL_DESC,
            rsWrap.getNumMutationsWithoutWAL())
        .addGauge(DATA_SIZE_WITHOUT_WAL,
            DATA_SIZE_WITHOUT_WAL_DESC,
            rsWrap.getDataInMemoryWithoutWAL())
        .addGauge(PERCENT_FILES_LOCAL, PERCENT_FILES_LOCAL_DESC, rsWrap.getPercentFileLocal())
        .addGauge(COMPACTION_QUEUE_LENGTH,
            COMPACTION_QUEUE_LENGTH_DESC,
            rsWrap.getCompactionQueueSize())
        .addGauge(LARGE_COMPACTION_QUEUE_LENGTH,
            COMPACTION_QUEUE_LENGTH_DESC,
            rsWrap.getLargeCompactionQueueSize())
        .addGauge(SMALL_COMPACTION_QUEUE_LENGTH,
            COMPACTION_QUEUE_LENGTH_DESC,
            rsWrap.getSmallCompactionQueueSize())
        .addGauge(FLUSH_QUEUE_LENGTH, FLUSH_QUEUE_LENGTH_DESC, rsWrap.getFlushQueueSize())
        .addGauge(BLOCK_CACHE_FREE_SIZE, BLOCK_CACHE_FREE_DESC, rsWrap.getBlockCacheFreeSize())
        .addGauge(BLOCK_CACHE_COUNT, BLOCK_CACHE_COUNT_DESC, rsWrap.getBlockCacheCount())
        .addGauge(BLOCK_CACHE_SIZE, BLOCK_CACHE_SIZE_DESC, rsWrap.getBlockCacheSize())
        .addCounter(BLOCK_CACHE_HIT_COUNT,
            BLOCK_CACHE_HIT_COUNT_DESC,
            rsWrap.getBlockCacheHitCount())
        .addCounter(BLOCK_CACHE_MISS_COUNT,
            BLOCK_COUNT_MISS_COUNT_DESC,
            rsWrap.getBlockCacheMissCount())
        .addCounter(BLOCK_CACHE_EVICTION_COUNT,
            BLOCK_CACHE_EVICTION_COUNT_DESC,
            rsWrap.getBlockCacheEvictedCount())
        .addGauge(BLOCK_CACHE_HIT_PERCENT,
            BLOCK_CACHE_HIT_PERCENT_DESC,
            rsWrap.getBlockCacheHitPercent())
        .addGauge(BLOCK_CACHE_EXPRESS_HIT_PERCENT,
            BLOCK_CACHE_EXPRESS_HIT_PERCENT_DESC,
            rsWrap.getBlockCacheHitCachingPercent())
        .addCounter(UPDATES_BLOCKED_TIME, UPDATES_BLOCKED_DESC, rsWrap.getUpdatesBlockedTime())
        .tag(ZOOKEEPER_QUORUM_NAME, ZOOKEEPER_QUORUM_DESC, rsWrap.getZookeeperQuorum())
        .tag(SERVER_NAME_NAME, SERVER_NAME_DESC, rsWrap.getServerName())
        .tag(CLUSTER_ID_NAME, CLUSTER_ID_DESC, rsWrap.getClusterId());
  }

  metricsRegistry.snapshot(mrb, all);
}

开发者ID:tenggyut，项目名称:HIndex，代码行数:80，代码来源:MetricsRegionServerSourceImpl.java

示例16: getMetrics

import org.apache.hadoop.metrics2.MetricsBuilder; //导入依赖的package包/类
/**
 * Yes this is a get function that doesn't return anything.  Thanks Hadoop for breaking all
 * expectations of java programmers.  Instead of returning anything Hadoop metrics expects
 * getMetrics to push the metrics into the metricsBuilder.
 *
 * @param metricsBuilder Builder to accept metrics
 * @param all            push all or only changed?
 */
@Override
public void getMetrics(MetricsBuilder metricsBuilder, boolean all) {

  MetricsRecordBuilder mrb = metricsBuilder.addRecord(metricsName)
      .setContext(metricsContext);

  // rsWrap can be null because this function is called inside of init.
  if (rsWrap != null) {
    mrb.addGauge(REGION_COUNT, REGION_COUNT_DESC, rsWrap.getNumOnlineRegions())
        .addGauge(STORE_COUNT, STORE_COUNT_DESC, rsWrap.getNumStores())
        .addGauge(STOREFILE_COUNT, STOREFILE_COUNT_DESC, rsWrap.getNumStoreFiles())
        .addGauge(MEMSTORE_SIZE, MEMSTORE_SIZE_DESC, rsWrap.getMemstoreSize())
        .addGauge(STOREFILE_SIZE, STOREFILE_SIZE_DESC, rsWrap.getStoreFileSize())
        .addGauge(RS_START_TIME_NAME, RS_START_TIME_DESC, rsWrap.getStartCode())
        .addCounter(TOTAL_REQUEST_COUNT, TOTAL_REQUEST_COUNT_DESC, rsWrap.getTotalRequestCount())
        .addCounter(READ_REQUEST_COUNT, READ_REQUEST_COUNT_DESC, rsWrap.getReadRequestsCount())
        .addCounter(WRITE_REQUEST_COUNT, WRITE_REQUEST_COUNT_DESC, rsWrap.getWriteRequestsCount())
        .addCounter(CHECK_MUTATE_FAILED_COUNT,
            CHECK_MUTATE_FAILED_COUNT_DESC,
            rsWrap.getCheckAndMutateChecksFailed())
        .addCounter(CHECK_MUTATE_PASSED_COUNT,
            CHECK_MUTATE_PASSED_COUNT_DESC,
            rsWrap.getCheckAndMutateChecksPassed())
        .addGauge(STOREFILE_INDEX_SIZE, STOREFILE_INDEX_SIZE_DESC, rsWrap.getStoreFileIndexSize())
        .addGauge(STATIC_INDEX_SIZE, STATIC_INDEX_SIZE_DESC, rsWrap.getTotalStaticIndexSize())
        .addGauge(STATIC_BLOOM_SIZE, STATIC_BLOOM_SIZE_DESC, rsWrap.getTotalStaticBloomSize())
        .addGauge(NUMBER_OF_MUTATIONS_WITHOUT_WAL,
            NUMBER_OF_MUTATIONS_WITHOUT_WAL_DESC,
            rsWrap.getNumMutationsWithoutWAL())
        .addGauge(DATA_SIZE_WITHOUT_WAL,
            DATA_SIZE_WITHOUT_WAL_DESC,
            rsWrap.getDataInMemoryWithoutWAL())
        .addGauge(PERCENT_FILES_LOCAL, PERCENT_FILES_LOCAL_DESC, rsWrap.getPercentFileLocal())
        .addGauge(COMPACTION_QUEUE_LENGTH,
            COMPACTION_QUEUE_LENGTH_DESC,
            rsWrap.getCompactionQueueSize())
        .addGauge(LARGE_COMPACTION_QUEUE_LENGTH,
            COMPACTION_QUEUE_LENGTH_DESC,
            rsWrap.getLargeCompactionQueueSize())
        .addGauge(SMALL_COMPACTION_QUEUE_LENGTH,
            COMPACTION_QUEUE_LENGTH_DESC,
            rsWrap.getSmallCompactionQueueSize())
        .addGauge(FLUSH_QUEUE_LENGTH, FLUSH_QUEUE_LENGTH_DESC, rsWrap.getFlushQueueSize())
        .addGauge(BLOCK_CACHE_FREE_SIZE, BLOCK_CACHE_FREE_DESC, rsWrap.getBlockCacheFreeSize())
        .addGauge(BLOCK_CACHE_COUNT, BLOCK_CACHE_COUNT_DESC, rsWrap.getBlockCacheCount())
        .addGauge(BLOCK_CACHE_SIZE, BLOCK_CACHE_SIZE_DESC, rsWrap.getBlockCacheSize())
        .addCounter(BLOCK_CACHE_HIT_COUNT,
            BLOCK_CACHE_HIT_COUNT_DESC,
            rsWrap.getBlockCacheHitCount())
        .addCounter(BLOCK_CACHE_MISS_COUNT,
            BLOCK_COUNT_MISS_COUNT_DESC,
            rsWrap.getBlockCacheMissCount())
        .addCounter(BLOCK_CACHE_EVICTION_COUNT,
            BLOCK_CACHE_EVICTION_COUNT_DESC,
            rsWrap.getBlockCacheEvictedCount())
        .addGauge(BLOCK_CACHE_HIT_PERCENT,
            BLOCK_CACHE_HIT_PERCENT_DESC,
            rsWrap.getBlockCacheHitPercent())
        .addGauge(BLOCK_CACHE_EXPRESS_HIT_PERCENT,
            BLOCK_CACHE_EXPRESS_HIT_PERCENT_DESC,
            rsWrap.getBlockCacheHitCachingPercent())
        .addCounter(UPDATES_BLOCKED_TIME, UPDATES_BLOCKED_DESC, rsWrap.getUpdatesBlockedTime())
        .tag(ZOOKEEPER_QUORUM_NAME, ZOOKEEPER_QUORUM_DESC, rsWrap.getZookeeperQuorum())
        .tag(SERVER_NAME_NAME, SERVER_NAME_DESC, rsWrap.getServerName())
        .tag(CLUSTER_ID_NAME, CLUSTER_ID_DESC, rsWrap.getClusterId());
  }

  metricsRegistry.snapshot(mrb, all);
}

开发者ID:cloud-software-foundation，项目名称:c5，代码行数:78，代码来源:MetricsRegionServerSourceImpl.java

示例17: getMetrics

import org.apache.hadoop.metrics2.MetricsBuilder; //导入依赖的package包/类
public void getMetrics(MetricsBuilder builder, boolean all) {
  updateRunningTime();
  registry.snapshot(builder.addRecord(registry.name()), all);
}

开发者ID:Seagate，项目名称:hadoop-on-lustre，代码行数:5，代码来源:QueueMetrics.java

示例18: getMetrics

import org.apache.hadoop.metrics2.MetricsBuilder; //导入依赖的package包/类
public void getMetrics(MetricsBuilder builder, boolean all) {
  registry.snapshot(builder.addRecord(registry.name()), all);
}

开发者ID:Seagate，项目名称:hadoop-on-lustre，代码行数:4，代码来源:JobTrackerMetricsSource.java

示例19: getMetrics

import org.apache.hadoop.metrics2.MetricsBuilder; //导入依赖的package包/类
@Override
public void getMetrics(MetricsBuilder builder, boolean all) {
  registry.snapshot(builder.addRecord(registry.name()), all);
}

开发者ID:Seagate，项目名称:hadoop-on-lustre，代码行数:5，代码来源:UgiInstrumentation.java

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

鲜花

握手

雷人

路过

鸡蛋

该文章已有0人参与评论

请发表评论

全部评论

专题导读

More+

10-27 六六分期app的软件客服如何联系？(六六分期

11-06 可心卡盟:win10系统火狐flash插件崩溃怎么

11-06 亲亲特价:怎么删除回收站图标

11-06 济南大学虚拟社区:鲁大师节能降温的具体办

11-06 xlueops.exe:无线网络安装向导

11-06 女斗合众国:win7系统cf与主机连接不稳定怎

11-06 0xc000022-[cf烟雾头]cf怎么调烟雾头

11-06 qizideyouhuo:应用程序无法正常启动0xc0000

11-06 ipz-185:win7系统vcf文件怎么打开

11-06 傻哥蹦迪:win10系统s4怎么打开usb调试

11-06 八神浩树gtaste:回收站清空了怎么恢复

11-06 妖尾之黑色守护:win10系统电脑没有1440x900

11-06 校园至尊魔王小说:win7系统浏览网页时字体

11-06 女斗合众国:win10系统访问共享文件夹提示请

11-06 tokyo hot n0654:恢复win7系统默认字体一招

11-06 雨酷仙境:设置win7系统转移临时文件夹腾出

11-06 阿穆纳伊之杖:win7系统开始菜单在右边还原

11-06 tunespotting:win10系统火狐flash插件总是

11-06 甘尔葛分析师：计谋网站seo关键词暴涨有什

11-06 蔡贵霖: 计谋网站seo关键词暴涨有什么秘密

11-06 博益网首页:ao3网页版进入不了解决方法

11-06 漏斗子专栏: 网站数据分析小白易懂精华篇

11-06 见证双虹怎么做:win7系统开启telnet命令的

11-06 颾狐蝶蜋:系统资源不足无法完成请求的服务

11-06 国光中学校歌:提交网站到alexa查询详细步骤

11-06 西安有情天:静态网页和动态网页的区别

11-06 红木雅尚斋:外部链接构造对网站的好处

11-06 前官礼遇：防止域名劫持–增强域安全性的10

11-06 密传二转答案: 中文分词算法有哪些

11-06 金泉家园邮编:百度快照劫持的表现及应对方

Java C2dmConstants类代码示例发布时间：2022-05-23

Java ClassDescriptor类代码示例发布时间：2022-05-23

剪的笔顺,诠释剪的笔画,认识剪的部首

1 六六分期app的软件客服如何联系？(六六分期

六六分期app的软件客服如何联系？不知道吗？加qq群【895510560】即可！标题：六六分期

阅读：18962|2023-10-27

2 可心卡盟:win10系统火狐flash插件崩溃怎么

今天小编告诉大家如何处理win10系统火狐flash插件总是崩溃的问题，可能很多用户都不知

阅读：9915|2022-11-06

3 亲亲特价:怎么删除回收站图标

今天小编告诉大家如何对win10系统删除桌面回收站图标进行设置，可能很多用户都不知道

阅读：8301|2022-11-06

4 济南大学虚拟社区:鲁大师节能降温的具体办

今天小编告诉大家如何对win10系统电脑设置节能降温的设置方法，想必大家都遇到过需要

阅读：8664|2022-11-06

5 xlueops.exe:无线网络安装向导

我们在使用xp系统的过程中,经常需要对xp系统无线网络安装向导设置进行设置，可能很多

阅读：8598|2022-11-06

6 女斗合众国:win7系统cf与主机连接不稳定怎

今天小编告诉大家如何处理win7系统玩cf老是与主机连接不稳定的问题，可能很多用户都不

阅读：9606|2022-11-06

7 0xc000022-[cf烟雾头]cf怎么调烟雾头

电脑对日常生活的重要性小编就不多说了，可是一旦碰到win7系统设置cf烟雾头的问题，很

阅读：8588|2022-11-06

8 qizideyouhuo:应用程序无法正常启动0xc0000

我们在日常使用电脑的时候，有的小伙伴们可能在打开应用的时候会遇见提示应用程序无法

阅读：7973|2022-11-06

9 ipz-185:win7系统vcf文件怎么打开

今天小编告诉大家如何对win7系统打开vcf文件进行设置，可能很多用户都不知道怎么对win

阅读：8600|2022-11-06

10 傻哥蹦迪:win10系统s4怎么打开usb调试

今天小编告诉大家如何对win10系统s4开启USB调试模式进行设置，可能很多用户都不知道怎

阅读：7515|2022-11-06

客服电话

电子邮件

Java MetricsBuilder类代码示例

示例1: getMetrics

示例2: getMetrics

示例3: getMetrics

示例4: getMetrics

示例5: registerSystemSource

示例6: getMetrics

示例7: getMetrics

示例8: getMetrics

示例9: getMetrics

示例10: getMetrics

示例11: getMetrics

示例12: getMetrics

示例13: getMetrics

示例14: getMetrics

示例15: getMetrics

示例16: getMetrics

示例17: getMetrics

示例18: getMetrics

示例19: getMetrics

请发表评论

全部评论

上一篇：

下一篇：

微信小程序模板消息（服务通知消息）原始po

GaloyMoney/galoy-mobile

swcarpentry/matlab-novice-inflammation:

美国三一学院字怎么样？专业特色有哪些？

Twzy/MarkWord: a markdown editer

剪的笔顺,诠释剪的笔画,认识剪的部首

六六分期app的软件客服如何联系？(六六分期

florent37/ViewAnimator: A fluent Android

florent37/Shrine-MaterialDesign2: implem

CVE-2020-36276

SimpleSoftwareIO/simple-sms: Send and re

关于我们

产品与服务

解决方案

139-2527-9053