cascading.flow.planner.process

Class BaseProcessGraph<Process extends ProcessModel>

java.lang.Object

cascading.flow.planner.process.BaseProcessGraph<Process>

All Implemented Interfaces:

ProcessGraph<Process>, Serializable

Direct Known Subclasses:

FlowNodeGraph, FlowStepGraph

public abstract class BaseProcessGraph<Process extends ProcessModel>
extends Object
implements ProcessGraph<Process>

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected Set<FlowElement>	sinkElements
protected Set<FlowElement>	sourceElements
protected Map<String,Tap>	trapsMap

Constructor Summary

Constructors

Constructor and Description
BaseProcessGraph()

Method Summary

Methods

Modifier and Type	Method and Description
ProcessEdge	addEdge(Process sourceVertex, Process targetVertex)
boolean	addEdge(Process sourceVertex, Process targetVertex, ProcessEdge processEdge)
boolean	addVertex(Process process)
protected void	bindEdges()
boolean	containsEdge(ProcessEdge processEdge)
boolean	containsEdge(Process sourceVertex, Process targetVertex)
boolean	containsVertex(Process process)
Set<ProcessEdge>	edgeSet()
Set<ProcessEdge>	edgesOf(Process vertex)
Set<ProcessEdge>	getAllEdges(Process sourceVertex, Process targetVertex)
Set<FlowElement>	getAllSinkElements()
Set<FlowElement>	getAllSourceElements()
EnumMultiMap<FlowElement>	getAnnotations()
Set<FlowElement>	getDuplicatedElements(ElementGraph elementGraph) All elements, from the given ElementGraph, that belong to two or more processes, that are not sink or source elements that connect processes.
ProcessEdge	getEdge(Process sourceVertex, Process targetVertex)
Process	getEdgeSource(ProcessEdge processEdge)
Process	getEdgeTarget(ProcessEdge processEdge)
double	getEdgeWeight(ProcessEdge processEdge)
List<ElementGraph>	getElementGraphs(FlowElement flowElement)
List<ElementGraph>	getElementGraphs(Scope scope)
List<Process>	getElementProcesses(FlowElement flowElement)
List<Process>	getElementProcesses(Scope scope)
List<Process>	getElementSinkProcesses(FlowElement flowElement)
List<Process>	getElementSourceProcesses(FlowElement flowElement)
Set<ElementGraph>	getIdentityElementGraphs()
Set<Process>	getIdentityProcesses() Returns a set of processes that perform no internal operations.
Iterator<Process>	getOrderedTopologicalIterator(Comparator<Process> comparator)
Iterator<Process>	getOrdinalTopologicalIterator()
Set<FlowElement>	getSinkElements()
Set<Tap>	getSinkTaps()
Set<FlowElement>	getSourceElements()
Set<Tap>	getSourceTaps()
Iterator<Process>	getTopologicalIterator()
Map<String,Tap>	getTrapsMap()
Set<ProcessEdge>	incomingEdgesOf(Process vertex)
int	inDegreeOf(Process vertex)
int	outDegreeOf(Process vertex)
Set<ProcessEdge>	outgoingEdgesOf(Process vertex)
protected void	printProcessGraph(String filename)
boolean	removeAllEdges(Collection<? extends ProcessEdge> edges)
Set<ProcessEdge>	removeAllEdges(Process sourceVertex, Process targetVertex)
boolean	removeAllVertices(Collection<? extends Process> vertices)
boolean	removeEdge(ProcessEdge processEdge)
ProcessEdge	removeEdge(Process sourceVertex, Process targetVertex)
boolean	removeVertex(Process process)
Set<Process>	vertexSet()
void	writeDOT(String filename) Method writeDOT writes this element graph to a DOT file for easy visualization and debugging.
void	writeDOTNested(String filename, ElementGraph graph)

Methods inherited from class java.lang.Object

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

Field Detail

sourceElements

protected Set<FlowElement> sourceElements

sinkElements

protected Set<FlowElement> sinkElements

trapsMap

protected Map<String,Tap> trapsMap

Constructor Detail

BaseProcessGraph

public BaseProcessGraph()

Method Detail

addVertex

public boolean addVertex(Process process)

Specified by:

addVertex in interface ProcessGraph<Process extends ProcessModel>

bindEdges

protected void bindEdges()

getSourceElements

public Set<FlowElement> getSourceElements()

Specified by:

getSourceElements in interface ProcessGraph<Process extends ProcessModel>

getSinkElements

public Set<FlowElement> getSinkElements()

Specified by:

getSinkElements in interface ProcessGraph<Process extends ProcessModel>

getSourceTaps

public Set<Tap> getSourceTaps()

Specified by:

getSourceTaps in interface ProcessGraph<Process extends ProcessModel>

getSinkTaps

public Set<Tap> getSinkTaps()

Specified by:

getSinkTaps in interface ProcessGraph<Process extends ProcessModel>

getTrapsMap

public Map<String,Tap> getTrapsMap()

Specified by:

getTrapsMap in interface ProcessGraph<Process extends ProcessModel>

getTopologicalIterator

public Iterator<Process> getTopologicalIterator()

Specified by:

getTopologicalIterator in interface ProcessGraph<Process extends ProcessModel>

getOrdinalTopologicalIterator

public Iterator<Process> getOrdinalTopologicalIterator()

Specified by:

getOrdinalTopologicalIterator in interface ProcessGraph<Process extends ProcessModel>

getOrderedTopologicalIterator

public Iterator<Process> getOrderedTopologicalIterator(Comparator<Process> comparator)

Specified by:

getOrderedTopologicalIterator in interface ProcessGraph<Process extends ProcessModel>

getElementGraphs

public List<ElementGraph> getElementGraphs(FlowElement flowElement)

Specified by:

getElementGraphs in interface ProcessGraph<Process extends ProcessModel>

getElementProcesses

public List<Process> getElementProcesses(FlowElement flowElement)

Specified by:

getElementProcesses in interface ProcessGraph<Process extends ProcessModel>

getElementGraphs

public List<ElementGraph> getElementGraphs(Scope scope)

Specified by:

getElementGraphs in interface ProcessGraph<Process extends ProcessModel>

getElementProcesses

public List<Process> getElementProcesses(Scope scope)

Specified by:

getElementProcesses in interface ProcessGraph<Process extends ProcessModel>

getElementSourceProcesses

public List<Process> getElementSourceProcesses(FlowElement flowElement)

Specified by:

getElementSourceProcesses in interface ProcessGraph<Process extends ProcessModel>

getElementSinkProcesses

public List<Process> getElementSinkProcesses(FlowElement flowElement)

Specified by:

getElementSinkProcesses in interface ProcessGraph<Process extends ProcessModel>

getAllSourceElements

public Set<FlowElement> getAllSourceElements()

Specified by:

getAllSourceElements in interface ProcessGraph<Process extends ProcessModel>

getAllSinkElements

public Set<FlowElement> getAllSinkElements()

Specified by:

getAllSinkElements in interface ProcessGraph<Process extends ProcessModel>

getAnnotations

public EnumMultiMap<FlowElement> getAnnotations()

Specified by:

getAnnotations in interface ProcessGraph<Process extends ProcessModel>

getDuplicatedElements

public Set<FlowElement> getDuplicatedElements(ElementGraph elementGraph)

All elements, from the given ElementGraph, that belong to two or more processes, that are not sink or source elements that connect processes.

Specified by:

getDuplicatedElements in interface ProcessGraph<Process extends ProcessModel>

Returns:

Set

getIdentityElementGraphs

public Set<ElementGraph> getIdentityElementGraphs()

Specified by:

getIdentityElementGraphs in interface ProcessGraph<Process extends ProcessModel>

getIdentityProcesses

public Set<Process> getIdentityProcesses()

Returns a set of processes that perform no internal operations.

for example if a FlowNode only has a Merge source and a GroupBy sink.

Specified by:

getIdentityProcesses in interface ProcessGraph<Process extends ProcessModel>

Returns:

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 ProcessGraph<Process extends ProcessModel>

Parameters:

filename - of type String

printProcessGraph

protected void printProcessGraph(String filename)

writeDOTNested

public void writeDOTNested(String filename,
                  ElementGraph graph)

Specified by:

writeDOTNested in interface ProcessGraph<Process extends ProcessModel>

containsEdge

public boolean containsEdge(Process sourceVertex,
                   Process targetVertex)

Specified by:

containsEdge in interface ProcessGraph<Process extends ProcessModel>

removeAllEdges

public boolean removeAllEdges(Collection<? extends ProcessEdge> edges)

Specified by:

removeAllEdges in interface ProcessGraph<Process extends ProcessModel>

removeAllEdges

public Set<ProcessEdge> removeAllEdges(Process sourceVertex,
                              Process targetVertex)

Specified by:

removeAllEdges in interface ProcessGraph<Process extends ProcessModel>

removeAllVertices

public boolean removeAllVertices(Collection<? extends Process> vertices)

Specified by:

removeAllVertices in interface ProcessGraph<Process extends ProcessModel>

getAllEdges

public Set<ProcessEdge> getAllEdges(Process sourceVertex,
                           Process targetVertex)

Specified by:

getAllEdges in interface ProcessGraph<Process extends ProcessModel>

getEdge

public ProcessEdge getEdge(Process sourceVertex,
                  Process targetVertex)

Specified by:

getEdge in interface ProcessGraph<Process extends ProcessModel>

addEdge

public ProcessEdge addEdge(Process sourceVertex,
                  Process targetVertex)

Specified by:

addEdge in interface ProcessGraph<Process extends ProcessModel>

addEdge

public boolean addEdge(Process sourceVertex,
              Process targetVertex,
              ProcessEdge processEdge)

Specified by:

addEdge in interface ProcessGraph<Process extends ProcessModel>

getEdgeSource

public Process getEdgeSource(ProcessEdge processEdge)

Specified by:

getEdgeSource in interface ProcessGraph<Process extends ProcessModel>

getEdgeTarget

public Process getEdgeTarget(ProcessEdge processEdge)

Specified by:

getEdgeTarget in interface ProcessGraph<Process extends ProcessModel>

containsEdge

public boolean containsEdge(ProcessEdge processEdge)

Specified by:

containsEdge in interface ProcessGraph<Process extends ProcessModel>

containsVertex

public boolean containsVertex(Process process)

Specified by:

containsVertex in interface ProcessGraph<Process extends ProcessModel>

edgeSet

public Set<ProcessEdge> edgeSet()

Specified by:

edgeSet in interface ProcessGraph<Process extends ProcessModel>

edgesOf

public Set<ProcessEdge> edgesOf(Process vertex)

Specified by:

edgesOf in interface ProcessGraph<Process extends ProcessModel>

inDegreeOf

public int inDegreeOf(Process vertex)

Specified by:

inDegreeOf in interface ProcessGraph<Process extends ProcessModel>

incomingEdgesOf

public Set<ProcessEdge> incomingEdgesOf(Process vertex)

Specified by:

incomingEdgesOf in interface ProcessGraph<Process extends ProcessModel>

outDegreeOf

public int outDegreeOf(Process vertex)

Specified by:

outDegreeOf in interface ProcessGraph<Process extends ProcessModel>

outgoingEdgesOf

public Set<ProcessEdge> outgoingEdgesOf(Process vertex)

Specified by:

outgoingEdgesOf in interface ProcessGraph<Process extends ProcessModel>

removeEdge

public ProcessEdge removeEdge(Process sourceVertex,
                     Process targetVertex)

Specified by:

removeEdge in interface ProcessGraph<Process extends ProcessModel>

removeEdge

public boolean removeEdge(ProcessEdge processEdge)

Specified by:

removeEdge in interface ProcessGraph<Process extends ProcessModel>

removeVertex

public boolean removeVertex(Process process)

Specified by:

removeVertex in interface ProcessGraph<Process extends ProcessModel>

vertexSet

public Set<Process> vertexSet()

Specified by:

vertexSet in interface ProcessGraph<Process extends ProcessModel>

getEdgeWeight

public double getEdgeWeight(ProcessEdge processEdge)

Specified by:

getEdgeWeight in interface ProcessGraph<Process extends ProcessModel>