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 and Description
static class	Topology.Builder
static class	Topology.Vertex
protected static class	Topology.VertexType

Field Summary

Fields

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

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	Topology(Topology.Builder builder)

Method Summary

Modifier and Type	Method and Description
static Topology.Builder	builder()
protected void	generateDag(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)
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 Detail

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 Detail

Topology

protected Topology(Topology.Builder builder)

Method Detail

builder

public static Topology.Builder builder()

toPlantuml

public String toPlantuml()

A plantuml representation of the topology.

toPlantuml

public String toPlantuml(Settings settings)

generateDag

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

Throws:

org.jgrapht.experimental.dag.DirectedAcyclicGraph.CycleFoundException

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()