com.hazelcast.map.impl.operation

Class SynchronizeIndexesForPartitionTask

java.lang.Object

com.hazelcast.map.impl.operation.SynchronizeIndexesForPartitionTask

All Implemented Interfaces:

PartitionSpecificRunnable, Runnable

public class SynchronizeIndexesForPartitionTask
extends Object
implements PartitionSpecificRunnable

A task that is sent to all local partitions in order to add the indexes that have been specified in the task. Each task is executed for a separate partition. It is a compatibility mode between 3.8 and 3.9 nodes. It is only necessary due to race between PostJoinMapOperations and MapReplicationOperations, so the map data may arrive before the index definitions. This task is responsible to put the index instances back in sync with the definitions.

See Also:

MapIndexSynchronizer, PostJoinMapOperation, MapReplicationStateHolder

Constructor Summary

Constructors

Constructor and Description
SynchronizeIndexesForPartitionTask(int partitionId, List<MapIndexInfo> mapIndexInfos, MapService mapService, SerializationService serializationService, InternalPartitionService partitionService)

Method Summary

Modifier and Type	Method and Description
int	getPartitionId() Returns the partition ID.
void	run()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SynchronizeIndexesForPartitionTask

public SynchronizeIndexesForPartitionTask(int partitionId,
                                          List<MapIndexInfo> mapIndexInfos,
                                          MapService mapService,
                                          SerializationService serializationService,
                                          InternalPartitionService partitionService)

Method Detail

run

public void run()

Specified by:

run in interface Runnable

getPartitionId

public int getPartitionId()

Description copied from interface: PartitionSpecificRunnable

Returns the partition ID. If the partition ID is smaller than 0, than it isn't specific to a partition.

Specified by:

getPartitionId in interface PartitionSpecificRunnable

Returns:

the partition ID