Java 类org.apache.hadoop.mapreduce.jobhistory.JhCounterGroup 实例源码

项目:hadoop    文件:LoggedTaskAttempt.java   
private static void incorporateCounter(SetField thunk, JhCounters counters,
    String counterName) {
  counterName = canonicalizeCounterName(counterName);

  for (JhCounterGroup group : counters.groups) {
    for (JhCounter counter : group.counts) {
      if (counterName
          .equals(canonicalizeCounterName(counter.name.toString()))) {
        thunk.set(counter.value);
        return;
      }
    }
  }
}
项目:hadoop    文件:LoggedTask.java   
private static void incorporateCounter(SetField thunk, JhCounters counters,
    String counterName) {
  counterName = canonicalizeCounterName(counterName);

  for (JhCounterGroup group : counters.groups) {
    for (JhCounter counter : group.counts) {
      if (counterName
          .equals(canonicalizeCounterName(counter.name.toString()))) {
        thunk.set(counter.value);
        return;
      }
    }
  }
}
项目:hadoop    文件:JobHistoryUtils.java   
/**
 * Extract/Add counters into the Map from the given JhCounters object.
 * @param counters the counters to be extracted from
 * @return the map of counters
 */
static Map<String, Long> extractCounters(JhCounters counters) {
  Map<String, Long> countersMap = new HashMap<String, Long>();
  if (counters != null) {
    for (JhCounterGroup group : counters.groups) {
      for (JhCounter counter : group.counts) {
        countersMap.put(counter.name.toString(), counter.value);
      }
    }
  }
  return countersMap;
}
项目:aliyun-oss-hadoop-fs    文件:LoggedTaskAttempt.java   
private static void incorporateCounter(SetField thunk, JhCounters counters,
    String counterName) {
  counterName = canonicalizeCounterName(counterName);

  for (JhCounterGroup group : counters.groups) {
    for (JhCounter counter : group.counts) {
      if (counterName
          .equals(canonicalizeCounterName(counter.name.toString()))) {
        thunk.set(counter.value);
        return;
      }
    }
  }
}
项目:aliyun-oss-hadoop-fs    文件:LoggedTask.java   
private static void incorporateCounter(SetField thunk, JhCounters counters,
    String counterName) {
  counterName = canonicalizeCounterName(counterName);

  for (JhCounterGroup group : counters.groups) {
    for (JhCounter counter : group.counts) {
      if (counterName
          .equals(canonicalizeCounterName(counter.name.toString()))) {
        thunk.set(counter.value);
        return;
      }
    }
  }
}
项目:aliyun-oss-hadoop-fs    文件:JobHistoryUtils.java   
/**
 * Extract/Add counters into the Map from the given JhCounters object.
 * @param counters the counters to be extracted from
 * @return the map of counters
 */
static Map<String, Long> extractCounters(JhCounters counters) {
  Map<String, Long> countersMap = new HashMap<String, Long>();
  if (counters != null) {
    for (JhCounterGroup group : counters.groups) {
      for (JhCounter counter : group.counts) {
        countersMap.put(counter.name.toString(), counter.value);
      }
    }
  }
  return countersMap;
}
项目:big-c    文件:LoggedTaskAttempt.java   
private static void incorporateCounter(SetField thunk, JhCounters counters,
    String counterName) {
  counterName = canonicalizeCounterName(counterName);

  for (JhCounterGroup group : counters.groups) {
    for (JhCounter counter : group.counts) {
      if (counterName
          .equals(canonicalizeCounterName(counter.name.toString()))) {
        thunk.set(counter.value);
        return;
      }
    }
  }
}
项目:big-c    文件:LoggedTask.java   
private static void incorporateCounter(SetField thunk, JhCounters counters,
    String counterName) {
  counterName = canonicalizeCounterName(counterName);

  for (JhCounterGroup group : counters.groups) {
    for (JhCounter counter : group.counts) {
      if (counterName
          .equals(canonicalizeCounterName(counter.name.toString()))) {
        thunk.set(counter.value);
        return;
      }
    }
  }
}
项目:big-c    文件:JobHistoryUtils.java   
/**
 * Extract/Add counters into the Map from the given JhCounters object.
 * @param counters the counters to be extracted from
 * @return the map of counters
 */
