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

项目：hadoop 文件：ParsedTask.java

public void incorporateCounters(JhCounters counters) {
  Map<String, Long> countersMap =
      JobHistoryUtils.extractCounters(counters);
  putCounters(countersMap);

  super.incorporateCounters(counters);
}

项目：hadoop 文件：ParsedTaskAttempt.java

/** incorporate event counters */
public void incorporateCounters(JhCounters counters) {

  Map<String, Long> countersMap =
    JobHistoryUtils.extractCounters(counters);
  putCounters(countersMap);

  super.incorporateCounters(counters);
}

项目：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

public void incorporateCounters(JhCounters counters) {
  switch (taskType) {
  case MAP:
    incorporateMapCounters(counters);
    return;
  case REDUCE:
    incorporateReduceCounters(counters);
    return;
    // NOT exhaustive
  }
}

项目：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 文件：ParsedTask.java

public void incorporateCounters(JhCounters counters) {
  Map<String, Long> countersMap =
      JobHistoryUtils.extractCounters(counters);
  putCounters(countersMap);

  super.incorporateCounters(counters);
}

项目：aliyun-oss-hadoop-fs 文件：ParsedTaskAttempt.java

/** incorporate event counters */
public void incorporateCounters(JhCounters counters) {

  Map<String, Long> countersMap =
    JobHistoryUtils.extractCounters(counters);
  putCounters(countersMap);

  super.incorporateCounters(counters);
}

项目：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

public void incorporateCounters(JhCounters counters) {
  switch (taskType) {
  case MAP:
    incorporateMapCounters(counters);
    return;
  case REDUCE:
    incorporateReduceCounters(counters);
    return;
    // NOT exhaustive
  }
}

项目：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 文件：ParsedTask.java

public void incorporateCounters(JhCounters counters) {
  Map<String, Long> countersMap =
      JobHistoryUtils.extractCounters(counters);
  putCounters(countersMap);

  super.incorporateCounters(counters);
}

项目：big-c 文件：ParsedTaskAttempt.java

/** incorporate event counters */
public void incorporateCounters(JhCounters counters) {

  Map<String, Long> countersMap =
    JobHistoryUtils.extractCounters(counters);
  putCounters(countersMap);

  super.incorporateCounters(counters);
}

项目：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

public void incorporateCounters(JhCounters counters) {
  switch (taskType) {
  case MAP:
    incorporateMapCounters(counters);
    return;
  case REDUCE:
    incorporateReduceCounters(counters);
    return;
    // NOT exhaustive
  }
}

项目：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 文件：ParsedTask.java

public void incorporateCounters(JhCounters counters) {
  Map<String, Long> countersMap =
      JobHistoryUtils.extractCounters(counters);
  putCounters(countersMap);

  super.incorporateCounters(counters);
}

项目：hadoop-2.6.0-cdh5.4.3 文件：ParsedTaskAttempt.java

/** incorporate event counters */
public void incorporateCounters(JhCounters counters) {

  Map<String, Long> countersMap =
    JobHistoryUtils.extractCounters(counters);
  putCounters(countersMap);

  super.incorporateCounters(counters);
}

项目：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

public void incorporateCounters(JhCounters counters) {
  switch (taskType) {
  case MAP:
    incorporateMapCounters(counters);
    return;
  case REDUCE:
    incorporateReduceCounters(counters);
    return;
    // NOT exhaustive
  }
}

项目：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 文件：ParsedTask.java

public void incorporateCounters(JhCounters counters) {
  Map<String, Long> countersMap =
      JobHistoryUtils.extractCounters(counters);
  putCounters(countersMap);

  super.incorporateCounters(counters);
}

项目：hadoop-plus 文件：ParsedTaskAttempt.java

/** incorporate event counters */
public void incorporateCounters(JhCounters counters) {

  Map<String, Long> countersMap =
    JobHistoryUtils.extractCounters(counters);
  putCounters(countersMap);

  super.incorporateCounters(counters);
}

项目：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

public void incorporateCounters(JhCounters counters) {
  switch (taskType) {
  case MAP:
    incorporateMapCounters(counters);
    return;
  case REDUCE:
    incorporateReduceCounters(counters);
    return;
    // NOT exhaustive
  }
}

项目：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 文件：ParsedTask.java

public void incorporateCounters(JhCounters counters) {
  Map<String, Long> countersMap =
      JobHistoryUtils.extractCounters(counters);
  putCounters(countersMap);

  super.incorporateCounters(counters);
}

项目：hops 文件：ParsedTaskAttempt.java

/** incorporate event counters */
public void incorporateCounters(JhCounters counters) {

  Map<String, Long> countersMap =
    JobHistoryUtils.extractCounters(counters);
  putCounters(countersMap);

  super.incorporateCounters(counters);
}

项目：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

public void incorporateCounters(JhCounters counters) {
  switch (taskType) {
  case MAP:
    incorporateMapCounters(counters);
    return;
  case REDUCE:
    incorporateReduceCounters(counters);
    return;
    // NOT exhaustive
  }
}

项目：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 文件：ParsedTask.java

public void incorporateCounters(JhCounters counters) {
  Map<String, Long> countersMap =
      JobHistoryUtils.extractCounters(counters);
  putCounters(countersMap);

  super.incorporateCounters(counters);
}

项目：hadoop-TCP 文件：ParsedTaskAttempt.java

/** incorporate event counters */
public void incorporateCounters(JhCounters counters) {

  Map<String, Long> countersMap =
    JobHistoryUtils.extractCounters(counters);
  putCounters(countersMap);

  super.incorporateCounters(counters);
}

项目：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

public void incorporateCounters(JhCounters counters) {
  switch (taskType) {
  case MAP:
    incorporateMapCounters(counters);
    return;
  case REDUCE:
    incorporateReduceCounters(counters);
    return;
    // NOT exhaustive
  }
}