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