public abstract class HadoopStepCounterCache extends HadoopCounterCache<RunningJob,Counters>
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 |
HadoopStepCounterCache(CascadingStats stats,
Configuration configuration) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
areCountersAvailable(RunningJob runningJob) |
protected Counters |
getCounters(RunningJob runningJob) |
protected Set<String> |
getCountersFor(Counters counters,
String group) |
protected long |
getCounterValue(Counters counters,
Enum counter) |
protected long |
getCounterValue(Counters counters,
String groupName,
String counterName) |
protected Collection<String> |
getGroupNames(Counters groups) |
getIntProperty
cachedCounters, cachedCounters, getCounterGroups, getCounterGroupsMatching, getCountersFor, getCounterValue, getCounterValue, getJobStatusClient, getLastSuccessfulFetch
protected HadoopStepCounterCache(CascadingStats stats, Configuration configuration)
protected boolean areCountersAvailable(RunningJob runningJob)
areCountersAvailable
in class CounterCache<Configuration,RunningJob,Counters>
protected Counters getCounters(RunningJob runningJob) throws IOException
getCounters
in class CounterCache<Configuration,RunningJob,Counters>
IOException
protected Collection<String> getGroupNames(Counters groups)
getGroupNames
in class CounterCache<Configuration,RunningJob,Counters>
protected Set<String> getCountersFor(Counters counters, String group)
getCountersFor
in class CounterCache<Configuration,RunningJob,Counters>
protected long getCounterValue(Counters counters, Enum counter)
getCounterValue
in class CounterCache<Configuration,RunningJob,Counters>
protected long getCounterValue(Counters counters, String groupName, String counterName)
getCounterValue
in class CounterCache<Configuration,RunningJob,Counters>
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.