public class HadoopReduceStreamGraph extends NodeStreamGraph
elementGraph, flowProcess, node, streamedSource
DOT_FILE_PATH, ERROR_DOT_FILE_NAME
Constructor and Description |
---|
HadoopReduceStreamGraph(HadoopFlowProcess flowProcess,
FlowNode node,
FlowElement sourceElement) |
Modifier and Type | Method and Description |
---|---|
protected void |
buildGraph() |
protected Gate |
createCoGroupGate(CoGroup element,
IORole role) |
protected Gate |
createGroupByGate(GroupBy element,
IORole role) |
protected Gate |
createHashJoinGate(HashJoin join) |
protected SinkStage |
createSinkStage(Tap element) |
createBlockingJoinGate, createBoundaryStage, createMergeStage, createNonBlockingJoinGate, findExisting, getProperty, handleDuct, setScopes, setTraps
addHead, addPath, addPath, addTail, asPathList, bind, cleanup, countAllEventingPathsTo, createFork, createNextFor, createOpenReducingWindow, createOpenWindow, findAllNextFor, findAllPreviousFor, getAllDucts, getHeads, getOrdinalMap, getReversedGraph, getReversedTopologicalOrderIterator, getTails, getTopologicalOrderIterator, ordinalBetween, prepare, printGraph, printGraph, printGraphError
public HadoopReduceStreamGraph(HadoopFlowProcess flowProcess, FlowNode node, FlowElement sourceElement)
protected void buildGraph()
protected SinkStage createSinkStage(Tap element)
createSinkStage
in class NodeStreamGraph
protected Gate createCoGroupGate(CoGroup element, IORole role)
createCoGroupGate
in class NodeStreamGraph
protected Gate createGroupByGate(GroupBy element, IORole role)
createGroupByGate
in class NodeStreamGraph
protected Gate createHashJoinGate(HashJoin join)
createHashJoinGate
in class NodeStreamGraph
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.