public class ProcessFlowStep extends BaseFlowStep
elementGraph, flowNodeGraph, flowStepStats, sinks, sources, tempSink
CASCADING_FLOW_STEP_ID
NULL
Constructor and Description |
---|
ProcessFlowStep(riffle.process.scheduler.ProcessWrapper processWrapper,
int counter) |
ProcessFlowStep(riffle.process.scheduler.ProcessWrapper processWrapper,
int counter,
java.util.Map<java.lang.String,java.lang.String> flowStepDescriptor) |
Modifier and Type | Method and Description |
---|---|
void |
clean(java.lang.Object object) |
protected FlowStepJob |
createFlowStepJob(ClientState clientState,
FlowProcess flowProcess,
java.lang.Object initializedStepConfig) |
java.lang.Object |
createInitializedConfig(FlowProcess flowProcess,
java.lang.Object parentConfig)
Public for testing.
|
java.util.Map<java.lang.Object,java.lang.Object> |
getConfigAsProperties()
Method getConfigAsProperties converts the internal configuration object into a
Map of
key value pairs. |
addAllGroups, addGroup, addGroups, addListener, addProcessAnnotation, addProcessAnnotation, addSink, addSinks, addSource, addSources, clean, commitSinks, configure, containsPipeNamed, createClientState, equals, findAllSerializableTypes, fireOnCompleted, fireOnRunning, fireOnStarting, fireOnStopping, fireOnThrowable, getAllAccumulatedSources, getAllOperations, getAllStreamedSources, getAnnotations, getConfig, getCreateFlowStepJob, getElementGraph, getFieldDeclaredSerializations, getFlow, getFlowID, getFlowName, getFlowNodeGraph, getFlowStepDescriptor, getFlowStepJob, getFlowStepStats, getGroup, getGroups, getID, getName, getNextFlowElement, getNextScope, getNodeDisplayName, getNumFlowNodes, getOrdinal, getPreviousScopes, getProcessAnnotations, getSink, getSinkElements, getSinkName, getSinkTaps, getSinkWith, getSourceElements, getSourceName, getSourceTaps, getSourceWith, getStepDisplayName, getStepDisplayName, getSubmitPriority, getTrap, getTrapMap, getTraps, hashCode, hasListeners, initConfFromNodeConfigDef, initConfFromStepConfigDef, isDebugEnabled, isInfoEnabled, logDebug, logError, logError, logInfo, logWarn, logWarn, logWarn, prepareResources, removeListener, rollbackSinks, setConfig, setFlow, setFlowName, setFlowStepDescriptor, setFlowStepStats, setName, setOrdinal, setSubmitPriority, toString
public ProcessFlowStep(riffle.process.scheduler.ProcessWrapper processWrapper, int counter)
public ProcessFlowStep(riffle.process.scheduler.ProcessWrapper processWrapper, int counter, java.util.Map<java.lang.String,java.lang.String> flowStepDescriptor)
public java.util.Map<java.lang.Object,java.lang.Object> getConfigAsProperties()
FlowStep
Map
of
key value pairs.getConfigAsProperties
in interface FlowStep
getConfigAsProperties
in class BaseFlowStep
public java.lang.Object createInitializedConfig(FlowProcess flowProcess, java.lang.Object parentConfig)
BaseFlowStep
createInitializedConfig
in class BaseFlowStep
public void clean(java.lang.Object object)
clean
in class BaseFlowStep
protected FlowStepJob createFlowStepJob(ClientState clientState, FlowProcess flowProcess, java.lang.Object initializedStepConfig)
createFlowStepJob
in class BaseFlowStep
Copyright © 2007-2017 Cascading Maintainers. All Rights Reserved.