public abstract class TezCounterCache<JobStatus> extends CounterCache<JobStatus,org.apache.tez.common.counters.TezCounters>
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 |
TezCounterCache(CascadingStats stats,
Configuration configuration) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
areCountersAvailable(JobStatus runningJob) |
protected Set<String> |
getCountersFor(org.apache.tez.common.counters.TezCounters counterGroups,
String group) |
protected long |
getCounterValue(org.apache.tez.common.counters.TezCounters counterGroups,
Enum counter) |
protected long |
getCounterValue(org.apache.tez.common.counters.TezCounters counterGroups,
String groupName,
String counterName) |
protected Collection<String> |
getGroupNames(org.apache.tez.common.counters.TezCounters counterGroups) |
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<JobStatus,org.apache.tez.common.counters.TezCounters>
protected Collection<String> getGroupNames(org.apache.tez.common.counters.TezCounters counterGroups)
getGroupNames
in class CounterCache<JobStatus,org.apache.tez.common.counters.TezCounters>
protected Set<String> getCountersFor(org.apache.tez.common.counters.TezCounters counterGroups, String group)
getCountersFor
in class CounterCache<JobStatus,org.apache.tez.common.counters.TezCounters>
protected long getCounterValue(org.apache.tez.common.counters.TezCounters counterGroups, Enum counter)
getCounterValue
in class CounterCache<JobStatus,org.apache.tez.common.counters.TezCounters>
protected long getCounterValue(org.apache.tez.common.counters.TezCounters counterGroups, String groupName, String counterName)
getCounterValue
in class CounterCache<JobStatus,org.apache.tez.common.counters.TezCounters>
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.