| 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.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) |
default void |
MigrationInterceptor.onMigrationCommit(MigrationInterceptor.MigrationParticipant participant,
MigrationInfo migration) |
default void |
MigrationInterceptor.onMigrationComplete(MigrationInterceptor.MigrationParticipant participant,
MigrationInfo migration,
boolean success) |
default void |
MigrationInterceptor.onMigrationRollback(MigrationInterceptor.MigrationParticipant participant,
MigrationInfo migration) |
default void |
MigrationInterceptor.onMigrationStart(MigrationInterceptor.MigrationParticipant participant,
MigrationInfo migration) |
void |
PartitionEventManager.sendMigrationEvent(MigrationState state,
MigrationInfo migrationInfo,
long elapsed)
Sends a
ReplicaMigrationEvent to the registered event listeners. |
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) |
default void |
MigrationInterceptor.onPromotionComplete(MigrationInterceptor.MigrationParticipant participant,
Collection<MigrationInfo> migrations,
boolean success) |
default void |
MigrationInterceptor.onPromotionStart(MigrationInterceptor.MigrationParticipant participant,
Collection<MigrationInfo> migrations) |
| Constructor and Description |
|---|
FinalizeMigrationOperation(MigrationInfo migrationInfo,
MigrationEndpoint endpoint,
boolean success) |
MigrationCommitOperation(MigrationInfo migration,
UUID 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,
UUID 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 © 2019 Hazelcast, Inc.. All rights reserved.