cascading.stats.hadoop
Class ProcessFlowStep

java.lang.Object
  cascading.flow.planner.BaseFlowStep<JobConf>
      cascading.flow.hadoop.HadoopFlowStep
          cascading.stats.hadoop.ProcessFlowStep

All Implemented Interfaces:

FlowStep<JobConf>, Serializable

Deprecated. ProcessFlowStep will be decoupled from Hadoop and moved to a different package in Cascading 3.0.

@Deprecated
public class ProcessFlowStep
extends HadoopFlowStep

Class representing a step in a ProcessFlow.

See Also:

Serialized Form

Field Summary

Fields inherited from class cascading.flow.planner.BaseFlowStep

accumulatedSourcesByJoin, sinks, sources, streamedSourceByJoin, tempSink

Fields inherited from interface cascading.flow.FlowStep

CASCADING_FLOW_STEP_ID

Constructor Summary

ProcessFlowStep(riffle.process.scheduler.ProcessWrapper processWrapper, int counter)
Deprecated.

Method Summary

Methods inherited from class cascading.flow.hadoop.HadoopFlowStep

clean, createFlowStepJob, getInitializedConfig, getMapperTrap, getMapperTraps, getReducerTrap, getReducerTraps, getTapForID, getTrap, getTraps, initFromSink, initFromSources, initFromTraps, isHadoopLocalMode

Methods inherited from class cascading.flow.planner.BaseFlowStep

addAccumulatedSourceFor, addGroup, addListener, addSink, addSource, addStreamedSourceFor, clean, commitSinks, containsPipeNamed, createClientState, equals, fireOnCompleted, fireOnRunning, fireOnStarting, fireOnStopping, fireOnThrowable, getAllAccumulatedSources, getAllOperations, getConfig, getFlow, getFlowID, getFlowName, getFlowStepJob, getFlowStepStats, getGraph, getGroup, getGroups, getID, getJoinTributariesBetween, getName, getNextFlowElement, getNextScope, getNextScopes, getPreviousScopes, getScopeFor, getSink, getSinkName, getSinks, getSinkWith, getSourceName, getSources, getSourceWith, getStepDisplayName, getStepDisplayName, getStepNum, getStreamedSourceByJoin, getSubmitPriority, getSuccessors, getTopologicalOrderIterator, hashCode, hasListeners, initConfFromProcessConfigDef, isDebugEnabled, isInfoEnabled, logDebug, logError, logInfo, logWarn, logWarn, prepareResources, removeListener, rollbackSinks, setConf, setFlow, setFlowName, setSubmitPriority, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

ProcessFlowStep

public ProcessFlowStep(riffle.process.scheduler.ProcessWrapper processWrapper,
                       int counter)

Deprecated.