public class HadoopNodeCounterCache extends HadoopCounterCache<FlowNodeStats,Map<String,Map<String,Long>>>
configuration, COUNTER_FETCH_RETRIES_PROPERTY, COUNTER_MAX_AGE_PROPERTY, COUNTER_TIMEOUT_PROPERTY, DEFAULT_CACHED_AGE_MAX, DEFAULT_FETCH_RETRIES, DEFAULT_NODE_CACHED_AGE_MAX, DEFAULT_TIMEOUT_TIMEOUT_SEC, fetchAttempts, maxAge, maxFetchAttempts, NODE_COUNTER_MAX_AGE_PROPERTY, timeout
Modifier | Constructor and Description |
---|---|
protected |
HadoopNodeCounterCache(FlowNodeStats flowNodeStats,
Configuration configuration) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
areCountersAvailable(FlowNodeStats runningJob) |
protected Map<String,Map<String,Long>> |
getCounters(FlowNodeStats flowNodeStats) |
protected Set<String> |
getCountersFor(Map<String,Map<String,Long>> counters,
String group) |
protected long |
getCounterValue(Map<String,Map<String,Long>> counters,
Enum counter) |
protected long |
getCounterValue(Map<String,Map<String,Long>> counters,
String groupName,
String counterName) |
protected Collection<String> |
getGroupNames(Map<String,Map<String,Long>> groups) |
protected FlowNodeStats |
getJobStatusClient() |
getIntProperty
cachedCounters, cachedCounters, getCounterGroups, getCounterGroupsMatching, getCountersFor, getCounterValue, getCounterValue, getLastSuccessfulFetch
protected HadoopNodeCounterCache(FlowNodeStats flowNodeStats, Configuration configuration)
protected FlowNodeStats getJobStatusClient()
getJobStatusClient
in class CounterCache<Configuration,FlowNodeStats,Map<String,Map<String,Long>>>
protected boolean areCountersAvailable(FlowNodeStats runningJob)
areCountersAvailable
in class CounterCache<Configuration,FlowNodeStats,Map<String,Map<String,Long>>>
protected Map<String,Map<String,Long>> getCounters(FlowNodeStats flowNodeStats) throws IOException
getCounters
in class CounterCache<Configuration,FlowNodeStats,Map<String,Map<String,Long>>>
IOException
protected Collection<String> getGroupNames(Map<String,Map<String,Long>> groups)
getGroupNames
in class CounterCache<Configuration,FlowNodeStats,Map<String,Map<String,Long>>>
protected Set<String> getCountersFor(Map<String,Map<String,Long>> counters, String group)
getCountersFor
in class CounterCache<Configuration,FlowNodeStats,Map<String,Map<String,Long>>>
protected long getCounterValue(Map<String,Map<String,Long>> counters, Enum counter)
getCounterValue
in class CounterCache<Configuration,FlowNodeStats,Map<String,Map<String,Long>>>
protected long getCounterValue(Map<String,Map<String,Long>> counters, String groupName, String counterName)
getCounterValue
in class CounterCache<Configuration,FlowNodeStats,Map<String,Map<String,Long>>>
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.