public class TezNodeStats extends BaseCachedNodeStats<Configuration,DAGClient,TezCounters>
Modifier and Type | Class and Description |
---|---|
static class |
TezNodeStats.Kind |
CascadingStats.Status, CascadingStats.Type
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.
|
allChildrenFinished, counterCache, sliceStatsMap
hasCapturedFinalDetail
clientState, finishedTime, lastCaptureDetail, listeners, name, pendingTime, runTime, startTime, STATS_COMPLETE_CHILD_DETAILS_BLOCK_DURATION, STATS_STORE_INTERVAL, status, submitTime, throwable, throwableTrace
Modifier | Constructor and Description |
---|---|
protected |
TezNodeStats(BaseCachedStepStats<Configuration,DAGClient,TezCounters> parentStepStats,
FlowNode flowNode,
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(BaseCachedStepStats<Configuration,DAGClient,TezCounters> parentStepStats, FlowNode flowNode, ClientState clientState, Configuration configuration)
public java.lang.String getKind()
getKind
in class FlowNodeStats
public int getTotalTaskCount()
public int getSucceededTaskCount()
public int getFailedTaskCount()
public int getKilledTaskCount()
public int getRunningTaskCount()
protected boolean captureChildDetailInternal()
captureChildDetailInternal
in class BaseCachedNodeStats<Configuration,DAGClient,TezCounters>
Copyright © 2007-2017 Cascading Maintainers. All Rights Reserved.