| Package | Description | 
|---|---|
| com.hazelcast.internal.partition | 
 Contains the internals for partition assignment/management, migration, replication etc. 
 | 
| com.hazelcast.internal.partition.impl | 
 Contains the actual implementation of the  
InternalPartitionService. | 
| com.hazelcast.internal.partition.operation | 
 Contains the operations for partition package. 
 | 
| com.hazelcast.spi.impl | 
 Contains implementations for Hazelcast SPI. 
 | 
| com.hazelcast.spi.impl.operationparker.impl | 
 Contains the implementation code for the  
OperationParker. | 
| Modifier and Type | Method and Description | 
|---|---|
MigrationInfo | 
PartitionRuntimeState.getActiveMigration()  | 
MigrationInfo | 
MigrationInfo.setMaster(Address master)  | 
MigrationInfo | 
MigrationInfo.setStatus(MigrationInfo.MigrationStatus status)  | 
| Modifier and Type | Method and Description | 
|---|---|
Collection<MigrationInfo> | 
PartitionRuntimeState.getCompletedMigrations()  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
PartitionRuntimeState.setActiveMigration(MigrationInfo activeMigration)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
PartitionRuntimeState.setCompletedMigrations(Collection<MigrationInfo> completedMigrations)  | 
| Constructor and Description | 
|---|
PartitionRuntimeState(InternalPartition[] partitions,
                     Collection<MigrationInfo> migrationInfos,
                     int version)  | 
| Modifier and Type | Method and Description | 
|---|---|
MigrationInfo | 
MigrationManager.setActiveMigration(MigrationInfo migrationInfo)
Sets the active migration if none is set and returns  
null, otherwise returns the currently set active migration. | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
InternalMigrationListener.onMigrationCommit(InternalMigrationListener.MigrationParticipant participant,
                 MigrationInfo migrationInfo)  | 
void | 
InternalMigrationListener.NopInternalMigrationListener.onMigrationCommit(InternalMigrationListener.MigrationParticipant participant,
                 MigrationInfo migrationInfo)  | 
void | 
InternalMigrationListener.onMigrationComplete(InternalMigrationListener.MigrationParticipant participant,
                   MigrationInfo migrationInfo,
                   boolean success)  | 
void | 
InternalMigrationListener.NopInternalMigrationListener.onMigrationComplete(InternalMigrationListener.MigrationParticipant participant,
                   MigrationInfo migrationInfo,
                   boolean success)  | 
void | 
InternalMigrationListener.onMigrationRollback(InternalMigrationListener.MigrationParticipant participant,
                   MigrationInfo migrationInfo)  | 
void | 
InternalMigrationListener.NopInternalMigrationListener.onMigrationRollback(InternalMigrationListener.MigrationParticipant participant,
                   MigrationInfo migrationInfo)  | 
void | 
InternalMigrationListener.onMigrationStart(InternalMigrationListener.MigrationParticipant participant,
                MigrationInfo migrationInfo)  | 
void | 
InternalMigrationListener.NopInternalMigrationListener.onMigrationStart(InternalMigrationListener.MigrationParticipant participant,
                MigrationInfo migrationInfo)  | 
MigrationInfo | 
MigrationManager.setActiveMigration(MigrationInfo migrationInfo)
Sets the active migration if none is set and returns  
null, otherwise returns the currently set active migration. | 
| Constructor and Description | 
|---|
FinalizeMigrationOperation(MigrationInfo migrationInfo,
                          MigrationEndpoint endpoint,
                          boolean success)  | 
LegacyMigrationOperation(MigrationInfo migrationInfo,
                        long[] replicaVersions,
                        Collection<Operation> tasks,
                        int partitionStateVersion)  | 
LegacyMigrationRequestOperation(MigrationInfo migrationInfo,
                               int partitionStateVersion)  | 
MigrationOperation(MigrationInfo migrationInfo,
                  int partitionStateVersion,
                  ReplicaFragmentMigrationState fragmentMigrationState,
                  boolean firstFragment,
                  boolean lastFragment)  | 
MigrationRequestOperation(MigrationInfo migrationInfo,
                         int partitionStateVersion,
                         boolean fragmentedMigrationEnabled)  | 
| Constructor and Description | 
|---|
PromotionCommitOperation(PartitionRuntimeState partitionState,
                        Collection<MigrationInfo> promotions,
                        String expectedMemberUuid)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
NodeEngineImpl.onPartitionMigrate(MigrationInfo migrationInfo)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
OperationParkerImpl.onPartitionMigrate(Address thisAddress,
                  MigrationInfo migrationInfo)
Invalidates all parked operations for the migrated partition and sends a  
PartitionMigratingException as a
 response. | 
Copyright © 2018 Hazelcast, Inc.. All Rights Reserved.