本文整理了Java中org.apache.hadoop.metrics2.lib.MetricsRegistry.newCounter()
方法的一些代码示例,展示了MetricsRegistry.newCounter()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。MetricsRegistry.newCounter()
方法的具体详情如下:
包路径:org.apache.hadoop.metrics2.lib.MetricsRegistry
类名称: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); }
});
内容来源于网络,如有侵权,请联系作者删除!