public class TezNodeStats extends cascading.stats.BaseCachedNodeStats<Configuration,org.apache.tez.dag.api.client.DAGClient,org.apache.tez.common.counters.TezCounters>
Modifier and Type | Class and Description |
---|---|
static class |
TezNodeStats.Kind |
Modifier and Type | Field and Description |
---|---|
static int |
DEFAULT_FETCH_LIMIT |
static java.lang.String |
TIMELINE_FETCH_LIMIT
Sets the fetch limit from the timeline server.
|
Modifier | Constructor and Description |
---|---|
protected |
TezNodeStats(cascading.stats.BaseCachedStepStats<Configuration,org.apache.tez.dag.api.client.DAGClient,org.apache.tez.common.counters.TezCounters> parentStepStats,
cascading.flow.FlowNode flowNode,
cascading.management.state.ClientState clientState,
Configuration configuration) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
captureChildDetailInternal() |
int |
getFailedTaskCount() |
int |
getKilledTaskCount() |
java.lang.String |
getKind() |
int |
getRunningTaskCount() |
int |
getSucceededTaskCount() |
int |
getTotalTaskCount() |
cachedCounters, captureDetail, getChildren, getChildWith, getCounterGroups, getCounterGroupsMatching, getCountersFor, getCounterValue, getCounterValue, getLastSuccessfulCounterFetchTime, isAllChildrenFinished, recordChildStats
getFlowNode, getID, getOrdinal, getProcessLogger, getType, hasCapturedFinalDetail, recordInfo, toString
addListener, captureDetail, cleanup, fireListeners, getCountersFor, getCurrentDuration, getDuration, getFinishedTime, getName, getPendingTime, getPrefix, getRunTime, getStartTime, getStatsString, getStatus, getSubmitTime, getThrowable, getThrowableTrace, isDetailStale, isEngaged, isFailed, isFinished, isPending, isRunning, isSkipped, isStarted, isStopped, isSubmitted, isSuccessful, logDebug, logError, logError, logInfo, logWarn, markDetailCaptured, markFailed, markFailed, markFailed, markFailed, markFinishedTime, markPending, markPendingTime, markRunning, markRunTime, markSkipped, markStarted, markStartedThenRunning, markStartTime, markStartToRunTime, markStopped, markSubmitted, markSubmitTime, markSuccessful, prepare, recordStats, removeListener, setStatsStoreInterval
public static final java.lang.String TIMELINE_FETCH_LIMIT
public static final int DEFAULT_FETCH_LIMIT
protected TezNodeStats(cascading.stats.BaseCachedStepStats<Configuration,org.apache.tez.dag.api.client.DAGClient,org.apache.tez.common.counters.TezCounters> parentStepStats, cascading.flow.FlowNode flowNode, cascading.management.state.ClientState clientState, Configuration configuration)
public java.lang.String getKind()
getKind
in class cascading.stats.FlowNodeStats
public int getTotalTaskCount()
public int getSucceededTaskCount()
public int getFailedTaskCount()
public int getKilledTaskCount()
public int getRunningTaskCount()
protected boolean captureChildDetailInternal()
captureChildDetailInternal
in class cascading.stats.BaseCachedNodeStats<Configuration,org.apache.tez.dag.api.client.DAGClient,org.apache.tez.common.counters.TezCounters>
Copyright © 2007-2015 Xplenty, Inc. All Rights Reserved.