public abstract class BaseHadoopNodeStats<JobStatus,Counters> extends FlowNodeStats
CascadingStats.Status, CascadingStats.Type
Modifier and Type | Field and Description |
---|---|
protected boolean |
allChildrenFinished |
protected CounterCache<JobStatus,Counters> |
counterCache |
protected Map<String,FlowSliceStats> |
sliceStatsMap |
hasCapturedFinalDetail
clientState, STATS_COMPLETE_CHILD_DETAILS_BLOCK_DURATION, STATS_STORE_INTERVAL
Modifier | Constructor and Description |
---|---|
protected |
BaseHadoopNodeStats(FlowNode flowNode,
ClientState clientState)
Constructor CascadingStats creates a new CascadingStats instance.
|
Modifier and Type | Method and Description |
---|---|
protected Counters |
cachedCounters(boolean force) |
protected abstract boolean |
captureChildDetailInternal()
Returns true if was able to capture/refresh the internal child stats cache.
|
void |
captureDetail(CascadingStats.Type depth) |
Collection<FlowSliceStats> |
getChildren() |
FlowSliceStats |
getChildWith(String id) |
Collection<String> |
getCounterGroups()
Method getCounterGroups returns all of the Hadoop counter groups.
|
Collection<String> |
getCounterGroupsMatching(String regex)
Method getCounterGroupsMatching returns all the Hadoop counter groups that match the give regex pattern.
|
Collection<String> |
getCountersFor(String group)
Method getCountersFor returns the Hadoop counters for the given group.
|
long |
getCounterValue(Enum counter)
Method getCounterValue returns the Hadoop counter value for the given counter enum.
|
long |
getCounterValue(String group,
String counter)
Method getCounterValue returns the Hadoop counter value for the given group and counter name.
|
long |
getLastSuccessfulCounterFetchTime() |
boolean |
isAllChildrenFinished() |
void |
recordChildStats()
Synchronized to prevent state changes mid record, #stop may be called out of band
|
getFlowNode, getID, getKind, 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 final Map<String,FlowSliceStats> sliceStatsMap
protected CounterCache<JobStatus,Counters> counterCache
protected boolean allChildrenFinished
protected BaseHadoopNodeStats(FlowNode flowNode, ClientState clientState)
flowNode
- clientState
- public long getLastSuccessfulCounterFetchTime()
public boolean isAllChildrenFinished()
public Collection<String> getCounterGroups()
public Collection<String> getCounterGroupsMatching(String regex)
getCounterGroupsMatching
in class CascadingStats<FlowSliceStats>
regex
- of Stringpublic Collection<String> getCountersFor(String group)
group
- of Stringpublic long getCounterValue(Enum counter)
counter
- of Enumpublic long getCounterValue(String group, String counter)
group
- of Stringcounter
- of Stringprotected Counters cachedCounters(boolean force)
public Collection<FlowSliceStats> getChildren()
getChildren
in class CascadingStats<FlowSliceStats>
public FlowSliceStats getChildWith(String id)
getChildWith
in class CascadingStats<FlowSliceStats>
public final void captureDetail(CascadingStats.Type depth)
captureDetail
in class CascadingStats<FlowSliceStats>
protected abstract boolean captureChildDetailInternal()
public void recordChildStats()
recordChildStats
in class FlowNodeStats
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.