Package com.hazelcast.jet.core
Class Partitioner.Default
java.lang.Object
com.hazelcast.jet.core.Partitioner.Default
- All Implemented Interfaces:
Partitioner<Object>
,Serializable
- Enclosing interface:
- Partitioner<T>
public static final class Partitioner.Default extends Object implements Partitioner<Object>
Partitioner which applies the default Hazelcast partitioning strategy.
Instances should be retrieved from
Partitioner.defaultPartitioner()
.- See Also:
- Serialized Form
-
Nested Class Summary
Nested classes/interfaces inherited from interface com.hazelcast.jet.core.Partitioner
Partitioner.Default
-
Field Summary
-
Method Summary
Modifier and Type Method Description int
getPartition(Object item, int partitionCount)
Returns the partition ID of the given item.void
init(DefaultPartitionStrategy defaultPartitioning)
Callback that injects the Hazelcast's default partitioning strategy into this partitioner so it can be consulted by thePartitioner.getPartition(Object, int)
method.
-
Method Details
-
init
Description copied from interface:Partitioner
Callback that injects the Hazelcast's default partitioning strategy into this partitioner so it can be consulted by thePartitioner.getPartition(Object, int)
method.The creation of instances of the
Partitioner
type is done in user's code, but the Hazelcast partitioning strategy only becomes available after the partitioner is deserialized on each target member. This method solves the lifecycle mismatch.- Specified by:
init
in interfacePartitioner<Object>
-
getPartition
Description copied from interface:Partitioner
Returns the partition ID of the given item.- Specified by:
getPartition
in interfacePartitioner<Object>
partitionCount
- the total number of partitions in use by the underlying Hazelcast instance
-