cascading.stats

Class FlowSliceStats<K extends Enum>

java.lang.Object

cascading.stats.FlowSliceStats<K>

public abstract class FlowSliceStats<K extends Enum>
extends Object

Typically CascadingStats objects have an internal state model with timings, the FlowSliceStats is a simplified Stats object and only reports what the underlying platform reports, not the client side observations.

Implementations may optionally implement the ProvidesCounters interface.

Provided as an abstract class so that implementations will be resilient to API additions.

• pendingTime - when the slice is created
• startTime - when the slice was told to begin work
• submitTime - when the slice was submitted to a work queue
• runTime - when work began
• finishedTime - when work ended

pending is mostly irrelevant and unavailable, start, submit, and runtime are by default synonymous at the slice level

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	FlowSliceStats.FlowSliceAttempt

Constructor Summary

Constructors

Constructor and Description
FlowSliceStats()

Method Summary

Methods

Modifier and Type	Method and Description
abstract Map<Integer,FlowSliceStats.FlowSliceAttempt>	getAttempts()
abstract Map<String,Map<String,Long>>	getCounters()
abstract String[]	getDiagnostics()
abstract String	getID()
abstract K	getKind()
abstract long	getProcessFinishTime()
long	getProcessPendingTime()
abstract float	getProcessProgress()
long	getProcessRunTime()
abstract String	getProcessSliceID()
abstract long	getProcessStartTime()
abstract String	getProcessStatus()
abstract String	getProcessStepID()
long	getProcessSubmitTime()
abstract CascadingStats.Status	getStatus()

Methods inherited from class java.lang.Object

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

Constructor Detail

FlowSliceStats

public FlowSliceStats()

Method Detail

getID

public abstract String getID()

getProcessPendingTime

public long getProcessPendingTime()

getProcessStartTime

public abstract long getProcessStartTime()

getProcessSubmitTime

public long getProcessSubmitTime()

getProcessRunTime

public long getProcessRunTime()

getProcessFinishTime

public abstract long getProcessFinishTime()

getStatus

public abstract CascadingStats.Status getStatus()

getKind

public abstract K getKind()

getProcessSliceID

public abstract String getProcessSliceID()

getProcessStepID

public abstract String getProcessStepID()

getProcessStatus

public abstract String getProcessStatus()

getProcessProgress

public abstract float getProcessProgress()

getDiagnostics

public abstract String[] getDiagnostics()

getCounters

public abstract Map<String,Map<String,Long>> getCounters()

getAttempts

public abstract Map<Integer,FlowSliceStats.FlowSliceAttempt> getAttempts()