cascading.stats.local

Class LocalStepStats

java.lang.Object

cascading.stats.CascadingStats<cascading.stats.FlowNodeStats>

cascading.stats.FlowStepStats

cascading.stats.local.LocalStepStats

All Implemented Interfaces:

cascading.stats.ProvidesCounters, java.io.Serializable

public class LocalStepStats
extends cascading.stats.FlowStepStats

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class cascading.stats.CascadingStats

cascading.stats.CascadingStats.Status, cascading.stats.CascadingStats.Type

Field Summary

Fields inherited from class cascading.stats.CascadingStats

clientState, finishedTime, lastCaptureDetail, listeners, name, pendingTime, runTime, startTime, STATS_COMPLETE_CHILD_DETAILS_BLOCK_DURATION, STATS_STORE_INTERVAL, status, submitTime, throwable, throwableTrace

Constructor Summary

Constructors

Constructor and Description
LocalStepStats(cascading.flow.FlowStep<java.util.Properties> flowStep, cascading.management.state.ClientState clientState) Constructor CascadingStats creates a new CascadingStats instance.

Method Summary

Methods

Modifier and Type	Method and Description
void	captureDetail(cascading.stats.CascadingStats.Type depth)
java.util.Collection	getChildren()
java.util.Collection<java.lang.String>	getCounterGroups()
java.util.Collection<java.lang.String>	getCounterGroupsMatching(java.lang.String regex)
java.util.Collection<java.lang.String>	getCountersFor(java.lang.String group)
long	getCounterValue(java.lang.Enum counter)
long	getCounterValue(java.lang.String group, java.lang.String counter)
long	getLastSuccessfulCounterFetchTime()
java.lang.String	getProcessStepID()
void	increment(java.lang.Enum counter, long amount)
void	increment(java.lang.String group, java.lang.String counter, long amount)
void	recordChildStats()

Methods inherited from class cascading.stats.FlowStepStats

addNodeStats, getChildWith, getFlowNodeIDs, getFlowNodeStats, getFlowNodeStatsMap, getFlowStep, getID, getNodesCount, getProcessLogger, getProcessStatusURL, getType, hasCapturedFinalDetail, recordInfo, toString

Methods inherited from class cascading.stats.CascadingStats

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

LocalStepStats

public LocalStepStats(cascading.flow.FlowStep<java.util.Properties> flowStep,
              cascading.management.state.ClientState clientState)

Constructor CascadingStats creates a new CascadingStats instance.

Method Detail

recordChildStats

public void recordChildStats()

Specified by:

recordChildStats in class cascading.stats.FlowStepStats

getLastSuccessfulCounterFetchTime

public long getLastSuccessfulCounterFetchTime()

getCounterGroups

public java.util.Collection<java.lang.String> getCounterGroups()

getCounterGroupsMatching

public java.util.Collection<java.lang.String> getCounterGroupsMatching(java.lang.String regex)

Specified by:

getCounterGroupsMatching in class cascading.stats.CascadingStats<cascading.stats.FlowNodeStats>

getCountersFor

public java.util.Collection<java.lang.String> getCountersFor(java.lang.String group)

getCounterValue

public long getCounterValue(java.lang.Enum counter)

getCounterValue

public long getCounterValue(java.lang.String group,
                   java.lang.String counter)

increment

public void increment(java.lang.Enum counter,
             long amount)

increment

public void increment(java.lang.String group,
             java.lang.String counter,
             long amount)

captureDetail

public void captureDetail(cascading.stats.CascadingStats.Type depth)

Specified by:

captureDetail in class cascading.stats.CascadingStats<cascading.stats.FlowNodeStats>

getProcessStepID

public java.lang.String getProcessStepID()

Specified by:

getProcessStepID in class cascading.stats.FlowStepStats

getChildren

public java.util.Collection getChildren()

Overrides:

getChildren in class cascading.stats.FlowStepStats