public class Hadoop2TezStreamGraph extends NodeStreamGraph
elementGraph, flowProcess, node, streamedSource
DOT_FILE_PATH, ERROR_DOT_FILE_NAME
Constructor and Description |
---|
Hadoop2TezStreamGraph(Hadoop2TezFlowProcess currentProcess,
FlowNode flowNode,
java.util.Map<java.lang.String,LogicalInput> inputMap,
java.util.Map<java.lang.String,LogicalOutput> outputMap) |
Modifier and Type | Method and Description |
---|---|
protected void |
buildGraph() |
protected Duct |
createBoundaryStage(Boundary element,
IORole role) |
protected Gate |
createCoGroupGate(CoGroup element,
IORole role) |
protected Gate |
createGroupByGate(GroupBy element,
IORole role) |
protected Duct |
createMergeStage(Merge element,
IORole role) |
protected MemoryHashJoinGate |
createNonBlockingJoinGate(HashJoin join) |
protected Gate |
createSinkGroupByGate(GroupBy element) |
protected SinkStage |
createSinkStage(Tap sink) |
protected Gate |
createSourceGroupByGate(GroupBy element) |
protected SourceStage |
createSourceStage(Tap source,
FlowProcess flowProcess) |
InputSource |
getStreamedHead() |
createBlockingJoinGate, createHashJoinGate, findExisting, getProperty, handleDuct, setScopes, 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
public Hadoop2TezStreamGraph(Hadoop2TezFlowProcess currentProcess, FlowNode flowNode, java.util.Map<java.lang.String,LogicalInput> inputMap, java.util.Map<java.lang.String,LogicalOutput> outputMap)
public InputSource getStreamedHead()
protected void buildGraph()
protected SourceStage createSourceStage(Tap source, FlowProcess flowProcess)
protected SinkStage createSinkStage(Tap sink)
createSinkStage
in class NodeStreamGraph
protected Duct createMergeStage(Merge element, IORole role)
createMergeStage
in class NodeStreamGraph
protected Duct createBoundaryStage(Boundary element, IORole role)
createBoundaryStage
in class NodeStreamGraph
protected Gate createGroupByGate(GroupBy element, IORole role)
createGroupByGate
in class NodeStreamGraph
protected Gate createCoGroupGate(CoGroup element, IORole role)
createCoGroupGate
in class NodeStreamGraph
protected Gate createSinkGroupByGate(GroupBy element)
protected Gate createSourceGroupByGate(GroupBy element)
protected MemoryHashJoinGate createNonBlockingJoinGate(HashJoin join)
createNonBlockingJoinGate
in class NodeStreamGraph
Copyright © 2007-2017 Cascading Maintainers. All Rights Reserved.