org.apache.hadoop.metrics2.lib.MetricsRegistry.newCounter()方法的使用及代码示例

x33g5p2x  于2022-01-25 转载在 其他  
字(5.9k)|赞(0)|评价(0)|浏览(96)

本文整理了Java中org.apache.hadoop.metrics2.lib.MetricsRegistry.newCounter()方法的一些代码示例,展示了MetricsRegistry.newCounter()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。MetricsRegistry.newCounter()方法的具体详情如下:
包路径:org.apache.hadoop.metrics2.lib.MetricsRegistry
类名称:MetricsRegistry
方法名:newCounter

MetricsRegistry.newCounter介绍

[英]Create a mutable integer counter
[中]创建可变整数计数器

代码示例

代码示例来源:origin: org.apache.hadoop/hadoop-common

/**
 * Create a mutable integer counter
 * @param name  of the metric
 * @param desc  metric description
 * @param iVal  initial value
 * @return a new counter object
 */
public MutableCounterInt newCounter(String name, String desc, int iVal) {
 return newCounter(Interns.info(name, desc), iVal);
}

代码示例来源:origin: org.apache.hadoop/hadoop-common

/**
 * Create a mutable long integer counter
 * @param name  of the metric
 * @param desc  metric description
 * @param iVal  initial value
 * @return a new counter object
 */
public MutableCounterLong newCounter(String name, String desc, long iVal) {
 return newCounter(Interns.info(name, desc), iVal);
}

代码示例来源:origin: org.apache.hadoop/hadoop-common

queueCapacity > 0, "queue capacity"));
latency = registry.newRate("Sink_"+ name, "Sink end to end latency", false);
dropped = registry.newCounter("Sink_"+ name +"Dropped",
               "Dropped updates per sink", 0);
qsize = registry.newGauge("Sink_"+ name + "Qsize", "Queue size", 0);

代码示例来源:origin: org.apache.hadoop/hadoop-common

return registry.newCounter(info, 0);
return registry.newCounter(info, 0L);

代码示例来源:origin: apache/accumulo

Metrics2TabletServerUpdateMetrics(MetricsSystem system) {
 this.system = system;
 this.registry = new MetricsRegistry(Interns.info(NAME, DESCRIPTION));
 this.registry.tag(MsInfo.ProcessName, MetricsSystemHelper.getProcessName());
 permissionErrorsCounter = registry
   .newCounter(Interns.info(PERMISSION_ERRORS, "Permission Errors"), 0L);
 unknownTabletErrorsCounter = registry
   .newCounter(Interns.info(UNKNOWN_TABLET_ERRORS, "Unknown Tablet Errors"), 0L);
 constraintViolationsCounter = registry
   .newCounter(Interns.info(CONSTRAINT_VIOLATIONS, "Table Constraint Violations"), 0L);
 commitPrepStat = registry.newStat(COMMIT_PREP, "preparing to commit mutations", "Ops", "Time",
   true);
 walogWriteTimeStat = registry.newStat(WALOG_WRITE_TIME, "writing mutations to WAL", "Ops",
   "Time", true);
 commitTimeStat = registry.newStat(COMMIT_TIME, "committing mutations", "Ops", "Time", true);
 mutationArraySizeStat = registry.newStat(MUTATION_ARRAY_SIZE, "mutation array", "ops", "Size",
   true);
}

代码示例来源:origin: org.apache.hadoop/hadoop-aws

/**
 * Create a counter in the registry.
 * @param name counter name
 * @param desc counter description
 * @return a new counter
 */
protected final MutableCounterLong counter(String name, String desc) {
 return registry.newCounter(name, desc, 0L);
}

代码示例来源:origin: io.hops/hadoop-common

/**
 * Create a mutable long integer counter
 * @param name  of the metric
 * @param desc  metric description
 * @param iVal  initial value
 * @return a new counter object
 */
public MutableCounterLong newCounter(String name, String desc, long iVal) {
 return newCounter(Interns.info(name, desc), iVal);
}

代码示例来源:origin: com.github.jiayuhan-it/hadoop-common

/**
 * Create a mutable long integer counter
 * @param name  of the metric
 * @param desc  metric description
 * @param iVal  initial value
 * @return a new counter object
 */
public MutableCounterLong newCounter(String name, String desc, long iVal) {
 return newCounter(Interns.info(name, desc), iVal);
}

代码示例来源:origin: io.prestosql.hadoop/hadoop-apache

/**
 * Create a mutable long integer counter
 * @param name  of the metric
 * @param desc  metric description
 * @param iVal  initial value
 * @return a new counter object
 */
public MutableCounterLong newCounter(String name, String desc, long iVal) {
 return newCounter(Interns.info(name, desc), iVal);
}

代码示例来源:origin: io.hops/hadoop-common

/**
 * Create a mutable integer counter
 * @param name  of the metric
 * @param desc  metric description
 * @param iVal  initial value
 * @return a new counter object
 */
public MutableCounterInt newCounter(String name, String desc, int iVal) {
 return newCounter(Interns.info(name, desc), iVal);
}

代码示例来源:origin: ch.cern.hadoop/hadoop-common

/**
 * Create a mutable long integer counter
 * @param name  of the metric
 * @param desc  metric description
 * @param iVal  initial value
 * @return a new counter object
 */
public MutableCounterLong newCounter(String name, String desc, long iVal) {
 return newCounter(Interns.info(name, desc), iVal);
}

代码示例来源:origin: com.github.jiayuhan-it/hadoop-common

/**
 * Create a mutable integer counter
 * @param name  of the metric
 * @param desc  metric description
 * @param iVal  initial value
 * @return a new counter object
 */
public MutableCounterInt newCounter(String name, String desc, int iVal) {
 return newCounter(Interns.info(name, desc), iVal);
}

代码示例来源:origin: io.prestosql.hadoop/hadoop-apache

/**
 * Create a mutable integer counter
 * @param name  of the metric
 * @param desc  metric description
 * @param iVal  initial value
 * @return a new counter object
 */
public MutableCounterInt newCounter(String name, String desc, int iVal) {
 return newCounter(Interns.info(name, desc), iVal);
}

代码示例来源:origin: ch.cern.hadoop/hadoop-common

/**
 * Create a mutable integer counter
 * @param name  of the metric
 * @param desc  metric description
 * @param iVal  initial value
 * @return a new counter object
 */
public MutableCounterInt newCounter(String name, String desc, int iVal) {
 return newCounter(Interns.info(name, desc), iVal);
}

代码示例来源:origin: ch.cern.hadoop/hadoop-common

@Override
 public void run() { r.newCounter("c1", "test dup", 0); }
});

代码示例来源:origin: com.github.jiayuhan-it/hadoop-common

@Override
 public void run() { r.newCounter("c1", "test dup", 0); }
});

代码示例来源:origin: ch.cern.hadoop/hadoop-common

@Override
 public void run() { r.newCounter("withnewline6\n", "c6 desc", 6); }
});

代码示例来源:origin: com.github.jiayuhan-it/hadoop-common

@Override
 public void run() { r.newCounter("badcount3  ", "c3 desc", 3); }
});

代码示例来源:origin: com.github.jiayuhan-it/hadoop-common

@Override
 public void run() { r.newCounter("  badcount4", "c4 desc", 4); }
});

代码示例来源:origin: ch.cern.hadoop/hadoop-common

@Override
 public void run() { r.newCounter("  badcount4", "c4 desc", 4); }
});

相关文章