cascading.flow.stream
Class StepStreamGraph
java.lang.Object
cascading.flow.stream.StreamGraph
cascading.flow.stream.StepStreamGraph
public abstract class StepStreamGraph
- extends StreamGraph
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 |
flowProcess
protected FlowProcess flowProcess
step
protected final BaseFlowStep step
StepStreamGraph
public StepStreamGraph(FlowProcess flowProcess,
BaseFlowStep step)
getProperty
protected Object getProperty(String name)
- Overrides:
getProperty
in class StreamGraph
handleDuct
protected void handleDuct(FlowElement lhsElement,
Duct lhsDuct)
stopOnElement
protected abstract boolean stopOnElement(FlowElement lhsElement,
List<FlowElement> successors)
createSinkStage
protected SinkStage createSinkStage(Tap element)
createCoGroupGate
protected abstract Gate createCoGroupGate(CoGroup element)
createGroupByGate
protected abstract Gate createGroupByGate(GroupBy element)
createMergeStage
protected Duct createMergeStage(Merge merge)
createHashJoinGate
protected Gate createHashJoinGate(HashJoin join)
createNonBlockingJoinGate
protected MemoryHashJoinGate createNonBlockingJoinGate(HashJoin join)
createBlockingJoinGate
protected MemoryCoGroupGate createBlockingJoinGate(HashJoin join)
findExisting
protected Duct findExisting(Duct current)
setTraps
protected void setTraps()
setScopes
protected void setScopes()
Copyright © 2007-2013 Concurrent, Inc. All Rights Reserved.