public class LocalStepStreamGraph extends cascading.flow.stream.graph.NodeStreamGraph
Constructor and Description |
---|
LocalStepStreamGraph(cascading.flow.FlowProcess<java.util.Properties> flowProcess,
LocalFlowStep step,
cascading.flow.FlowNode node) |
Modifier and Type | Method and Description |
---|---|
protected void |
buildGraph() |
protected cascading.flow.stream.duct.Gate |
createCoGroupGate(cascading.pipe.CoGroup element,
cascading.flow.stream.graph.IORole role) |
protected cascading.flow.stream.duct.Duct |
createFork(cascading.flow.stream.duct.Duct[] allNext) |
protected cascading.flow.stream.duct.Gate |
createGroupByGate(cascading.pipe.GroupBy element,
cascading.flow.stream.graph.IORole source) |
protected cascading.flow.stream.duct.Duct |
createMergeStage(cascading.pipe.Merge merge,
cascading.flow.stream.graph.IORole both) |
protected cascading.flow.stream.element.SinkStage |
createSinkStage(cascading.tap.Tap element) |
createBlockingJoinGate, createBoundaryStage, createHashJoinGate, createNonBlockingJoinGate, findExisting, getProperty, handleDuct, setScopes, setTraps
addHead, addPath, addPath, addTail, bind, cleanup, createCloseWindow, createNextFor, createOpenReducingWindow, createOpenWindow, findAllNextFor, findAllPreviousFor, getAllDucts, getHeads, getReversedGraph, getReversedTopologicalOrderIterator, getTails, getTopologicalOrderIterator, ordinalBetween, prepare, printBoundGraph, printBoundGraph, printGraph, printGraph, printGraphError, wrapWithOrdinal
public LocalStepStreamGraph(cascading.flow.FlowProcess<java.util.Properties> flowProcess, LocalFlowStep step, cascading.flow.FlowNode node)
protected void buildGraph()
protected cascading.flow.stream.duct.Duct createFork(cascading.flow.stream.duct.Duct[] allNext)
createFork
in class cascading.flow.stream.graph.StreamGraph
protected cascading.flow.stream.duct.Gate createCoGroupGate(cascading.pipe.CoGroup element, cascading.flow.stream.graph.IORole role)
createCoGroupGate
in class cascading.flow.stream.graph.NodeStreamGraph
protected cascading.flow.stream.duct.Gate createGroupByGate(cascading.pipe.GroupBy element, cascading.flow.stream.graph.IORole source)
createGroupByGate
in class cascading.flow.stream.graph.NodeStreamGraph
protected cascading.flow.stream.duct.Duct createMergeStage(cascading.pipe.Merge merge, cascading.flow.stream.graph.IORole both)
createMergeStage
in class cascading.flow.stream.graph.NodeStreamGraph
protected cascading.flow.stream.element.SinkStage createSinkStage(cascading.tap.Tap element)
createSinkStage
in class cascading.flow.stream.graph.NodeStreamGraph
Copyright © 2007-2015 Xplenty, Inc. All Rights Reserved.