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.