cascading.flow.hadoop.stream
Class HadoopMapStreamGraph

java.lang.Object
  cascading.flow.stream.StreamGraph
      cascading.flow.stream.StepStreamGraph
          cascading.flow.hadoop.stream.HadoopMapStreamGraph

public class HadoopMapStreamGraph
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

HadoopMapStreamGraph(HadoopFlowProcess flowProcess, HadoopFlowStep step, cascading.tap.Tap source)

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.MemoryHashJoinGate	createNonBlockingJoinGate(cascading.pipe.HashJoin join)
protected cascading.flow.stream.SinkStage	createSinkStage(cascading.tap.Tap element)
cascading.flow.stream.SourceStage	getStreamedHead()
protected boolean	stopOnElement(cascading.flow.FlowElement lhsElement, List<cascading.flow.FlowElement> successors)

Methods inherited from class cascading.flow.stream.StepStreamGraph

createBlockingJoinGate, createHashJoinGate, createMergeStage, 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

HadoopMapStreamGraph

public HadoopMapStreamGraph(HadoopFlowProcess flowProcess,
                            HadoopFlowStep step,
                            cascading.tap.Tap source)

Method Detail

getStreamedHead

public cascading.flow.stream.SourceStage getStreamedHead()

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

createNonBlockingJoinGate

protected cascading.flow.stream.MemoryHashJoinGate createNonBlockingJoinGate(cascading.pipe.HashJoin join)

Overrides:

createNonBlockingJoinGate 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