public static enum Edge.RoutingPolicy extends Enum<Edge.RoutingPolicy> implements Serializable
|Enum Constant and Description|
This policy sends each item to all candidate processors.
This policy sends an item to all members, but only to one processor on each member.
This policy sets up isolated parallel data paths between two vertices as much as it can, given the level of mismatch between the local parallelism (LP) of the upstream vs.
This policy sends every item to the one processor responsible for the item's partition ID.
This policy chooses for each item a single destination processor from the candidate set, with no restriction on the choice.
|Modifier and Type||Method and Description|
Returns the enum constant of this type with the specified name.
Returns an array containing the constants of this enum type, in the order they are declared.
clone, compareTo, equals, finalize, getDeclaringClass, hashCode, name, ordinal, toString, valueOf
public static final Edge.RoutingPolicy UNICAST
public static final Edge.RoutingPolicy ISOLATED
This policy is only available on a local edge.
public static final Edge.RoutingPolicy PARTITIONED
public static final Edge.RoutingPolicy BROADCAST
public static final Edge.RoutingPolicy FANOUT
UNICAST: an item is first broadcast to all members, and then, on each member, it is unicast to one processor.
If the destination local parallelism is 1, the behavior is equal to
BROADCAST. If the member count in the cluster is 1, the
behavior is equal to
To work as expected, the edge must be also
Otherwise it will work just like
public static Edge.RoutingPolicy values()
for (Edge.RoutingPolicy c : Edge.RoutingPolicy.values()) System.out.println(c);
public static Edge.RoutingPolicy valueOf(String name)
name- the name of the enum constant to be returned.
IllegalArgumentException- if this enum type has no constant with the specified name
NullPointerException- if the argument is null
Copyright © 2022 Hazelcast, Inc.. All rights reserved.