Uses of Class
com.hazelcast.jet.core.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-casedPARTITIONED
routing policy where all items will be routed to the same partition ID, determined from the givenkey
.static Edge
Edge. between(Vertex source, Vertex destination)
Returns an edge between two vertices.Edge
Edge. broadcast()
Activates theBROADCAST
routing policy.Edge
Edge. distributed()
Declares that the edge is distributed.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 theISOLATED
routing policy which establishes isolated paths from upstream to downstream processors.<T> Edge
Edge. partitioned(FunctionEx<T,?> extractKeyFn)
Activates thePARTITIONED
routing policy and applies thedefault
Hazelcast partitioning strategy.<T, K> Edge
Edge. partitioned(FunctionEx<T,K> extractKeyFn, Partitioner<? super K> partitioner)
Activates thePARTITIONED
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 anEdgeConfig
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 theUNICAST
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.