Package | Description |
---|---|
com.hazelcast.jet.core |
Jet's Core API.
|
Modifier and Type | Method and Description |
---|---|
Vertex |
Edge.getDestination()
Returns this edge's destination vertex.
|
Vertex |
Edge.getSource()
Returns this edge's source vertex.
|
Vertex |
DAG.getVertex(String vertexName)
Returns the vertex with the given name, or
null if there is no
vertex with that name. |
Vertex |
Vertex.localParallelism(int localParallelism)
Sets the number of processors corresponding to this vertex that will be
created on each member.
|
Vertex |
DAG.newUniqueVertex(String namePrefix,
ProcessorMetaSupplier metaSupplier)
Creates a vertex from a
ProcessorMetaSupplier and adds it to
this DAG. |
Vertex |
DAG.newUniqueVertex(String namePrefix,
ProcessorSupplier processorSupplier)
Creates a vertex from a
ProcessorSupplier and adds it to this
DAG. |
Vertex |
DAG.newUniqueVertex(String namePrefix,
SupplierEx<? extends Processor> simpleSupplier)
Creates a vertex from a
Supplier<Processor> and adds it to this
DAG. |
Vertex |
DAG.newVertex(String name,
ProcessorMetaSupplier metaSupplier)
Creates a vertex from a
ProcessorMetaSupplier and adds it to this DAG. |
Vertex |
DAG.newVertex(String name,
ProcessorSupplier processorSupplier)
Creates a vertex from a
ProcessorSupplier and adds it to this DAG. |
Vertex |
DAG.newVertex(String name,
SupplierEx<? extends Processor> simpleSupplier)
Creates a vertex from a
Supplier<Processor> and adds it to this DAG. |
Modifier and Type | Method and Description |
---|---|
Iterator<Vertex> |
DAG.iterator()
Returns an iterator over the DAG's vertices in topological order.
|
Modifier and Type | Method and Description |
---|---|
static Edge |
Edge.between(Vertex source,
Vertex destination)
Returns an edge between two vertices.
|
static Edge |
Edge.from(Vertex source)
Returns an edge with the given source vertex and no destination vertex.
|
static Edge |
Edge.from(Vertex source,
int ordinal)
Returns an edge with the given source vertex at the given ordinal
and no destination vertex.
|
Edge |
Edge.to(Vertex destination)
Sets the destination vertex of this edge, with ordinal 0.
|
Edge |
Edge.to(Vertex destination,
int ordinal)
Sets the destination vertex and ordinal of this edge.
|
DAG |
DAG.vertex(Vertex vertex)
Adds a vertex to this DAG.
|
Constructor and Description |
---|
Edge(Vertex source,
int sourceOrdinal,
Vertex destination,
int destOrdinal) |
Copyright © 2021 Hazelcast, Inc.. All rights reserved.