Package org.nuxeo.lib.stream.computation

Class Topology

java.lang.Object

org.nuxeo.lib.stream.computation.Topology

public class Topology
extends Object

Represent a Directed Acyclic Graph (DAG) of computations.

Since:

9.3

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	Topology.Builder
static class	Topology.Vertex
static enum	Topology.VertexType

Field Summary

Fields

Modifier and Type	Field	Description
protected final org.jgrapht.experimental.dag.DirectedAcyclicGraph<Topology.Vertex,org.jgrapht.graph.DefaultEdge>	dag
protected final List<ComputationMetadataMapping>	metadataList
protected final Map<String,ComputationMetadataMapping>	metadataMap
protected final Map<String,Supplier<Computation>>	supplierMap

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	Topology(Topology.Builder builder)

Method Summary

Modifier and Type	Method	Description
static Topology.Builder	builder()
protected String	compactPolicy(ComputationPolicy policy)
protected void	generateDag(Set<ComputationMetadataMapping> metadataSet)
protected void	generateMetadataMapping(Set<ComputationMetadataMapping> metadataSet)
Set<String>	getAncestorComputationNames(String name)
Set<String>	getAncestors(String name)
Set<String>	getChildren(String name)
Set<String>	getChildrenComputationNames(String name)
org.jgrapht.experimental.dag.DirectedAcyclicGraph<Topology.Vertex,org.jgrapht.graph.DefaultEdge>	getDag()
Set<String>	getDescendantComputationNames(String name)
Set<String>	getDescendants(String name)
ComputationMetadataMapping	getMetadata(String name)
Set<String>	getParentComputationsNames(String name)
Set<String>	getParents(String name)
protected String	getPumlIdentifier(String name)
protected String	getPumlName(Topology.Vertex vertex)
Set<String>	getRoots()
Supplier<Computation>	getSupplier(String name)
protected Topology.Vertex	getVertex(String name)
boolean	isSink(String name)
boolean	isSource(String name)
List<ComputationMetadataMapping>	metadataList()
Set<String>	streamsSet()
Set<String>	streamsSet(String root)
String	toPlantuml()	A plantuml representation of the topology.
String	toPlantuml(Settings settings)

Methods inherited from class java.lang.Object

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

Field Details

metadataList

protected final List<ComputationMetadataMapping> metadataList

metadataMap

protected final Map<String,ComputationMetadataMapping> metadataMap

supplierMap

protected final Map<String,Supplier<Computation>> supplierMap

dag

protected final org.jgrapht.experimental.dag.DirectedAcyclicGraph<Topology.Vertex,org.jgrapht.graph.DefaultEdge> dag

Constructor Details

Topology

protected Topology(Topology.Builder builder)

Method Details

builder

public static Topology.Builder builder()

toPlantuml

public String toPlantuml()

A plantuml representation of the topology.

toPlantuml

public String toPlantuml(Settings settings)

compactPolicy

protected String compactPolicy(ComputationPolicy policy)

getPumlName

protected String getPumlName(Topology.Vertex vertex)

getPumlIdentifier

protected String getPumlIdentifier(String name)

generateDag

protected void generateDag(Set<ComputationMetadataMapping> metadataSet)
                    throws org.jgrapht.experimental.dag.DirectedAcyclicGraph.CycleFoundException

Throws:

org.jgrapht.experimental.dag.DirectedAcyclicGraph.CycleFoundException

generateMetadataMapping

protected void generateMetadataMapping(Set<ComputationMetadataMapping> metadataSet)

getMetadata

public ComputationMetadataMapping getMetadata(String name)

getSupplier

public Supplier<Computation> getSupplier(String name)

isSource

public boolean isSource(String name)

isSink

public boolean isSink(String name)

streamsSet

public Set<String> streamsSet()

streamsSet

public Set<String> streamsSet(String root)

metadataList

public List<ComputationMetadataMapping> metadataList()

getVertex

protected Topology.Vertex getVertex(String name)

getDescendants

public Set<String> getDescendants(String name)

getDescendantComputationNames

public Set<String> getDescendantComputationNames(String name)

getChildren

public Set<String> getChildren(String name)

getChildrenComputationNames

public Set<String> getChildrenComputationNames(String name)

getParents

public Set<String> getParents(String name)

getParentComputationsNames

public Set<String> getParentComputationsNames(String name)

getAncestorComputationNames

public Set<String> getAncestorComputationNames(String name)

getAncestors

public Set<String> getAncestors(String name)

getRoots

public Set<String> getRoots()

getDag

public org.jgrapht.experimental.dag.DirectedAcyclicGraph<Topology.Vertex,org.jgrapht.graph.DefaultEdge> getDag()