public class HadoopNodeStats extends BaseHadoopNodeStats<FlowNodeStats,Map<String,Map<String,Long>>>
CascadingStats.Status, CascadingStats.Type
allChildrenFinished, counterCache, sliceStatsMap
hasCapturedFinalDetail
clientState, STATS_COMPLETE_CHILD_DETAILS_BLOCK_DURATION, STATS_STORE_INTERVAL
Modifier | Constructor and Description |
---|---|
protected |
HadoopNodeStats(HadoopStepStats parentStepStats,
Configuration configuration,
HadoopSliceStats.Kind kind,
FlowNode flowNode,
ClientState clientState)
Constructor CascadingStats creates a new CascadingStats instance.
|
Modifier and Type | Method and Description |
---|---|
protected void |
addAttempt(TaskCompletionEvent event) |
protected void |
addTaskStats(TaskReport[] taskReports,
boolean skipLast) |
protected boolean |
captureChildDetailInternal()
Returns true if was able to capture/refresh the internal child stats cache.
|
String |
getKind() |
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
protected HadoopNodeStats(HadoopStepStats parentStepStats, Configuration configuration, HadoopSliceStats.Kind kind, FlowNode flowNode, ClientState clientState)
parentStepStats
- configuration
- kind
- flowNode
- clientState
- public String getKind()
getKind
in class FlowNodeStats
protected boolean captureChildDetailInternal()
BaseHadoopNodeStats
captureChildDetailInternal
in class BaseHadoopNodeStats<FlowNodeStats,Map<String,Map<String,Long>>>
protected void addTaskStats(TaskReport[] taskReports, boolean skipLast)
protected void addAttempt(TaskCompletionEvent event)
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.