public class HadoopMapStreamGraph extends cascading.flow.stream.graph.NodeStreamGraph
Constructor and Description |
---|
HadoopMapStreamGraph(HadoopFlowProcess flowProcess,
cascading.flow.FlowNode node,
cascading.tap.Tap source) |
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.Gate |
createGroupByGate(cascading.pipe.GroupBy element,
cascading.flow.stream.graph.IORole role) |
protected cascading.flow.stream.element.GroupingSpliceGate |
createNonBlockingJoinGate(cascading.pipe.HashJoin join) |
protected cascading.flow.stream.element.SinkStage |
createSinkStage(cascading.tap.Tap element) |
cascading.flow.stream.element.SourceStage |
getStreamedHead() |
createBlockingJoinGate, createBoundaryStage, createHashJoinGate, createMergeStage, findExisting, getProperty, handleDuct, setScopes, setTraps
addHead, addPath, addPath, addTail, bind, cleanup, createCloseWindow, createFork, createNextFor, createOpenReducingWindow, createOpenWindow, findAllNextFor, findAllPreviousFor, getAllDucts, getHeads, getReversedGraph, getReversedTopologicalOrderIterator, getTails, getTopologicalOrderIterator, ordinalBetween, prepare, printBoundGraph, printBoundGraph, printGraph, printGraph, printGraphError, wrapWithOrdinal
public HadoopMapStreamGraph(HadoopFlowProcess flowProcess, cascading.flow.FlowNode node, cascading.tap.Tap source)
public cascading.flow.stream.element.SourceStage getStreamedHead()
protected void buildGraph()
protected cascading.flow.stream.element.SinkStage createSinkStage(cascading.tap.Tap element)
createSinkStage
in class cascading.flow.stream.graph.NodeStreamGraph
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 role)
createGroupByGate
in class cascading.flow.stream.graph.NodeStreamGraph
protected cascading.flow.stream.element.GroupingSpliceGate createNonBlockingJoinGate(cascading.pipe.HashJoin join)
createNonBlockingJoinGate
in class cascading.flow.stream.graph.NodeStreamGraph
Copyright © 2007-2015 Xplenty, Inc. All Rights Reserved.