|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectcascading.flow.FlowPlanner
public class FlowPlanner
Class FlowPlanner is the base class for all planner implementations.
Field Summary | |
---|---|
protected AssertionLevel |
assertionLevel
Field assertionLevel |
protected DebugLevel |
debugLevel
Field debugLevel |
protected Map<Object,Object> |
properties
Field properties |
Method Summary | |
---|---|
protected ElementGraph |
createElementGraph(Pipe[] pipes,
Map<String,Tap> sources,
Map<String,Tap> sinks,
Map<String,Tap> traps)
Creates a new ElementGraph instance. |
protected void |
failOnGroupEverySplit(ElementGraph elementGraph)
|
protected void |
failOnLoneGroupAssertion(ElementGraph elementGraph)
Verifies that there are not only GroupAssertions following any given Group instance. |
protected void |
failOnMissingGroup(ElementGraph elementGraph)
|
protected void |
failOnMisusedBuffer(ElementGraph elementGraph)
|
protected void |
verifyAssembly(Pipe[] pipes,
Map<String,Tap> sources,
Map<String,Tap> sinks,
Map<String,Tap> traps)
Must be called to determine if all elements of the base pipe assembly are available |
protected void |
verifyPipeAssemblyEndPoints(Map<String,Tap> sources,
Map<String,Tap> sinks,
Pipe[] pipes)
Method verifyEndPoints verifies there aren't dupe names in heads or tails. |
protected void |
verifySourceNotSinks(Map<String,Tap> sources,
Map<String,Tap> sinks)
|
protected void |
verifyTaps(Map<String,Tap> taps,
boolean areSources,
boolean mayNotBeEmpty)
Method verifyTaps ... |
protected void |
verifyTraps(Map<String,Tap> traps,
Pipe[] pipes,
Map<String,Tap> sources,
Map<String,Tap> sinks)
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
protected final Map<Object,Object> properties
protected AssertionLevel assertionLevel
protected DebugLevel debugLevel
Method Detail |
---|
protected void verifyAssembly(Pipe[] pipes, Map<String,Tap> sources, Map<String,Tap> sinks, Map<String,Tap> traps)
protected ElementGraph createElementGraph(Pipe[] pipes, Map<String,Tap> sources, Map<String,Tap> sinks, Map<String,Tap> traps)
protected void verifySourceNotSinks(Map<String,Tap> sources, Map<String,Tap> sinks)
protected void verifyTaps(Map<String,Tap> taps, boolean areSources, boolean mayNotBeEmpty)
taps
- of type MapareSources
- of type booleanmayNotBeEmpty
- of type booleanprotected void verifyPipeAssemblyEndPoints(Map<String,Tap> sources, Map<String,Tap> sinks, Pipe[] pipes)
sources
- of type Mapsinks
- of type Mappipes
- of type Pipe[]protected void verifyTraps(Map<String,Tap> traps, Pipe[] pipes, Map<String,Tap> sources, Map<String,Tap> sinks)
protected void failOnLoneGroupAssertion(ElementGraph elementGraph)
protected void failOnMissingGroup(ElementGraph elementGraph)
protected void failOnMisusedBuffer(ElementGraph elementGraph)
protected void failOnGroupEverySplit(ElementGraph elementGraph)
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |