Uses of Interface
com.hazelcast.jet.core.Partitioner
Package | Description |
---|---|
com.hazelcast.jet.core |
Jet's Core API.
|
-
Uses of Partitioner in com.hazelcast.jet.core
Classes in com.hazelcast.jet.core that implement Partitioner Modifier and Type Class Description static class
Partitioner.Default
Partitioner which applies the default Hazelcast partitioning strategy.Fields in com.hazelcast.jet.core declared as Partitioner Modifier and Type Field Description static Partitioner<Object>
Partitioner. HASH_CODE
Partitioner which callsObject.hashCode()
and coerces it with the modulo operation into the allowed range of partition IDs.Methods in com.hazelcast.jet.core that return Partitioner Modifier and Type Method 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.Methods in com.hazelcast.jet.core with parameters of type Partitioner Modifier and Type Method Description <T, K> Edge
Edge. partitioned(FunctionEx<T,K> extractKeyFn, Partitioner<? super K> partitioner)
Activates thePARTITIONED
routing policy and applies the provided partitioning strategy.