org.apache.hadoop.yarn.server.resourcemanager.scheduler.QueueMetrics.<init>()方法的使用及代码示例

x33g5p2x  于2022-01-28 转载在 其他  
字(3.8k)|赞(0)|评价(0)|浏览(79)

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

QueueMetrics.<init>介绍

暂无

代码示例

代码示例来源:origin: ch.cern.hadoop/hadoop-yarn-server-resourcemanager

public synchronized QueueMetrics getUserMetrics(String userName) {
 if (users == null) {
  return null;
 }
 QueueMetrics metrics = users.get(userName);
 if (metrics == null) {
  metrics = new QueueMetrics(metricsSystem, queueName, null, false, conf);
  users.put(userName, metrics);
  metricsSystem.register(
    sourceName(queueName).append(",user=").append(userName).toString(),
    "Metrics for user '"+ userName +"' in queue '"+ queueName +"'",
    metrics.tag(QUEUE_INFO, queueName).tag(USER_INFO, userName));
 }
 return metrics;
}

代码示例来源:origin: org.apache.hadoop/hadoop-yarn-server-resourcemanager

public synchronized QueueMetrics getUserMetrics(String userName) {
 if (users == null) {
  return null;
 }
 QueueMetrics metrics = users.get(userName);
 if (metrics == null) {
  metrics = new QueueMetrics(metricsSystem, queueName, null, false, conf);
  users.put(userName, metrics);
  metricsSystem.register(
    sourceName(queueName).append(",user=").append(userName).toString(),
    "Metrics for user '"+ userName +"' in queue '"+ queueName +"'",
    metrics.tag(QUEUE_INFO, queueName).tag(USER_INFO, userName));
 }
 return metrics;
}

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

public synchronized QueueMetrics getUserMetrics(String userName) {
 if (users == null) {
  return null;
 }
 QueueMetrics metrics = users.get(userName);
 if (metrics == null) {
  metrics = new QueueMetrics(metricsSystem, queueName, null, false, conf);
  users.put(userName, metrics);
  metricsSystem.register(
    sourceName(queueName).append(",user=").append(userName).toString(),
    "Metrics for user '"+ userName +"' in queue '"+ queueName +"'",
    metrics.tag(QUEUE_INFO, queueName).tag(USER_INFO, userName));
 }
 return metrics;
}

代码示例来源:origin: ch.cern.hadoop/hadoop-yarn-server-resourcemanager

public synchronized 
static QueueMetrics forQueue(MetricsSystem ms, String queueName,
                  Queue parent, boolean enableUserMetrics,
          Configuration conf) {
 QueueMetrics metrics = queueMetrics.get(queueName);
 if (metrics == null) {
  metrics =
    new QueueMetrics(ms, queueName, parent, enableUserMetrics, conf).
    tag(QUEUE_INFO, queueName);
  
  // Register with the MetricsSystems
  if (ms != null) {
   metrics = 
     ms.register(
       sourceName(queueName).toString(), 
       "Metrics for queue: " + queueName, metrics);
  }
  queueMetrics.put(queueName, metrics);
 }
 return metrics;
}

代码示例来源:origin: org.apache.hadoop/hadoop-yarn-server-resourcemanager

public synchronized 
static QueueMetrics forQueue(MetricsSystem ms, String queueName,
                  Queue parent, boolean enableUserMetrics,
          Configuration conf) {
 QueueMetrics metrics = QUEUE_METRICS.get(queueName);
 if (metrics == null) {
  metrics =
    new QueueMetrics(ms, queueName, parent, enableUserMetrics, conf).
    tag(QUEUE_INFO, queueName);
  
  // Register with the MetricsSystems
  if (ms != null) {
   metrics = 
     ms.register(
       sourceName(queueName).toString(), 
       "Metrics for queue: " + queueName, metrics);
  }
  QUEUE_METRICS.put(queueName, metrics);
 }
 return metrics;
}

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

public synchronized 
static QueueMetrics forQueue(MetricsSystem ms, String queueName,
                  Queue parent, boolean enableUserMetrics,
          Configuration conf) {
 QueueMetrics metrics = queueMetrics.get(queueName);
 if (metrics == null) {
  metrics =
    new QueueMetrics(ms, queueName, parent, enableUserMetrics, conf).
    tag(QUEUE_INFO, queueName);
  
  // Register with the MetricsSystems
  if (ms != null) {
   metrics = 
     ms.register(
       sourceName(queueName).toString(), 
       "Metrics for queue: " + queueName, metrics);
  }
  queueMetrics.put(queueName, metrics);
 }
 return metrics;
}

相关文章

微信公众号

最新文章

更多

QueueMetrics类方法