Uses of Class
com.hazelcast.jet.core.Edge

Packages that use Edge

Package	Description
com.hazelcast.jet.core	Jet's Core API.

Uses of Edge in com.hazelcast.jet.core

Methods in com.hazelcast.jet.core that return Edge

Modifier and Type	Method	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.

Methods in com.hazelcast.jet.core that return types with arguments of type Edge

Modifier and Type	Method	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.

Methods in com.hazelcast.jet.core with parameters of type Edge

Modifier and Type	Method	Description
DAG	DAG.edge(Edge edge)	Adds an edge to this DAG.