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 cascading.flow.stream.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 cascading.flow.stream.Gate	createCoGroupGate(cascading.pipe.CoGroup element)
protected cascading.flow.stream.Gate	createGroupByGate(cascading.pipe.GroupBy element)
protected cascading.flow.stream.Gate	createHashJoinGate(cascading.pipe.HashJoin join)
protected cascading.flow.stream.SinkStage	createSinkStage(cascading.tap.Tap element)
protected boolean	stopOnElement(cascading.flow.FlowElement lhsElement, List<cascading.flow.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 cascading.flow.stream.SinkStage createSinkStage(cascading.tap.Tap element)

Overrides:

createSinkStage in class cascading.flow.stream.StepStreamGraph

createCoGroupGate

protected cascading.flow.stream.Gate createCoGroupGate(cascading.pipe.CoGroup element)

Specified by:

createCoGroupGate in class cascading.flow.stream.StepStreamGraph

createGroupByGate

protected cascading.flow.stream.Gate createGroupByGate(cascading.pipe.GroupBy element)

Specified by:

createGroupByGate in class cascading.flow.stream.StepStreamGraph

createHashJoinGate

protected cascading.flow.stream.Gate createHashJoinGate(cascading.pipe.HashJoin join)

Overrides:

createHashJoinGate in class cascading.flow.stream.StepStreamGraph

stopOnElement

protected boolean stopOnElement(cascading.flow.FlowElement lhsElement,
                                List<cascading.flow.FlowElement> successors)

Specified by:

stopOnElement in class cascading.flow.stream.StepStreamGraph