public class TezNodeStats extends BaseHadoopNodeStats<org.apache.tez.dag.api.client.DAGClient,org.apache.tez.common.counters.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 String |
TIMELINE_FETCH_LIMIT
Sets the fetch limit from the timeline server.
|
allChildrenFinished, counterCache, sliceStatsMap
hasCapturedFinalDetail
clientState, STATS_COMPLETE_CHILD_DETAILS_BLOCK_DURATION, STATS_STORE_INTERVAL
Modifier | Constructor and Description |
---|---|
protected |
TezNodeStats(TezStepStats parentStepStats,
FlowNode flowNode,
ClientState clientState,
Configuration configuration) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
captureChildDetailInternal()
Returns true if was able to capture/refresh the internal child stats cache.
|
int |
getFailedTaskCount() |
int |
getKilledTaskCount() |
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, 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, markPending, markPendingTime, markRunning, markRunTime, markSkipped, markStarted, markStartedThenRunning, markStartTime, markStartToRunTime, markStopped, markSubmitted, markSubmitTime, markSuccessful, prepare, recordStats, removeListener, setStatsStoreInterval
public static final String TIMELINE_FETCH_LIMIT
public static final int DEFAULT_FETCH_LIMIT
protected TezNodeStats(TezStepStats parentStepStats, FlowNode flowNode, ClientState clientState, Configuration configuration)
public String getKind()
getKind
in class FlowNodeStats
public int getTotalTaskCount()
public int getSucceededTaskCount()
public int getFailedTaskCount()
public int getKilledTaskCount()
public int getRunningTaskCount()
protected boolean captureChildDetailInternal()
BaseHadoopNodeStats
captureChildDetailInternal
in class BaseHadoopNodeStats<org.apache.tez.dag.api.client.DAGClient,org.apache.tez.common.counters.TezCounters>
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.