static Map<String, Long> extractCounters(JhCounters counters) {
  Map<String, Long> countersMap = new HashMap<String, Long>();
  if (counters != null) {
    for (JhCounterGroup group : counters.groups) {
      for (JhCounter counter : group.counts) {
        countersMap.put(counter.name.toString(), counter.value);
      }
    }
  }
  return countersMap;
}
项目:hadoop-2.6.0-cdh5.4.3    文件:LoggedTaskAttempt.java   
private static void incorporateCounter(SetField thunk, JhCounters counters,
    String counterName) {
  counterName = canonicalizeCounterName(counterName);

  for (JhCounterGroup group : counters.groups) {
    for (JhCounter counter : group.counts) {
      if (counterName
          .equals(canonicalizeCounterName(counter.name.toString()))) {
        thunk.set(counter.value);
        return;
      }
    }
  }
}
项目:hadoop-2.6.0-cdh5.4.3    文件:LoggedTask.java   
private static void incorporateCounter(SetField thunk, JhCounters counters,
    String counterName) {
  counterName = canonicalizeCounterName(counterName);

  for (JhCounterGroup group : counters.groups) {
    for (JhCounter counter : group.counts) {
      if (counterName
          .equals(canonicalizeCounterName(counter.name.toString()))) {
        thunk.set(counter.value);
        return;
      }
    }
  }
}
项目:hadoop-2.6.0-cdh5.4.3    文件:JobHistoryUtils.java   
/**
 * Extract/Add counters into the Map from the given JhCounters object.
 * @param counters the counters to be extracted from
 * @return the map of counters
 */
static Map<String, Long> extractCounters(JhCounters counters) {
  Map<String, Long> countersMap = new HashMap<String, Long>();
  if (counters != null) {
    for (JhCounterGroup group : counters.groups) {
      for (JhCounter counter : group.counts) {
        countersMap.put(counter.name.toString(), counter.value);
      }
    }
  }
  return countersMap;
}
项目:hadoop-plus    文件:LoggedTaskAttempt.java   
private static void incorporateCounter(SetField thunk, JhCounters counters,
    String counterName) {
  counterName = canonicalizeCounterName(counterName);

  for (JhCounterGroup group : counters.groups) {
    for (JhCounter counter : group.counts) {
      if (counterName
          .equals(canonicalizeCounterName(counter.name.toString()))) {
        thunk.set(counter.value);
        return;
      }
    }
  }
}
项目:hadoop-plus    文件:LoggedTask.java   
private static void incorporateCounter(SetField thunk, JhCounters counters,
    String counterName) {
  counterName = canonicalizeCounterName(counterName);

  for (JhCounterGroup group : counters.groups) {
    for (JhCounter counter : group.counts) {
      if (counterName
          .equals(canonicalizeCounterName(counter.name.toString()))) {
        thunk.set(counter.value);
        return;
      }
    }
  }
}
项目:hadoop-plus    文件:JobHistoryUtils.java   
/**
 * Extract/Add counters into the Map from the given JhCounters object.
 * @param counters the counters to be extracted from
 * @return the map of counters
 */
static Map<String, Long> extractCounters(JhCounters counters) {
  Map<String, Long> countersMap = new HashMap<String, Long>();
  if (counters != null) {
    for (JhCounterGroup group : counters.groups) {
      for (JhCounter counter : group.counts) {
        countersMap.put(counter.name.toString(), counter.value);
      }
    }
  }
  return countersMap;
}
项目:hops    文件:LoggedTaskAttempt.java   
private static void incorporateCounter(SetField thunk, JhCounters counters,
    String counterName) {
  counterName = canonicalizeCounterName(counterName);

  for (JhCounterGroup group : counters.groups) {
    for (JhCounter counter : group.counts) {
      if (counterName
          .equals(canonicalizeCounterName(counter.name.toString()))) {
        thunk.set(counter.value);
        return;
      }
    }
  }
}
项目:hops    文件:LoggedTask.java   
private static void incorporateCounter(SetField thunk, JhCounters counters,
    String counterName) {
  counterName = canonicalizeCounterName(counterName);

  for (JhCounterGroup group : counters.groups) {
    for (JhCounter counter : group.counts) {
      if (counterName
          .equals(canonicalizeCounterName(counter.name.toString()))) {
        thunk.set(counter.value);
        return;
      }
    }
  }
}
项目:hops    文件:JobHistoryUtils.java   
/**
 * Extract/Add counters into the Map from the given JhCounters object.
 * @param counters the counters to be extracted from
 * @return the map of counters
 */
static Map<String, Long> extractCounters(JhCounters counters) {
  Map<String, Long> countersMap = new HashMap<String, Long>();
  if (counters != null) {
    for (JhCounterGroup group : counters.groups) {
      for (JhCounter counter : group.counts) {
        countersMap.put(counter.name.toString(), counter.value);
      }
    }
  }
  return countersMap;
}
项目:hadoop-TCP    文件:LoggedTaskAttempt.java   
private static void incorporateCounter(SetField thunk, JhCounters counters,
    String counterName) {
  counterName = canonicalizeCounterName(counterName);

  for (JhCounterGroup group : counters.groups) {
    for (JhCounter counter : group.counts) {
      if (counterName
          .equals(canonicalizeCounterName(counter.name.toString()))) {
        thunk.set(counter.value);
        return;
      }
    }
  }
}
项目:hadoop-TCP    文件:LoggedTask.java   
private static void incorporateCounter(SetField thunk, JhCounters counters,
    String counterName) {
  counterName = canonicalizeCounterName(counterName);

  for (JhCounterGroup group : counters.groups) {
    for (JhCounter counter : group.counts) {
      if (counterName
          .equals(canonicalizeCounterName(counter.name.toString()))) {
        thunk.set(counter.value);
        return;
      }
    }
  }
}
项目:hadoop-TCP    文件:JobHistoryUtils.java   
/**
 * Extract/Add counters into the Map from the given JhCounters object.
 * @param counters the counters to be extracted from
 * @return the map of counters
 */
