public interface FlowStep<Config> extends ProcessModel
getSubmitPriority()
value determines the order in which
all steps will be submitted for execution. The default submit priority is 5.Modifier and Type | Field and Description |
---|---|
static String |
CASCADING_FLOW_STEP_ID |
Modifier and Type | Method and Description |
---|---|
void |
addListener(FlowStepListener flowStepListener)
Method addListener registers the given
FlowStepListener with this instance. |
boolean |
containsPipeNamed(String pipeName)
Returns true if this FlowStep contains a pipe/branch with the given name.
|
Config |
getConfig()
Method getConfig returns the current initialized configuration.
|
Map<Object,Object> |
getConfigAsProperties()
Method getConfigAsProperties converts the internal configuration object into a
Map of
key value pairs. |
Flow<Config> |
getFlow() |
String |
getFlowID() |
String |
getFlowName()
Method getParentFlowName returns the parentFlowName of this FlowStep object.
|
FlowNodeGraph |
getFlowNodeGraph() |
Map<String,String> |
getFlowStepDescriptor()
Returns an immutable map of properties giving more details about the FlowStep object.
|
FlowStepStats |
getFlowStepStats() |
Group |
getGroup() |
String |
getID()
Method getId returns the id of this FlowStep object.
|
String |
getName()
Method getName returns the name of this FlowStep object.
|
int |
getNumFlowNodes() |
int |
getOrdinal() |
Tap |
getSink() |
Set<String> |
getSinkName(Tap sink) |
Tap |
getSinkWith(String identifier) |
Set<String> |
getSourceName(Tap source) |
Tap |
getSourceWith(String identifier) |
String |
getStepDisplayName()
Method getStepDisplayName returns the stepDisplayName of this FlowStep object.
|
int |
getSubmitPriority()
Method getSubmitPriority returns the submitPriority of this FlowStep object.
|
Tap |
getTrap(String name) |
Set<Tap> |
getTraps() |
boolean |
hasListeners()
Method hasListeners returns true if
FlowStepListener instances have been registered. |
boolean |
removeListener(FlowStepListener flowStepListener)
Method removeListener removes the given flowStepListener from this instance.
|
void |
setFlowStepStats(FlowStepStats flowStepStats) |
void |
setSubmitPriority(int submitPriority)
Method setSubmitPriority sets the submitPriority of this FlowStep object.
|
addProcessAnnotation, addProcessAnnotation, getElementGraph, getGroups, getProcessAnnotations, getSinkElements, getSinkTaps, getSourceElements, getSourceTaps, getTrapMap
static final String CASCADING_FLOW_STEP_ID
String getID()
getID
in interface ProcessModel
int getOrdinal()
getOrdinal
in interface ProcessModel
String getName()
getName
in interface ProcessModel
Map<String,String> getFlowStepDescriptor()
FlowStepDescriptors
.String getFlowName()
Config getConfig()
Map<Object,Object> getConfigAsProperties()
Map
of
key value pairs.String getStepDisplayName()
int getSubmitPriority()
getSubmitPriority
in interface ProcessModel
void setSubmitPriority(int submitPriority)
submitPriority
- the submitPriority of this FlowStep object.FlowNodeGraph getFlowNodeGraph()
int getNumFlowNodes()
Set<String> getSourceName(Tap source)
Set<String> getSinkName(Tap sink)
Tap getSourceWith(String identifier)
Tap getSinkWith(String identifier)
boolean containsPipeNamed(String pipeName)
pipeName
- the name of the Pipevoid setFlowStepStats(FlowStepStats flowStepStats)
FlowStepStats getFlowStepStats()
boolean hasListeners()
FlowStepListener
instances have been registered.void addListener(FlowStepListener flowStepListener)
FlowStepListener
with this instance.flowStepListener
- of type flowStepListenerboolean removeListener(FlowStepListener flowStepListener)
flowStepListener
- of type FlowStepListenerCopyright © 2007-2015 Concurrent, Inc. All Rights Reserved.