public abstract class NodeStreamGraph extends StreamGraph
Modifier and Type | Field and Description |
---|---|
protected ElementGraph |
elementGraph |
protected FlowProcess |
flowProcess |
protected FlowNode |
node |
protected FlowElement |
streamedSource |
DOT_FILE_PATH, ERROR_DOT_FILE_NAME
Constructor and Description |
---|
NodeStreamGraph(FlowProcess flowProcess,
FlowNode node) |
NodeStreamGraph(FlowProcess flowProcess,
FlowNode node,
FlowElement streamedSource) |
Modifier and Type | Method and Description |
---|---|
protected MemoryCoGroupGate |
createBlockingJoinGate(HashJoin join) |
protected Duct |
createBoundaryStage(Boundary element,
IORole role) |
protected abstract Gate |
createCoGroupGate(CoGroup element,
IORole role) |
protected abstract Gate |
createGroupByGate(GroupBy element,
IORole role) |
protected Gate |
createHashJoinGate(HashJoin join) |
protected Duct |
createMergeStage(Merge merge,
IORole both) |
protected GroupingSpliceGate |
createNonBlockingJoinGate(HashJoin join) |
protected SinkStage |
createSinkStage(Tap element) |
protected Duct |
findExisting(Duct current) |
protected java.lang.Object |
getProperty(java.lang.String name) |
protected void |
handleDuct(FlowElement lhsElement,
Duct lhsDuct) |
protected void |
setScopes() |
protected void |
setTraps() |
addHead, addPath, addPath, addTail, bind, cleanup, createCloseWindow, createFork, createNextFor, createOpenReducingWindow, createOpenWindow, findAllNextFor, findAllPreviousFor, getAllDucts, getHeads, getReversedGraph, getReversedTopologicalOrderIterator, getTails, getTopologicalOrderIterator, ordinalBetween, prepare, printBoundGraph, printBoundGraph, printGraph, printGraph, printGraphError, wrapWithOrdinal
protected FlowProcess flowProcess
protected FlowElement streamedSource
protected final ElementGraph elementGraph
public NodeStreamGraph(FlowProcess flowProcess, FlowNode node)
public NodeStreamGraph(FlowProcess flowProcess, FlowNode node, FlowElement streamedSource)
protected java.lang.Object getProperty(java.lang.String name)
getProperty
in class StreamGraph
protected void handleDuct(FlowElement lhsElement, Duct lhsDuct)
protected Duct createBoundaryStage(Boundary element, IORole role)
protected SinkStage createSinkStage(Tap element)
protected abstract Gate createCoGroupGate(CoGroup element, IORole role)
protected abstract Gate createGroupByGate(GroupBy element, IORole role)
protected Duct createMergeStage(Merge merge, IORole both)
protected Gate createHashJoinGate(HashJoin join)
protected GroupingSpliceGate createNonBlockingJoinGate(HashJoin join)
protected MemoryCoGroupGate createBlockingJoinGate(HashJoin join)
protected Duct findExisting(Duct current)
protected void setTraps()
protected void setScopes()
Copyright © 2007-2015 Xplenty, Inc. All Rights Reserved.