cascading.flow.hadoop.stream
Class HadoopReduceStreamGraph

java.lang.Object
  extended by cascading.flow.stream.StreamGraph
      extended by cascading.flow.stream.StepStreamGraph
          extended by cascading.flow.hadoop.stream.HadoopReduceStreamGraph

public class HadoopReduceStreamGraph
extends StepStreamGraph


Field Summary
 
Fields inherited from class cascading.flow.stream.StepStreamGraph
flowProcess, step
 
Fields inherited from class cascading.flow.stream.StreamGraph
DOT_FILE_PATH, ERROR_DOT_FILE_NAME
 
Constructor Summary
HadoopReduceStreamGraph(HadoopFlowProcess flowProcess, HadoopFlowStep step)
           
 
Method Summary
protected  void buildGraph()
           
protected  Gate createCoGroupGate(CoGroup element)
           
protected  Gate createGroupByGate(GroupBy element)
           
protected  Gate createHashJoinGate(HashJoin join)
           
protected  SinkStage createSinkStage(Tap element)
           
protected  boolean stopOnElement(FlowElement lhsElement, List<FlowElement> successors)
           
 
Methods inherited from class cascading.flow.stream.StepStreamGraph
createBlockingJoinGate, createMergeStage, createNonBlockingJoinGate, findExisting, getProperty, handleDuct, setScopes, setTraps
 
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
 

Constructor Detail

HadoopReduceStreamGraph

public HadoopReduceStreamGraph(HadoopFlowProcess flowProcess,
                               HadoopFlowStep step)
Method Detail

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.