public class HadoopReduceStreamGraph extends cascading.flow.stream.graph.NodeStreamGraph
Constructor and Description |
---|
HadoopReduceStreamGraph(HadoopFlowProcess flowProcess,
cascading.flow.FlowNode node,
cascading.flow.FlowElement sourceElement) |
Modifier and Type | Method and Description |
---|---|
protected void |
buildGraph() |
protected cascading.flow.stream.duct.Gate |
createCoGroupGate(cascading.pipe.CoGroup element,
cascading.flow.stream.graph.IORole role) |
protected cascading.flow.stream.duct.Gate |
createGroupByGate(cascading.pipe.GroupBy element,
cascading.flow.stream.graph.IORole role) |
protected cascading.flow.stream.duct.Gate |
createHashJoinGate(cascading.pipe.HashJoin join) |
protected cascading.flow.stream.element.SinkStage |
createSinkStage(cascading.tap.Tap element) |
createBlockingJoinGate, createBoundaryStage, createMergeStage, createNonBlockingJoinGate, 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 HadoopReduceStreamGraph(HadoopFlowProcess flowProcess, cascading.flow.FlowNode node, cascading.flow.FlowElement sourceElement)
protected void buildGraph()
protected cascading.flow.stream.element.SinkStage createSinkStage(cascading.tap.Tap element)
createSinkStage
in class cascading.flow.stream.graph.NodeStreamGraph
protected cascading.flow.stream.duct.Gate createCoGroupGate(cascading.pipe.CoGroup element, cascading.flow.stream.graph.IORole role)
createCoGroupGate
in class cascading.flow.stream.graph.NodeStreamGraph
protected cascading.flow.stream.duct.Gate createGroupByGate(cascading.pipe.GroupBy element, cascading.flow.stream.graph.IORole role)
createGroupByGate
in class cascading.flow.stream.graph.NodeStreamGraph
protected cascading.flow.stream.duct.Gate createHashJoinGate(cascading.pipe.HashJoin join)
createHashJoinGate
in class cascading.flow.stream.graph.NodeStreamGraph
Copyright © 2007-2015 Xplenty, Inc. All Rights Reserved.