com.hazelcast.jet.dag

Class DAG

java.lang.Object

com.hazelcast.jet.dag.DAG

All Implemented Interfaces:

com.hazelcast.nio.serialization.DataSerializable

public class DAG
extends Object
implements com.hazelcast.nio.serialization.DataSerializable

Direct acyclic graph representation

DAG describes topology of calculation flow

     Vertex1 -> Vertex2  -> Vertex3
                            -> Vertex4
 

Data will be passed from vertex to vertex

Constructor Summary

Constructors

Constructor and Description
DAG() Empty constructor
DAG(String name) Create a DAG with a given name

Method Summary

Modifier and Type	Method and Description
DAG	addEdge(Edge edge) Add edge to dag
DAG	addVertex(Vertex vertex)
boolean	containsEdge(Edge edge)
boolean	containsVertex(Vertex vertex)
String	getName()
Iterator<Vertex>	getRevertedTopologicalVertexIterator()
Iterator<Vertex>	getTopologicalVertexIterator()
Vertex	getVertex(String vertexName) Return vertex with corresponding name
Collection<Vertex>	getVertices()
void	readData(com.hazelcast.nio.ObjectDataInput in)
void	validate() Validate DAG's consistency
void	writeData(com.hazelcast.nio.ObjectDataOutput out)

Methods inherited from class java.lang.Object

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

Constructor Detail

DAG

public DAG()

Empty constructor

DAG

public DAG(String name)

Create a DAG with a given name

Parameters:

name - name of the DAG

Method Detail

addVertex

public DAG addVertex(Vertex vertex)

Parameters:

vertex - vertex to add to the DAG

Returns:

the DAG

getVertex

public Vertex getVertex(String vertexName)

Return vertex with corresponding name

Parameters:

vertexName - name of the vertex

Returns:

corresponding vertex

getVertices

public Collection<Vertex> getVertices()

Returns:

collections of DAG's vertices

getName

public String getName()

Returns:

name of the DAG

containsVertex

public boolean containsVertex(Vertex vertex)

Parameters:

vertex - some vertex

Returns:

true if DAG contains vertex, false otherwise

containsEdge

public boolean containsEdge(Edge edge)

Parameters:

edge - some edge

Returns:

true if DAG contains edge, false otherwise

getTopologicalVertexIterator

public Iterator<Vertex> getTopologicalVertexIterator()

Returns:

iterator over DAG's vertices on accordance with DAG's topology

getRevertedTopologicalVertexIterator

public Iterator<Vertex> getRevertedTopologicalVertexIterator()

Returns:

iterator over DAG's vertices on accordance with DAG's reverted topology

validate

public void validate()
              throws IllegalStateException

Validate DAG's consistency

It checks:

        duplicate of vertices names
        duplicate of edges names
        absence of loops on DAG
 

Throws:

IllegalStateException - if DAG validation fails

addEdge

public DAG addEdge(Edge edge)

Add edge to dag

Parameters:

edge - corresponding edge

Returns:

DAG itself

writeData

public void writeData(com.hazelcast.nio.ObjectDataOutput out)
               throws IOException

Specified by:

writeData in interface com.hazelcast.nio.serialization.DataSerializable

Throws:

IOException

readData

public void readData(com.hazelcast.nio.ObjectDataInput in)
              throws IOException

Specified by:

readData in interface com.hazelcast.nio.serialization.DataSerializable

Throws:

IOException