Package | Description |
---|---|
com.hazelcast.jet.core |
Jet's Core API.
|
Modifier and Type | Class and Description |
---|---|
static class |
Partitioner.Default
Partitioner which applies the default Hazelcast partitioning strategy.
|
Modifier and Type | Field and Description |
---|---|
static Partitioner<Object> |
Partitioner.HASH_CODE
Partitioner which calls
Object.hashCode() and coerces it with the
modulo operation into the allowed range of partition IDs. |
Modifier and Type | Method and Description |
---|---|
static Partitioner<Object> |
Partitioner.defaultPartitioner()
Returns a partitioner which applies the default Hazelcast partitioning.
|
Partitioner<?> |
Edge.getPartitioner()
Returns the instance encapsulating the partitioning strategy in effect
on this edge.
|
Modifier and Type | Method and Description |
---|---|
<T,K> Edge |
Edge.partitioned(FunctionEx<T,K> extractKeyFn,
Partitioner<? super K> partitioner)
Activates the
PARTITIONED routing
policy and applies the provided partitioning strategy. |
Copyright © 2023 Hazelcast, Inc.. All rights reserved.