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

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