public interface InternalPartitionService extends CoreService
Modifier and Type | Field and Description |
---|---|
static long |
DEFAULT_REPLICA_SYNC_DELAY |
static int |
MAX_PARALLEL_REPLICATIONS |
static long |
REPLICA_SYNC_RETRY_DELAY |
static String |
SERVICE_NAME |
Modifier and Type | Method and Description |
---|---|
String |
addMigrationListener(MigrationListener migrationListener) |
void |
clearPartitionReplicaVersions(int partitionId) |
void |
firstArrangement() |
Collection<MigrationInfo> |
getActiveMigrations() |
Member |
getMember(Address address) |
int |
getMemberGroupsSize() |
List<Integer> |
getMemberPartitions(Address target) |
Map<Address,List<Integer>> |
getMemberPartitionsMap() |
long |
getMigrationQueueSize() |
InternalPartition |
getPartition(int partitionId)
Returns the InternalPartition for a given partitionId.
|
int |
getPartitionCount()
Returns the number of partitions.
|
int |
getPartitionId(Data key)
Returns the partition id for a Data key.
|
int |
getPartitionId(Object key)
Returns the partition id for a given object.
|
Address |
getPartitionOwner(int partitionId) |
long[] |
getPartitionReplicaVersions(int partitionId) |
InternalPartition[] |
getPartitions() |
PartitionService |
getPartitionServiceProxy() |
boolean |
hasOnGoingMigration()
Checks if there currently are any migrations.
|
long[] |
incrementPartitionReplicaVersions(int partitionId,
int totalBackupCount) |
void |
memberAdded(MemberImpl newMember) |
void |
memberRemoved(MemberImpl deadMember) |
void |
pauseMigration() |
boolean |
prepareToSafeShutdown(long timeout,
TimeUnit seconds) |
boolean |
removeMigrationListener(String registrationId) |
void |
resumeMigration() |
void |
setPartitionReplicaVersions(int partitionId,
long[] versions) |
void |
updatePartitionReplicaVersions(int partitionId,
long[] replicaVersions,
int replicaIndex) |
static final String SERVICE_NAME
static final int MAX_PARALLEL_REPLICATIONS
static final long DEFAULT_REPLICA_SYNC_DELAY
static final long REPLICA_SYNC_RETRY_DELAY
Address getPartitionOwner(int partitionId)
partitionId
- InternalPartition getPartition(int partitionId)
partitionId
- the partitionIdint getPartitionId(Data key)
key
- the Data key.NullPointerException
- if key is null.int getPartitionId(Object key)
key
- the object key.int getPartitionCount()
boolean hasOnGoingMigration()
int getMemberGroupsSize()
String addMigrationListener(MigrationListener migrationListener)
boolean removeMigrationListener(String registrationId)
long getMigrationQueueSize()
void pauseMigration()
void resumeMigration()
void memberAdded(MemberImpl newMember)
void memberRemoved(MemberImpl deadMember)
boolean prepareToSafeShutdown(long timeout, TimeUnit seconds)
InternalPartition[] getPartitions()
Collection<MigrationInfo> getActiveMigrations()
void firstArrangement()
long[] getPartitionReplicaVersions(int partitionId)
void updatePartitionReplicaVersions(int partitionId, long[] replicaVersions, int replicaIndex)
long[] incrementPartitionReplicaVersions(int partitionId, int totalBackupCount)
void setPartitionReplicaVersions(int partitionId, long[] versions)
void clearPartitionReplicaVersions(int partitionId)
PartitionService getPartitionServiceProxy()
Copyright © 2014 Hazelcast, Inc.. All rights reserved.