import org.apache.hadoop.metrics2.source.JvmMetricsSource; //导入依赖的package包/类
synchronized void init(String name) {
  if (inited) return;
  inited = true;
  DefaultMetricsSystem.initialize(HBASE_METRICS_SYSTEM_NAME);
  jvmMetricsSource = JvmMetricsSource.create(name, "");

}
 

import org.apache.hadoop.metrics2.source.JvmMetricsSource; //导入依赖的package包/类
public TaskTrackerMetricsSource(TaskTracker tt) {
  super(tt);
  String sessionId = tt.getJobConf().getSessionId();
  JvmMetricsSource.create("TaskTracker", sessionId);
  registry.setContext("mapred").tag("sessionId", "", sessionId);
}
 

import org.apache.hadoop.metrics2.source.JvmMetricsSource; //导入依赖的package包/类
public JobTrackerMetricsSource(JobTracker jt, JobConf conf) {
  super(jt, conf);
  sessionId = conf.getSessionId();
  registry.setContext("mapred").tag("sessionId", "", sessionId);
  JvmMetricsSource.create("JobTracker", sessionId);
}
 

import org.apache.hadoop.metrics2.source.JvmMetricsSource; //导入依赖的package包/类
private static void initMetrics(String prefix, String procName,
                                String sessionId) {
  DefaultMetricsSystem.initialize(prefix);  
  JvmMetricsSource.create(procName, sessionId);
}
 

import org.apache.hadoop.metrics2.source.JvmMetricsSource; //导入依赖的package包/类
NameNodeInstrumentation(Configuration conf) {
  sessionId = conf.get("session.id");
  JvmMetricsSource.create("NameNode", sessionId);
  registry.setContext("dfs").tag("sessionId", "", sessionId);
}
 

import org.apache.hadoop.metrics2.source.JvmMetricsSource; //导入依赖的package包/类
public DataNodeInstrumentation(Configuration conf, String storageId) {
  String sessionId = conf.get("session.id");
  JvmMetricsSource.create("DataNode", sessionId);
  registry.setContext("dfs").tag("sessionId", "", sessionId);
}