static Map<String, Long> extractCounters(JhCounters counters) {
  Map<String, Long> countersMap = new HashMap<String, Long>();
  if (counters != null) {
    for (JhCounterGroup group : counters.groups) {
      for (JhCounter counter : group.counts) {
        countersMap.put(counter.name.toString(), counter.value);
      }
    }
  }
  return countersMap;
}
项目:hardfs    文件:LoggedTaskAttempt.java   
private static void incorporateCounter(SetField thunk, JhCounters counters,
    String counterName) {
  counterName = canonicalizeCounterName(counterName);

  for (JhCounterGroup group : counters.groups) {
    for (JhCounter counter : group.counts) {
      if (counterName
          .equals(canonicalizeCounterName(counter.name.toString()))) {
        thunk.set(counter.value);
        return;
      }
    }
  }
}
项目:hardfs    文件:LoggedTask.java   
private static void incorporateCounter(SetField thunk, JhCounters counters,
    String counterName) {
  counterName = canonicalizeCounterName(counterName);

  for (JhCounterGroup group : counters.groups) {
    for (JhCounter counter : group.counts) {
      if (counterName
          .equals(canonicalizeCounterName(counter.name.toString()))) {
        thunk.set(counter.value);
        return;
      }
    }
  }
}
项目:hardfs    文件:JobHistoryUtils.java   
/**
 * Extract/Add counters into the Map from the given JhCounters object.
 * @param counters the counters to be extracted from
 * @return the map of counters
 */
static Map<String, Long> extractCounters(JhCounters counters) {
  Map<String, Long> countersMap = new HashMap<String, Long>();
  if (counters != null) {
    for (JhCounterGroup group : counters.groups) {
      for (JhCounter counter : group.counts) {
        countersMap.put(counter.name.toString(), counter.value);
      }
    }
  }
  return countersMap;
}
项目:hadoop-on-lustre2    文件:LoggedTaskAttempt.java   
private static void incorporateCounter(SetField thunk, JhCounters counters,
    String counterName) {
  counterName = canonicalizeCounterName(counterName);

  for (JhCounterGroup group : counters.groups) {
    for (JhCounter counter : group.counts) {
      if (counterName
          .equals(canonicalizeCounterName(counter.name.toString()))) {
        thunk.set(counter.value);
        return;
      }
    }
  }
}
项目:hadoop-on-lustre2    文件:LoggedTask.java   
private static void incorporateCounter(SetField thunk, JhCounters counters,
    String counterName) {
  counterName = canonicalizeCounterName(counterName);

  for (JhCounterGroup group : counters.groups) {
    for (JhCounter counter : group.counts) {
      if (counterName
          .equals(canonicalizeCounterName(counter.name.toString()))) {
        thunk.set(counter.value);
        return;
      }
    }
  }
}
项目:hadoop-on-lustre2    文件:JobHistoryUtils.java   
/**
 * Extract/Add counters into the Map from the given JhCounters object.
 * @param counters the counters to be extracted from
 * @return the map of counters
 */
static Map<String, Long> extractCounters(JhCounters counters) {
  Map<String, Long> countersMap = new HashMap<String, Long>();
  if (counters != null) {
    for (JhCounterGroup group : counters.groups) {
      for (JhCounter counter : group.counts) {
        countersMap.put(counter.name.toString(), counter.value);
      }
    }
  }
  return countersMap;
}
项目:mapreduce-fork    文件:LoggedTaskAttempt.java   
private static void incorporateCounter(SetField thunk, JhCounters counters,
    String counterName) {
  counterName = canonicalizeCounterName(counterName);

  for (JhCounterGroup group : counters.groups) {
    for (JhCounter counter : group.counts) {
      if (counterName
          .equals(canonicalizeCounterName(counter.name.toString()))) {
        thunk.set(counter.value);
        return;
      }
    }
  }
}
项目:mapreduce-fork    文件:LoggedTask.java   
private static void incorporateCounter(SetField thunk, JhCounters counters,
    String counterName) {
  counterName = canonicalizeCounterName(counterName);

  for (JhCounterGroup group : counters.groups) {
    for (JhCounter counter : group.counts) {
      if (counterName
          .equals(canonicalizeCounterName(counter.name.toString()))) {
        thunk.set(counter.value);
        return;
      }
    }
  }
}