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.waitnotifyservice.impl |
Contains the implementation code for the
WaitNotifyService . |
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 |
---|---|
boolean |
MigrationManager.addActiveMigration(MigrationInfo migrationInfo) |
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) |
Constructor and Description |
---|
FinalizeMigrationOperation(MigrationInfo migrationInfo,
MigrationEndpoint endpoint,
boolean success) |
MigrationOperation(MigrationInfo migrationInfo,
long[] replicaVersions,
Collection<Operation> tasks,
int partitionStateVersion) |
MigrationRequestOperation(MigrationInfo migrationInfo,
int partitionStateVersion) |
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 |
WaitNotifyServiceImpl.onPartitionMigrate(Address thisAddress,
MigrationInfo migrationInfo) |
Copyright © 2016 Hazelcast, Inc.. All Rights Reserved.