public static enum Edge.RoutingPolicy extends Enum<Edge.RoutingPolicy> implements Serializable
Enum Constant and Description |
---|
BROADCAST
Each item is sent to all candidate processors.
|
ISOLATED
Like
UNICAST , but guarantees that any given downstream
processor receives data from exactly one upstream processor. |
PARTITIONED
Each item is sent to the one processor responsible for the item's
partition ID.
|
UNICAST
For each item a single destination processor is chosen from the
candidate set, with no restriction on the choice.
|
Modifier and Type | Method and Description |
---|---|
static Edge.RoutingPolicy |
valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static Edge.RoutingPolicy[] |
values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
public static final Edge.RoutingPolicy UNICAST
public static final Edge.RoutingPolicy ISOLATED
UNICAST
, but guarantees that any given downstream
processor receives data from exactly one upstream processor. This is
needed in some DAG setups to apply selective backpressure to individual
upstream source processors.
The downstream's local parallelism must not be less than the upstream's. This policy is only available on a local edge.
public static final Edge.RoutingPolicy PARTITIONED
public static final Edge.RoutingPolicy BROADCAST
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 nameNullPointerException
- if the argument is nullCopyright © 2019 Hazelcast, Inc.. All rights reserved.