public class BaseFlowNode extends java.lang.Object implements java.io.Serializable, FlowNode, ProcessLogger
Modifier and Type | Field and Description |
---|---|
protected FlowNodeStats |
flowNodeStats |
protected ElementGraph |
nodeSubGraph |
protected java.util.List<? extends ElementGraph> |
pipelineGraphs |
protected java.util.Set<Tap> |
sinkTaps |
protected java.util.Set<Tap> |
sourceTaps |
CASCADING_FLOW_NODE
NULL
Constructor and Description |
---|
BaseFlowNode(ElementGraph nodeSubGraph) |
BaseFlowNode(ElementGraph nodeSubGraph,
java.util.List<? extends ElementGraph> pipelineGraphs) |
BaseFlowNode(ElementGraph nodeSubGraph,
java.util.Map<java.lang.String,java.lang.String> flowNodeDescriptor) |
BaseFlowNode(ElementGraph nodeSubGraph,
java.lang.String name,
int ordinal) |
BaseFlowNode(ElementGraph nodeSubGraph,
java.lang.String name,
int ordinal,
java.util.Map<java.lang.String,java.lang.String> flowNodeDescriptor) |
BaseFlowNode(FlowElementGraph flowElementGraph,
ElementGraph nodeSubGraph,
java.util.List<? extends ElementGraph> pipelineGraphs) |
BaseFlowNode(FlowElementGraph flowElementGraph,
ElementGraph nodeSubGraph,
java.util.List<? extends ElementGraph> pipelineGraphs,
java.util.Map<java.lang.String,java.lang.String> flowNodeDescriptor) |
BaseFlowNode(FlowElementGraph flowElementGraph,
ElementGraph nodeSubGraph,
java.util.Map<java.lang.String,java.lang.String> flowNodeDescriptor) |
BaseFlowNode(java.lang.String name,
int ordinal) |
BaseFlowNode(java.lang.String name,
int ordinal,
java.util.Map<java.lang.String,java.lang.String> flowNodeDescriptor) |
Modifier and Type | Method and Description |
---|---|
void |
addProcessAnnotation(java.lang.Enum annotation) |
void |
addProcessAnnotation(java.lang.String key,
java.lang.String value) |
boolean |
equals(java.lang.Object object) |
ElementGraph |
getElementGraph() |
java.util.Set<? extends FlowElement> |
getFlowElementsFor(java.lang.Enum annotation) |
java.util.Map<java.lang.String,java.lang.String> |
getFlowNodeDescriptor()
Returns an immutable map of properties giving more details about the FlowNode object.
|
FlowNodeStats |
getFlowNodeStats() |
FlowStep |
getFlowStep() |
java.util.Collection<Group> |
getGroups() |
java.lang.String |
getID() |
java.lang.String |
getName() |
java.util.Collection<? extends Scope> |
getNextScopes(FlowElement flowElement) |
int |
getOrdinal() |
ElementGraph |
getPipelineGraphFor(FlowElement streamedSource) |
java.util.List<? extends ElementGraph> |
getPipelineGraphs() |
java.util.Collection<? extends Scope> |
getPreviousScopes(FlowElement flowElement) |
java.util.Map<java.lang.String,java.lang.String> |
getProcessAnnotations()
Method getProcessAnnotations returns an immutable Map of platform specific annotations or meta-data
that describe the current model type.
|
java.util.Set<java.lang.String> |
getSinkElementNames() |
java.util.Set<FlowElement> |
getSinkElements() |
java.util.Set<? extends FlowElement> |
getSinkElements(java.lang.Enum annotation) |
java.util.Set<java.lang.String> |
getSinkTapNames(Tap sink) |
java.util.Set<Tap> |
getSinkTaps() |
java.util.Set<java.lang.String> |
getSourceElementNames() |
java.util.Set<FlowElement> |
getSourceElements() |
java.util.Set<? extends FlowElement> |
getSourceElements(java.lang.Enum annotation) |
java.util.Set<java.lang.String> |
getSourceTapNames(Tap source) |
java.util.Set<Tap> |
getSourceTaps() |
int |
getSubmitPriority() |
Tap |
getTrap(java.lang.String branchName) |
java.util.Map<java.lang.String,Tap> |
getTrapMap() |
java.util.Collection<? extends Tap> |
getTraps() |
int |
hashCode() |
boolean |
isDebugEnabled() |
boolean |
isInfoEnabled() |
void |
logDebug(java.lang.String message,
java.lang.Object... arguments) |
void |
logError(java.lang.String message,
java.lang.Object... arguments) |
void |
logError(java.lang.String message,
java.lang.Throwable throwable) |
void |
logInfo(java.lang.String message,
java.lang.Object... arguments) |
void |
logWarn(java.lang.String message) |
void |
logWarn(java.lang.String message,
java.lang.Object... arguments) |
void |
logWarn(java.lang.String message,
java.lang.Throwable throwable) |
protected void |
setFlowNodeDescriptor(java.util.Map<java.lang.String,java.lang.String> flowNodeDescriptor) |
void |
setFlowNodeStats(FlowNodeStats flowNodeStats) |
void |
setFlowStep(FlowStep flowStep) |
void |
setName(java.lang.String name) |
void |
setOrdinal(int ordinal) |
protected void |
setPipelineGraphs(java.util.List<? extends ElementGraph> pipelineGraphs) |
protected ElementGraph nodeSubGraph
protected java.util.List<? extends ElementGraph> pipelineGraphs
protected java.util.Set<Tap> sourceTaps
protected transient FlowNodeStats flowNodeStats
public BaseFlowNode(java.lang.String name, int ordinal)
public BaseFlowNode(java.lang.String name, int ordinal, java.util.Map<java.lang.String,java.lang.String> flowNodeDescriptor)
public BaseFlowNode(ElementGraph nodeSubGraph, java.lang.String name, int ordinal)
public BaseFlowNode(ElementGraph nodeSubGraph, java.lang.String name, int ordinal, java.util.Map<java.lang.String,java.lang.String> flowNodeDescriptor)
public BaseFlowNode(ElementGraph nodeSubGraph)
public BaseFlowNode(ElementGraph nodeSubGraph, java.util.Map<java.lang.String,java.lang.String> flowNodeDescriptor)
public BaseFlowNode(ElementGraph nodeSubGraph, java.util.List<? extends ElementGraph> pipelineGraphs)
public BaseFlowNode(FlowElementGraph flowElementGraph, ElementGraph nodeSubGraph, java.util.Map<java.lang.String,java.lang.String> flowNodeDescriptor)
public BaseFlowNode(FlowElementGraph flowElementGraph, ElementGraph nodeSubGraph, java.util.List<? extends ElementGraph> pipelineGraphs)
public BaseFlowNode(FlowElementGraph flowElementGraph, ElementGraph nodeSubGraph, java.util.List<? extends ElementGraph> pipelineGraphs, java.util.Map<java.lang.String,java.lang.String> flowNodeDescriptor)
public void setOrdinal(int ordinal)
public int getOrdinal()
getOrdinal
in interface ProcessModel
public java.lang.String getID()
getID
in interface FlowNode
getID
in interface ProcessModel
public void setName(java.lang.String name)
public java.lang.String getName()
getName
in interface ProcessModel
public java.util.Map<java.lang.String,java.lang.String> getFlowNodeDescriptor()
FlowNode
FlowNodeDescriptors
.getFlowNodeDescriptor
in interface FlowNode
protected void setFlowNodeDescriptor(java.util.Map<java.lang.String,java.lang.String> flowNodeDescriptor)
public java.util.Map<java.lang.String,java.lang.String> getProcessAnnotations()
ProcessModel
ProcessModel.addProcessAnnotation(Enum)
or ProcessModel.addProcessAnnotation(String, String)
to insert
annotations or meta-data.getProcessAnnotations
in interface ProcessModel
public void addProcessAnnotation(java.lang.Enum annotation)
addProcessAnnotation
in interface ProcessModel
public void addProcessAnnotation(java.lang.String key, java.lang.String value)
addProcessAnnotation
in interface ProcessModel
public void setFlowNodeStats(FlowNodeStats flowNodeStats)
public FlowNodeStats getFlowNodeStats()
getFlowNodeStats
in interface FlowNode
public void setFlowStep(FlowStep flowStep)
public FlowStep getFlowStep()
getFlowStep
in interface FlowNode
public ElementGraph getElementGraph()
getElementGraph
in interface ProcessModel
public java.util.Set<java.lang.String> getSourceElementNames()
getSourceElementNames
in interface FlowNode
public java.util.Set<FlowElement> getSourceElements()
getSourceElements
in interface ProcessModel
public java.util.Set<? extends FlowElement> getSourceElements(java.lang.Enum annotation)
getSourceElements
in interface FlowNode
public java.util.Set<java.lang.String> getSinkElementNames()
getSinkElementNames
in interface FlowNode
public java.util.Set<FlowElement> getSinkElements()
getSinkElements
in interface ProcessModel
public java.util.Set<? extends FlowElement> getSinkElements(java.lang.Enum annotation)
getSinkElements
in interface FlowNode
public java.util.List<? extends ElementGraph> getPipelineGraphs()
getPipelineGraphs
in interface FlowNode
protected void setPipelineGraphs(java.util.List<? extends ElementGraph> pipelineGraphs)
public ElementGraph getPipelineGraphFor(FlowElement streamedSource)
getPipelineGraphFor
in interface FlowNode
public java.util.Collection<Group> getGroups()
getGroups
in interface ProcessModel
public java.util.Set<Tap> getSourceTaps()
getSourceTaps
in interface ProcessModel
public java.util.Set<Tap> getSinkTaps()
getSinkTaps
in interface ProcessModel
public int getSubmitPriority()
getSubmitPriority
in interface ProcessModel
public java.util.Set<java.lang.String> getSourceTapNames(Tap source)
getSourceTapNames
in interface FlowNode
public java.util.Set<java.lang.String> getSinkTapNames(Tap sink)
getSinkTapNames
in interface FlowNode
public java.util.Map<java.lang.String,Tap> getTrapMap()
getTrapMap
in interface ProcessModel
public java.util.Collection<? extends Scope> getPreviousScopes(FlowElement flowElement)
getPreviousScopes
in interface FlowNode
public java.util.Collection<? extends Scope> getNextScopes(FlowElement flowElement)
getNextScopes
in interface FlowNode
public boolean equals(java.lang.Object object)
equals
in class java.lang.Object
public int hashCode()
hashCode
in class java.lang.Object
public java.util.Set<? extends FlowElement> getFlowElementsFor(java.lang.Enum annotation)
getFlowElementsFor
in interface FlowNode
public boolean isInfoEnabled()
isInfoEnabled
in interface ProcessLogger
public boolean isDebugEnabled()
isDebugEnabled
in interface ProcessLogger
public void logInfo(java.lang.String message, java.lang.Object... arguments)
logInfo
in interface ProcessLogger
public void logDebug(java.lang.String message, java.lang.Object... arguments)
logDebug
in interface ProcessLogger
public void logWarn(java.lang.String message)
logWarn
in interface ProcessLogger
public void logWarn(java.lang.String message, java.lang.Object... arguments)
logWarn
in interface ProcessLogger
public void logWarn(java.lang.String message, java.lang.Throwable throwable)
logWarn
in interface ProcessLogger
public void logError(java.lang.String message, java.lang.Object... arguments)
logError
in interface ProcessLogger
public void logError(java.lang.String message, java.lang.Throwable throwable)
logError
in interface ProcessLogger
Copyright © 2007-2015 Xplenty, Inc. All Rights Reserved.