public class LocalFlowStep extends BaseFlowStep<Properties>
FlowStep
.flowStepStats, sinks, sources, tempSink
CASCADING_FLOW_STEP_ID
NULL
Constructor and Description |
---|
LocalFlowStep(ElementGraph elementGraph,
FlowNodeGraph flowNodeGraph) |
Modifier and Type | Method and Description |
---|---|
void |
clean(Properties config) |
protected FlowStepJob<Properties> |
createFlowStepJob(ClientState clientState,
FlowProcess<Properties> flowProcess,
Properties initializedStepConfig) |
Properties |
createInitializedConfig(FlowProcess<Properties> flowProcess,
Properties parentConfig) |
Map<Object,Object> |
getConfigAsProperties() |
Map<Tap,Properties> |
getPropertiesMap() |
protected void |
initTaps(FlowProcess<Properties> flowProcess,
Properties conf,
Set<Tap> taps,
boolean isSink) |
addAllGroups, addGroup, addGroups, addListener, addProcessAnnotation, addProcessAnnotation, addSink, addSinks, addSource, addSources, clean, commitSinks, configure, containsPipeNamed, createClientState, equals, fireOnCompleted, fireOnRunning, fireOnStarting, fireOnStopping, fireOnThrowable, getAllAccumulatedSources, getAllOperations, getAnnotations, getConfig, getCreateFlowStepJob, getElementGraph, 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 LocalFlowStep(ElementGraph elementGraph, FlowNodeGraph flowNodeGraph)
public Map<Object,Object> getConfigAsProperties()
getConfigAsProperties
in interface FlowStep<Properties>
getConfigAsProperties
in class BaseFlowStep<Properties>
public Properties createInitializedConfig(FlowProcess<Properties> flowProcess, Properties parentConfig)
createInitializedConfig
in class BaseFlowStep<Properties>
protected void initTaps(FlowProcess<Properties> flowProcess, Properties conf, Set<Tap> taps, boolean isSink)
public void clean(Properties config)
clean
in class BaseFlowStep<Properties>
protected FlowStepJob<Properties> createFlowStepJob(ClientState clientState, FlowProcess<Properties> flowProcess, Properties initializedStepConfig)
createFlowStepJob
in class BaseFlowStep<Properties>
public Map<Tap,Properties> getPropertiesMap()
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.