cascading.flow.local
Class LocalFlowStep
java.lang.Object
cascading.flow.planner.BaseFlowStep<Properties>
cascading.flow.local.LocalFlowStep
- All Implemented Interfaces:
- FlowStep<Properties>, Serializable
public class LocalFlowStep
- extends BaseFlowStep<Properties>
Class LocalFlowStep is the local mode implementation of FlowStep
.
- See Also:
- Serialized Form
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, removeListener, rollbackSinks, setConf, setFlow, setFlowName, setSubmitPriority, toString |
LocalFlowStep
public LocalFlowStep(String name,
int id)
getInitializedConfig
public Properties getInitializedConfig(FlowProcess<Properties> flowProcess,
Properties parentConfig)
- Specified by:
getInitializedConfig
in class BaseFlowStep<Properties>
initTaps
protected void initTaps(FlowProcess<Properties> flowProcess,
Properties conf,
Set<Tap> taps,
boolean isSink)
clean
public void clean(Properties config)
- Specified by:
clean
in class BaseFlowStep<Properties>
createFlowStepJob
protected FlowStepJob<Properties> createFlowStepJob(FlowProcess<Properties> flowProcess,
Properties parentConfig)
- Specified by:
createFlowStepJob
in class BaseFlowStep<Properties>
getTrapMap
public Map<String,Tap> getTrapMap()
getPropertiesMap
public Map<Tap,Properties> getPropertiesMap()
getTraps
public Set<Tap> getTraps()
getTrap
public Tap getTrap(String name)
Copyright © 2007-2014 Concurrent, Inc. All Rights Reserved.