cascading.flow.planner.graph

Class FlowElementGraph

java.lang.Object

cascading.flow.planner.graph.BaseElementGraph

cascading.flow.planner.graph.BaseAnnotatedElementGraph

cascading.flow.planner.graph.ElementDirectedGraph

cascading.flow.planner.graph.FlowElementGraph

All Implemented Interfaces:

AnnotatedGraph, ElementGraph, Serializable

public class FlowElementGraph
extends ElementDirectedGraph
implements AnnotatedGraph

Class ElementGraph represents the executable FlowElement graph.

See Also:

Serialized Form

Field Summary

Fields inherited from class cascading.flow.planner.graph.BaseAnnotatedElementGraph

annotations

Fields inherited from class cascading.flow.planner.graph.BaseElementGraph

graph, NULL

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	FlowElementGraph()
	FlowElementGraph(FlowElementGraph flowElementGraph)
	FlowElementGraph(Pipe[] pipes, Map<String,Tap> sources, Map<String,Tap> sinks)
	FlowElementGraph(PlatformInfo platformInfo, Pipe[] pipes, Map<String,Tap> sources, Map<String,Tap> sinks, Map<String,Tap> traps, Map<String,Tap> checkpoints, boolean requireUniqueCheckpoints) Constructor ElementGraph creates a new ElementGraph instance.

Method Summary

Methods

Modifier and Type	Method and Description
ElementGraph	copyElementGraph()
Map<String,Tap>	getCheckpointsMap()
org.jgrapht.traverse.DepthFirstIterator<FlowElement,Scope>	getDepthFirstIterator() Method getDepthFirstIterator returns the depthFirstIterator of this ElementGraph object.
Map<String,Tap>	getSinkMap()
Collection<Tap>	getSinks()
Map<String,Tap>	getSourceMap()
Collection<Tap>	getSources()
org.jgrapht.traverse.TopologicalOrderIterator<FlowElement,Scope>	getTopologicalIterator() Method getTopologicalIterator returns the topologicalIterator of this ElementGraph object.
Map<String,Tap>	getTrapMap()
Collection<Tap>	getTraps()
protected void	initialize(Map<String,Tap> sources, Map<String,Tap> sinks, Pipe... tails)
void	resolveFields() Method resolveFields performs a breadth first traversal and resolves the tuple fields between each Pipe instance.
protected FlowElementGraph	shallowCopyElementGraph()
void	writeDOT(String filename) Method writeDOT writes this element graph to a DOT file for easy visualization and debugging.

Methods inherited from class cascading.flow.planner.graph.BaseAnnotatedElementGraph

addParentAnnotations, getAnnotations, hasAnnotations, hashCode

Methods inherited from class cascading.flow.planner.graph.BaseElementGraph

addEdge, addEdge, addVertex, containsEdge, containsEdge, containsVertex, edgeSet, edgesOf, equals, getAllEdges, getEdge, getEdgeSource, getEdgeTarget, incomingEdgesOf, inDegreeOf, outDegreeOf, outgoingEdgesOf, predecessorListOf, removeAllEdges, removeAllEdges, removeAllVertices, removeEdge, removeEdge, removeVertex, successorListOf, vertexSet

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface cascading.flow.planner.graph.AnnotatedGraph

getAnnotations, hasAnnotations

Constructor Detail

FlowElementGraph

protected FlowElementGraph()

FlowElementGraph

public FlowElementGraph(FlowElementGraph flowElementGraph)

FlowElementGraph

public FlowElementGraph(Pipe[] pipes,
                Map<String,Tap> sources,
                Map<String,Tap> sinks)

FlowElementGraph

public FlowElementGraph(PlatformInfo platformInfo,
                Pipe[] pipes,
                Map<String,Tap> sources,
                Map<String,Tap> sinks,
                Map<String,Tap> traps,
                Map<String,Tap> checkpoints,
                boolean requireUniqueCheckpoints)

Constructor ElementGraph creates a new ElementGraph instance.

Parameters:

pipes - of type Pipe[]

sources - of type Map

sinks - of type Map

Method Detail

getSourceMap

public Map<String,Tap> getSourceMap()

getSinkMap

public Map<String,Tap> getSinkMap()

getTrapMap

public Map<String,Tap> getTrapMap()

getCheckpointsMap

public Map<String,Tap> getCheckpointsMap()

getSources

public Collection<Tap> getSources()

getSinks

public Collection<Tap> getSinks()

getTraps

public Collection<Tap> getTraps()

initialize

protected void initialize(Map<String,Tap> sources,
              Map<String,Tap> sinks,
              Pipe... tails)

shallowCopyElementGraph

protected FlowElementGraph shallowCopyElementGraph()

getTopologicalIterator

public org.jgrapht.traverse.TopologicalOrderIterator<FlowElement,Scope> getTopologicalIterator()

Method getTopologicalIterator returns the topologicalIterator of this ElementGraph object.

Returns:

the topologicalIterator (type TopologicalOrderIterator) of this ElementGraph object.

getDepthFirstIterator

public org.jgrapht.traverse.DepthFirstIterator<FlowElement,Scope> getDepthFirstIterator()

Method getDepthFirstIterator returns the depthFirstIterator of this ElementGraph object.

Returns:

the depthFirstIterator (type DepthFirstIterator) of this ElementGraph object.

writeDOT

public void writeDOT(String filename)

Method writeDOT writes this element graph to a DOT file for easy visualization and debugging.

Specified by:

writeDOT in interface ElementGraph

Overrides:

writeDOT in class BaseElementGraph

Parameters:

filename - of type String

resolveFields

public void resolveFields()

Method resolveFields performs a breadth first traversal and resolves the tuple fields between each Pipe instance.

copyElementGraph

public ElementGraph copyElementGraph()

Specified by:

copyElementGraph in interface ElementGraph

Overrides:

copyElementGraph in class ElementDirectedGraph