|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object cascading.flow.stream.StreamGraph cascading.flow.stream.StepStreamGraph cascading.flow.hadoop.stream.HadoopMapStreamGraph
public class HadoopMapStreamGraph
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 |
---|
public HadoopMapStreamGraph(HadoopFlowProcess flowProcess, HadoopFlowStep step, cascading.tap.Tap source)
Method Detail |
---|
public cascading.flow.stream.SourceStage getStreamedHead()
protected void buildGraph()
protected cascading.flow.stream.SinkStage createSinkStage(cascading.tap.Tap element)
createSinkStage
in class cascading.flow.stream.StepStreamGraph
protected cascading.flow.stream.Gate createCoGroupGate(cascading.pipe.CoGroup element)
createCoGroupGate
in class cascading.flow.stream.StepStreamGraph
protected cascading.flow.stream.Gate createGroupByGate(cascading.pipe.GroupBy element)
createGroupByGate
in class cascading.flow.stream.StepStreamGraph
protected cascading.flow.stream.MemoryHashJoinGate createNonBlockingJoinGate(cascading.pipe.HashJoin join)
createNonBlockingJoinGate
in class cascading.flow.stream.StepStreamGraph
protected boolean stopOnElement(cascading.flow.FlowElement lhsElement, List<cascading.flow.FlowElement> successors)
stopOnElement
in class cascading.flow.stream.StepStreamGraph
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |