public class BaseFlowNode extends Object implements Serializable, FlowNode, ProcessLogger
Modifier and Type | Field and Description |
---|---|
protected ElementGraph |
nodeSubGraph |
protected List<? extends ElementGraph> |
pipelineGraphs |
CASCADING_FLOW_NODE
NULL
Constructor and Description |
---|
BaseFlowNode(FlowElementGraph flowElementGraph,
ElementGraph nodeSubGraph,
List<? extends ElementGraph> pipelineGraphs) |
BaseFlowNode(String name,
int ordinal) |
protected ElementGraph nodeSubGraph
protected List<? extends ElementGraph> pipelineGraphs
public BaseFlowNode(String name, int ordinal)
public BaseFlowNode(FlowElementGraph flowElementGraph, ElementGraph nodeSubGraph, List<? extends ElementGraph> pipelineGraphs)
public void setOrdinal(int ordinal)
public int getOrdinal()
getOrdinal
in interface ProcessModel
public String getID()
getID
in interface FlowNode
getID
in interface ProcessModel
public String getName()
getName
in interface ProcessModel
public Map<String,String> getProcessAnnotations()
ProcessModel
ProcessModel.addProcessAnnotation(Enum)
or ProcessModel.addProcessAnnotation(String, String)
to insert
annotations or meta-data.getProcessAnnotations
in interface ProcessModel
public void addProcessAnnotation(Enum annotation)
addProcessAnnotation
in interface ProcessModel
public void addProcessAnnotation(String key, String value)
addProcessAnnotation
in interface ProcessModel
public void setFlowStep(FlowStep flowStep)
public FlowStep getFlowStep()
getFlowStep
in interface FlowNode
public ElementGraph getElementGraph()
getElementGraph
in interface ProcessModel
public Set<String> getSourceElementNames()
getSourceElementNames
in interface FlowNode
public Set<FlowElement> getSourceElements()
getSourceElements
in interface ProcessModel
public Set<? extends FlowElement> getSourceElements(Enum annotation)
getSourceElements
in interface FlowNode
public Set<String> getSinkElementNames()
getSinkElementNames
in interface FlowNode
public Set<FlowElement> getSinkElements()
getSinkElements
in interface ProcessModel
public Set<? extends FlowElement> getSinkElements(Enum annotation)
getSinkElements
in interface FlowNode
public List<? extends ElementGraph> getPipelineGraphs()
getPipelineGraphs
in interface FlowNode
public ElementGraph getPipelineGraphFor(FlowElement streamedSource)
getPipelineGraphFor
in interface FlowNode
public Collection<Group> getGroups()
getGroups
in interface ProcessModel
public Set<Tap> getSourceTaps()
getSourceTaps
in interface ProcessModel
public Set<Tap> getSinkTaps()
getSinkTaps
in interface ProcessModel
public int getSubmitPriority()
getSubmitPriority
in interface ProcessModel
public Set<String> getSourceTapNames(Tap source)
getSourceTapNames
in interface FlowNode
public Set<String> getSinkTapNames(Tap sink)
getSinkTapNames
in interface FlowNode
public Map<String,Tap> getTrapMap()
getTrapMap
in interface ProcessModel
public Collection<? extends Tap> getTraps()
public Collection<? extends Scope> getPreviousScopes(FlowElement flowElement)
getPreviousScopes
in interface FlowNode
public Collection<? extends Scope> getNextScopes(FlowElement flowElement)
getNextScopes
in interface FlowNode
public Set<? extends FlowElement> getFlowElementsFor(Enum annotation)
getFlowElementsFor
in interface FlowNode
public boolean isInfoEnabled()
isInfoEnabled
in interface ProcessLogger
public boolean isDebugEnabled()
isDebugEnabled
in interface ProcessLogger
public void logInfo(String message, Object... arguments)
logInfo
in interface ProcessLogger
public void logDebug(String message, Object... arguments)
logDebug
in interface ProcessLogger
public void logWarn(String message)
logWarn
in interface ProcessLogger
public void logWarn(String message, Object... arguments)
logWarn
in interface ProcessLogger
public void logWarn(String message, Throwable throwable)
logWarn
in interface ProcessLogger
public void logError(String message, Object... arguments)
logError
in interface ProcessLogger
public void logError(String message, Throwable throwable)
logError
in interface ProcessLogger
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.