cascading.stats.hadoop
Class ProcessFlowStats

java.lang.Object
  cascading.stats.CascadingStats
      cascading.stats.FlowStats
          cascading.stats.hadoop.ProcessFlowStats

All Implemented Interfaces:

Serializable

Deprecated. ProcessFlowStats will be moved to a different package in Cascading 3.0.

@Deprecated
public class ProcessFlowStats
extends FlowStats

ProcessFlowStats is a sub-class of FlowStats which can fetch counters from a ProcessWrapper and hook them into the stats mechanism of Cascading.

See Also:

Serialized Form

Nested Class Summary

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

CascadingStats.Status

Field Summary

Fields inherited from class cascading.stats.CascadingStats

clientState, STATS_STORE_INTERVAL

Constructor Summary

ProcessFlowStats(Flow flow, ClientState clientState, riffle.process.scheduler.ProcessWrapper processWrapper)
Deprecated. Constructs a new ProcessFlowStats instance.

Method Summary

Collection	getChildren() Deprecated.
List<FlowStepStats>	getFlowStepStats() Deprecated.
int	getStepsCount() Deprecated.

Methods inherited from class cascading.stats.FlowStats

addStepStats, captureDetail, equals, getAppID, getAppName, getCounterGroups, getCounterGroupsMatching, getCountersFor, getCounterValue, getCounterValue, getFlowProperties, getID, getStatsString, hashCode, recordInfo, toString

Methods inherited from class cascading.stats.CascadingStats

cleanup, getCountersFor, getCurrentDuration, getDuration, getFinishedTime, getName, getPendingTime, getRunTime, getStartTime, getStatus, getSubmitTime, getThrowable, isEngaged, isFailed, isFinished, isPending, isRunning, isSkipped, isStarted, isStopped, isSubmitted, isSuccessful, markFailed, markPending, markPendingTime, markRunning, markRunTime, markSkipped, markStarted, markStartedThenRunning, markStartTime, markStartToRunTime, markStopped, markSubmitted, markSubmitTime, markSuccessful, prepare, recordStats, setStatsStoreInterval

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

ProcessFlowStats

public ProcessFlowStats(Flow flow,
                        ClientState clientState,
                        riffle.process.scheduler.ProcessWrapper processWrapper)

Deprecated.

Constructs a new ProcessFlowStats instance.

Parameters:

flow - a Flow instance.

clientState - The current client state.

processWrapper - a ProcessWrapper instance.

Method Detail

getFlowStepStats

public List<FlowStepStats> getFlowStepStats()

Deprecated.

Overrides:

getFlowStepStats in class FlowStats

getChildren

public Collection getChildren()

Deprecated.

Overrides:

getChildren in class FlowStats

getStepsCount

public int getStepsCount()

Deprecated.

Overrides:

getStepsCount in class FlowStats