org.apache.hadoop.metrics2.annotation.Metrics.<init>()方法的使用及代码示例

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

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

Metrics.<init>介绍

暂无

代码示例

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

@Metrics(about = "LlapDaemon JVM Metrics", context = "jvm")
public class LlapDaemonJvmMetrics implements MetricsSource {
 private final String name;

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

@Metrics(about = "LlapDaemon IO Metrics", context = "io")
public class LlapDaemonIOMetrics implements MetricsSource {
 protected static final Logger LOG = LoggerFactory.getLogger(LlapDaemonIOMetrics.class);

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

@Metrics(about="Shuffle output metrics", context="mapred")
static class ShuffleMetrics implements ChannelFutureListener {
 @Metric("Shuffle output in bytes")
 MutableCounterLong shuffleOutputBytes;
 @Metric("# of failed shuffle outputs")
 MutableCounterInt shuffleOutputsFailed;
 @Metric("# of succeeded shuffle outputs")
 MutableCounterInt shuffleOutputsOK;
 @Metric("# of current shuffle connections")
 MutableGaugeInt shuffleConnections;
 @Override
 public void operationComplete(ChannelFuture future) throws Exception {
  if (future.isSuccess()) {
   shuffleOutputsOK.incr();
  } else {
   shuffleOutputsFailed.incr();
  }
  shuffleConnections.decr();
 }
}

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

@Metrics(about="Per method RPC metrics", context="rpcdetailed")
public class RpcDetailedMetrics {

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

@Metrics(about="Aggregate RetryCache metrics", context="rpc")
public class RetryCacheMetrics {

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

@Metrics(about="User and group related metrics", context="ugi")
static class UgiMetrics {
 final MetricsRegistry registry = new MetricsRegistry("UgiMetrics");

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

@Metrics(name = "Query", about = "Query metrics", context = "Kylin")
public class QueryMetrics {

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

@Metrics(context="metricssystem")
public class MetricsSystemImpl extends MetricsSystem implements MetricsSource {

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

@Metrics(about = "LlapDaemon Cache Metrics", context = "cache")
public class LlapDaemonCacheMetrics implements MetricsSource {
 final String name;

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

@Metrics(about="Journal client metrics", context="dfs")
class IPCLoggerChannelMetrics {
 final MetricsRegistry registry = new MetricsRegistry("NameNode");

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

@Metrics(about="Aggregate RPC metrics", context="rpc")
public class RpcMetrics {

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

@Metrics(about = "Llap Task Scheduler Metrics", context = "scheduler")
public class LlapTaskSchedulerMetrics implements MetricsSource {
 private final String name;

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

@Metrics(about = "LlapDaemon Executor Metrics", context = "executors")
public class LlapDaemonExecutorMetrics implements MetricsSource {

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

@Metrics(about="Journal metrics", context="dfs")
class JournalMetrics {
 final MetricsRegistry registry = new MetricsRegistry("JournalNode");

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

@Metrics(context="dfs")
public class FSNamesystem implements Namesystem, FSNamesystemMBean,
  NameNodeMXBean, ReplicatedBlocksMBean, ECBlockGroupsMBean {

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

@Metrics(context="test")
private static class TestSource {
 @Metric("C1 desc") MutableCounterLong c1;
 @Metric("XXX desc") MutableCounterLong xxx;
 @Metric("G1 desc") MutableGaugeLong g1;
 @Metric("YYY desc") MutableGaugeLong yyy;
 @Metric MutableRate s1;
 final MetricsRegistry registry;
 TestSource(String recName) {
  registry = new MetricsRegistry(recName);
 }
}

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

@Metrics(name = "DataNodeVolume", about = "DataNode Volume metrics",
  context = "dfs")
public class DataNodeVolumeMetrics {

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

@Metrics(context="hybrid")
static class BadHybridMetrics implements MetricsSource {
 @Metric MutableCounterInt c1;
 @Override
 public void getMetrics(MetricsCollector collector, boolean all) {
  collector.addRecord("foo");
 }
}

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

@Metrics(name="NameNodeActivity", about="NameNode metrics", context="dfs")
public class NameNodeMetrics {
 final MetricsRegistry registry = new MetricsRegistry("namenode");

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

@Metrics(about="DataNode metrics", context="dfs")
public class DataNodeMetrics {

相关文章