public class HadoopMapStreamGraph extends NodeStreamGraph
elementGraph, flowProcess, node, streamedSource
DOT_FILE_PATH, ERROR_DOT_FILE_NAME
Constructor and Description |
---|
HadoopMapStreamGraph(HadoopFlowProcess flowProcess,
FlowNode node,
Tap source) |
Modifier and Type | Method and Description |
---|---|
protected void |
buildGraph() |
protected Gate |
createCoGroupGate(CoGroup element,
IORole role) |
protected Gate |
createGroupByGate(GroupBy element,
IORole role) |
protected GroupingSpliceGate |
createNonBlockingJoinGate(HashJoin join) |
protected SinkStage |
createSinkStage(Tap element) |
SourceStage |
getStreamedHead() |
createBlockingJoinGate, createBoundaryStage, createHashJoinGate, createMergeStage, 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 HadoopMapStreamGraph(HadoopFlowProcess flowProcess, FlowNode node, Tap source)
public SourceStage getStreamedHead()
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 GroupingSpliceGate createNonBlockingJoinGate(HashJoin join)
createNonBlockingJoinGate
in class NodeStreamGraph
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.