public class LocalStepStreamGraph extends NodeStreamGraph
elementGraph, flowProcess, node, streamedSource
DOT_FILE_PATH, ERROR_DOT_FILE_NAME
Constructor and Description |
---|
LocalStepStreamGraph(FlowProcess<java.util.Properties> flowProcess,
LocalFlowStep step,
FlowNode node) |
Modifier and Type | Method and Description |
---|---|
protected void |
buildGraph() |
protected Gate |
createCoGroupGate(CoGroup element,
IORole role) |
protected Duct |
createFork(Duct[] allNext) |
protected Gate |
createGroupByGate(GroupBy element,
IORole source) |
protected Duct |
createMergeStage(Merge merge,
IORole both) |
protected SinkStage |
createSinkStage(Tap element) |
createBlockingJoinGate, createBoundaryStage, createHashJoinGate, createNonBlockingJoinGate, findExisting, getProperty, handleDuct, setScopes, setTraps
addHead, addPath, addPath, addTail, bind, cleanup, createCloseWindow, createNextFor, createOpenReducingWindow, createOpenWindow, findAllNextFor, findAllPreviousFor, getAllDucts, getHeads, getReversedGraph, getReversedTopologicalOrderIterator, getTails, getTopologicalOrderIterator, ordinalBetween, prepare, printBoundGraph, printBoundGraph, printGraph, printGraph, printGraphError, wrapWithOrdinal
public LocalStepStreamGraph(FlowProcess<java.util.Properties> flowProcess, LocalFlowStep step, FlowNode node)
protected void buildGraph()
protected Duct createFork(Duct[] allNext)
createFork
in class StreamGraph
protected Gate createCoGroupGate(CoGroup element, IORole role)
createCoGroupGate
in class NodeStreamGraph
protected Gate createGroupByGate(GroupBy element, IORole source)
createGroupByGate
in class NodeStreamGraph
protected Duct createMergeStage(Merge merge, IORole both)
createMergeStage
in class NodeStreamGraph
protected SinkStage createSinkStage(Tap element)
createSinkStage
in class NodeStreamGraph
Copyright © 2007-2015 Xplenty, Inc. All Rights Reserved.