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.setInitialPartitionVersion(int initialPartitionVersion) |
MigrationInfo |
MigrationInfo.setMaster(Address master) |
MigrationInfo |
MigrationInfo.setPartitionVersionIncrement(int partitionVersionIncrement) |
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) |
Constructor and Description |
---|
PartitionRuntimeState(InternalPartition[] partitions,
Collection<MigrationInfo> completedMigrations,
int version) |
Modifier and Type | Method and Description |
---|---|
MigrationInfo |
MigrationManager.getActiveMigration() |
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 |
---|---|
boolean |
InternalPartitionServiceImpl.commitMigrationOnDestination(MigrationInfo migration,
Address sender) |
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) |
boolean |
MigrationManager.removeFinalizingMigration(MigrationInfo migration) |
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 |
---|---|
boolean |
InternalPartitionServiceImpl.applyCompletedMigrations(Collection<MigrationInfo> migrations,
Address sender) |
void |
InternalMigrationListener.onPromotionComplete(InternalMigrationListener.MigrationParticipant participant,
Collection<MigrationInfo> migrationInfos,
boolean success) |
void |
InternalMigrationListener.onPromotionStart(InternalMigrationListener.MigrationParticipant participant,
Collection<MigrationInfo> migrationInfos) |
Constructor and Description |
---|
FinalizeMigrationOperation(MigrationInfo migrationInfo,
MigrationEndpoint endpoint,
boolean success) |
MigrationCommitOperation(MigrationInfo migration,
String expectedMemberUuid) |
MigrationOperation(MigrationInfo migrationInfo,
List<MigrationInfo> completedMigrations,
int partitionStateVersion,
ReplicaFragmentMigrationState fragmentMigrationState,
boolean firstFragment,
boolean lastFragment) |
MigrationRequestOperation(MigrationInfo migrationInfo,
List<MigrationInfo> completedMigrations,
int partitionStateVersion,
boolean fragmentedMigrationEnabled) |
Constructor and Description |
---|
MigrationOperation(MigrationInfo migrationInfo,
List<MigrationInfo> completedMigrations,
int partitionStateVersion,
ReplicaFragmentMigrationState fragmentMigrationState,
boolean firstFragment,
boolean lastFragment) |
MigrationRequestOperation(MigrationInfo migrationInfo,
List<MigrationInfo> completedMigrations,
int partitionStateVersion,
boolean fragmentedMigrationEnabled) |
PromotionCommitOperation(PartitionRuntimeState partitionState,
Collection<MigrationInfo> promotions,
String expectedMemberUuid) |
PublishCompletedMigrationsOperation(Collection<MigrationInfo> completedMigrations) |
Modifier and Type | Method and Description |
---|---|
void |
NodeEngineImpl.onPartitionMigrate(MigrationInfo migrationInfo) |
Modifier and Type | Method and Description |
---|---|
void |
OperationParkerImpl.onPartitionMigrate(MigrationInfo migrationInfo)
Invalidates all parked operations for the migrated partition and sends a
PartitionMigratingException as a
response. |
Copyright © 2022 Hazelcast, Inc.. All Rights Reserved.