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