public abstract class FlowStepStats extends CascadingStats<FlowNodeStats>
FlowStep
specific statistics.CascadingStats.Status, CascadingStats.Type
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 |
FlowStepStats(FlowStep flowStep,
ClientState clientState) |
Modifier and Type | Method and Description |
---|---|
void |
addNodeStats(FlowNodeStats flowNodeStats) |
java.util.Collection<FlowNodeStats> |
getChildren()
Method getChildren returns any relevant child statistics instances.
|
FlowNodeStats |
getChildWith(java.lang.String id)
Method getChildWith returns a child stats instance with the given ID value.
|
protected java.util.Collection<java.lang.String> |
getFlowNodeIDs() |
java.util.List<FlowNodeStats> |
getFlowNodeStats() |
protected java.util.Map<java.lang.String,FlowNodeStats> |
getFlowNodeStatsMap() |
FlowStep |
getFlowStep() |
java.lang.String |
getID()
Method getID returns the ID of this CascadingStats object.
|
int |
getNodesCount() |
protected ProcessLogger |
getProcessLogger() |
java.lang.String |
getProcessStatusURL() |
abstract java.lang.String |
getProcessStepID()
Method getProcessStepID returns the ID representing the under platform process.
|
CascadingStats.Type |
getType() |
boolean |
hasCapturedFinalDetail() |
abstract void |
recordChildStats()
An internal method that will refresh current counters and, if a clientState client is enabled, the child details
including node and slice statistics.
|
void |
recordInfo() |
java.lang.String |
toString() |
addListener, captureDetail, captureDetail, cleanup, fireListeners, getCounterGroupsMatching, 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
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getCounterGroups, getCountersFor, getCounterValue, getCounterValue, getLastSuccessfulCounterFetchTime
protected FlowStepStats(FlowStep flowStep, ClientState clientState)
protected ProcessLogger getProcessLogger()
getProcessLogger
in class CascadingStats<FlowNodeStats>
public java.lang.String getID()
CascadingStats
getID
in class CascadingStats<FlowNodeStats>
public CascadingStats.Type getType()
getType
in class CascadingStats<FlowNodeStats>
public FlowStep getFlowStep()
public void addNodeStats(FlowNodeStats flowNodeStats)
protected java.util.Map<java.lang.String,FlowNodeStats> getFlowNodeStatsMap()
public java.util.List<FlowNodeStats> getFlowNodeStats()
public int getNodesCount()
protected java.util.Collection<java.lang.String> getFlowNodeIDs()
public java.util.Collection<FlowNodeStats> getChildren()
CascadingStats
getChildren
in class CascadingStats<FlowNodeStats>
public FlowNodeStats getChildWith(java.lang.String id)
CascadingStats
getChildWith
in class CascadingStats<FlowNodeStats>
id
- the id of a child instancepublic void recordInfo()
recordInfo
in class CascadingStats<FlowNodeStats>
public java.lang.String toString()
toString
in class CascadingStats<FlowNodeStats>
public boolean hasCapturedFinalDetail()
public abstract void recordChildStats()
All results will be then recorded by the clientState implementation.
See CascadingStats.captureDetail()
to force all statistics to be cached and locally accessible.
public abstract java.lang.String getProcessStepID()
A FlowStep represents a unit of work on a remote platform, in the case of MapReduce, a MapReduce job. The step ID would be the job id.
public java.lang.String getProcessStatusURL()
Copyright © 2007-2017 Cascading Maintainers. All Rights Reserved.