Package | Description |
---|---|
com.hazelcast.jet.core |
Jet's Core API.
|
Modifier and Type | Method and Description |
---|---|
Edge |
Edge.allToOne(Object key)
Activates a special-cased
PARTITIONED
routing policy where all items will be routed to the same partition ID,
determined from the given key . |
static Edge |
Edge.between(Vertex source,
Vertex destination)
Returns an edge between two vertices.
|
Edge |
Edge.broadcast()
Activates the
BROADCAST routing policy. |
Edge |
Edge.distributed()
Declares that the edge is distributed.
|
Edge |
Edge.distributeTo(Address targetMember)
Declares that all items sent over this edge will be delivered to the
specified member.
|
Edge |
Edge.fanout()
Activates the
FANOUT routing policy. |
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.isolated()
Activates the
ISOLATED routing policy
which establishes isolated paths from upstream to downstream processors. |
Edge |
Edge.local()
Declares that the edge is local.
|
Edge |
Edge.ordered(ComparatorEx<?> comparator)
Specifies that the data traveling on this edge is ordered according to
the provided comparator.
|
<T> Edge |
Edge.partitioned(FunctionEx<T,?> extractKeyFn)
Activates the
PARTITIONED routing
policy and applies the default
Hazelcast partitioning strategy. |
<T,K> Edge |
Edge.partitioned(FunctionEx<T,K> extractKeyFn,
Partitioner<? super K> partitioner)
Activates the
PARTITIONED routing
policy and applies the provided partitioning strategy. |
Edge |
Edge.priority(int priority)
Sets the priority of the edge.
|
Edge |
Edge.setConfig(EdgeConfig config)
Assigns an
EdgeConfig to this edge. |
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.
|
Edge |
Edge.unicast()
Chooses the
UNICAST routing policy for
this edge. |
Modifier and Type | Method and Description |
---|---|
List<Edge> |
DAG.getInboundEdges(String vertexName)
Returns the inbound edges connected to the vertex with the given name.
|
List<Edge> |
DAG.getOutboundEdges(String vertexName)
Returns the outbound edges connected to the vertex with the given name.
|
Modifier and Type | Method and Description |
---|---|
DAG |
DAG.edge(Edge edge)
Adds an edge to this DAG.
|
Copyright © 2022 Hazelcast, Inc.. All rights reserved.