public abstract class TezCounterCache<JobStatus> extends CounterCache<Configuration,JobStatus,TezCounters>
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 |
TezCounterCache(CascadingStats stats,
Configuration configuration) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
areCountersAvailable(JobStatus runningJob) |
protected java.util.Set<java.lang.String> |
getCountersFor(TezCounters counterGroups,
java.lang.String group) |
protected long |
getCounterValue(TezCounters counterGroups,
java.lang.Enum counter) |
protected long |
getCounterValue(TezCounters counterGroups,
java.lang.String groupName,
java.lang.String counterName) |
protected java.util.Collection<java.lang.String> |
getGroupNames(TezCounters counterGroups) |
protected int |
getIntProperty(java.lang.String property,
int defaultValue) |
cachedCounters, cachedCounters, getCounterGroups, getCounterGroupsMatching, getCounters, getCountersFor, getCounterValue, getCounterValue, getJobStatusClient, getLastSuccessfulFetch
protected TezCounterCache(CascadingStats stats, Configuration configuration)
protected boolean areCountersAvailable(JobStatus runningJob)
areCountersAvailable
in class CounterCache<Configuration,JobStatus,TezCounters>
protected java.util.Collection<java.lang.String> getGroupNames(TezCounters counterGroups)
getGroupNames
in class CounterCache<Configuration,JobStatus,TezCounters>
protected java.util.Set<java.lang.String> getCountersFor(TezCounters counterGroups, java.lang.String group)
getCountersFor
in class CounterCache<Configuration,JobStatus,TezCounters>
protected long getCounterValue(TezCounters counterGroups, java.lang.Enum counter)
getCounterValue
in class CounterCache<Configuration,JobStatus,TezCounters>
protected long getCounterValue(TezCounters counterGroups, java.lang.String groupName, java.lang.String counterName)
getCounterValue
in class CounterCache<Configuration,JobStatus,TezCounters>
protected int getIntProperty(java.lang.String property, int defaultValue)
getIntProperty
in class CounterCache<Configuration,JobStatus,TezCounters>
Copyright © 2007-2017 Cascading Maintainers. All Rights Reserved.