cascading.flow.hadoop.stream
Class HadoopReduceStreamGraph
java.lang.Object
cascading.flow.stream.StreamGraph
cascading.flow.stream.StepStreamGraph
cascading.flow.hadoop.stream.HadoopReduceStreamGraph
public class HadoopReduceStreamGraph
- extends StepStreamGraph
Methods inherited from class cascading.flow.stream.StreamGraph |
addHead, addPath, addPath, addTail, asPathList, bind, cleanup, countAllEventingPathsTo, createFork, createNextFor, createOpenReducingWindow, createOpenWindow, findAllNextFor, findAllPreviousFor, getAllDucts, getHeads, getReversedGraph, getReversedTopologicalOrderIterator, getTails, getTopologicalOrderIterator, ordinalBetween, prepare, printGraph, printGraph, printGraphError |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
HadoopReduceStreamGraph
public HadoopReduceStreamGraph(HadoopFlowProcess flowProcess,
HadoopFlowStep step)
buildGraph
protected void buildGraph()
createSinkStage
protected SinkStage createSinkStage(Tap element)
- Overrides:
createSinkStage
in class StepStreamGraph
createCoGroupGate
protected Gate createCoGroupGate(CoGroup element)
- Specified by:
createCoGroupGate
in class StepStreamGraph
createGroupByGate
protected Gate createGroupByGate(GroupBy element)
- Specified by:
createGroupByGate
in class StepStreamGraph
createHashJoinGate
protected Gate createHashJoinGate(HashJoin join)
- Overrides:
createHashJoinGate
in class StepStreamGraph
stopOnElement
protected boolean stopOnElement(FlowElement lhsElement,
List<FlowElement> successors)
- Specified by:
stopOnElement
in class StepStreamGraph
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.