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.