com.hazelcast.partition

Interface InternalPartitionService

All Superinterfaces:

CoreService

All Known Implementing Classes:

InternalPartitionServiceImpl

public interface InternalPartitionService
extends CoreService

Field Summary

Fields

Modifier and Type	Field and Description
static long	DEFAULT_REPLICA_SYNC_DELAY
static String	MIGRATION_EVENT_TOPIC Static constant for dispatching and listening migration events
static String	PARTITION_LOST_EVENT_TOPIC Static constant for dispatching and listening internal partition lost events
static long	REPLICA_SYNC_RETRY_DELAY
static String	SERVICE_NAME

Method Summary

Methods

Modifier and Type	Method and Description
String	addLocalPartitionLostListener(PartitionLostListener partitionLostListener)
String	addMigrationListener(MigrationListener migrationListener)
String	addPartitionLostListener(PartitionLostListener partitionLostListener)
void	clearPartitionReplicaVersions(int partitionId)
void	firstArrangement()
Collection<MigrationInfo>	getActiveMigrations()
int	getMaxBackupCount()
Member	getMember(Address address)
int	getMemberGroupsSize()
List<Integer>	getMemberPartitions(Address target)
Map<Address,List<Integer>>	getMemberPartitionsMap() Gets member partition IDs.
long	getMigrationQueueSize()
InternalPartition	getPartition(int partitionId) Returns the InternalPartition for a given partitionId.
InternalPartition	getPartition(int partitionId, boolean triggerOwnerAssignment) 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) Gets the owner of the partition if it's set.
Address	getPartitionOwnerOrWait(int partitionId) Gets the owner of the partition.
long[]	getPartitionReplicaVersions(int partitionId)
InternalPartition[]	getPartitions()
PartitionService	getPartitionServiceProxy()
int	getPartitionStateVersion()
boolean	hasOnGoingMigration() Checks if there currently are any migrations.
boolean	hasOnGoingMigrationLocal()
long[]	incrementPartitionReplicaVersions(int partitionId, int totalBackupCount)
boolean	isMemberStateSafe() Query and return if this member in a safe state or not.
boolean	isPartitionOwner(int partitionId) Check if this node is the owner of a partition
void	memberAdded(MemberImpl newMember)
void	memberRemoved(MemberImpl deadMember)
void	pauseMigration()
boolean	prepareToSafeShutdown(long timeout, TimeUnit seconds)
boolean	removeMigrationListener(String registrationId)
boolean	removePartitionLostListener(String registrationId)
void	resumeMigration()
void	setPartitionReplicaVersions(int partitionId, long[] versions, int replicaOffset)
void	updatePartitionReplicaVersions(int partitionId, long[] replicaVersions, int replicaIndex)

Field Detail

SERVICE_NAME

static final String SERVICE_NAME

See Also:

Constant Field Values

DEFAULT_REPLICA_SYNC_DELAY

static final long DEFAULT_REPLICA_SYNC_DELAY

See Also:

Constant Field Values

REPLICA_SYNC_RETRY_DELAY

static final long REPLICA_SYNC_RETRY_DELAY

See Also:

Constant Field Values

MIGRATION_EVENT_TOPIC

static final String MIGRATION_EVENT_TOPIC

Static constant for dispatching and listening migration events

See Also:

Constant Field Values

PARTITION_LOST_EVENT_TOPIC

static final String PARTITION_LOST_EVENT_TOPIC

Static constant for dispatching and listening internal partition lost events

See Also:

Constant Field Values

Method Detail

getPartitionOwner

Address getPartitionOwner(int partitionId)

Gets the owner of the partition if it's set. Otherwise it will trigger partition assignment.

Parameters:

partitionId - the partitionId

Returns:

owner of partition or null if it's not set yet.

getPartitionOwnerOrWait

Address getPartitionOwnerOrWait(int partitionId)

Gets the owner of the partition. If none is set, it will wait till the owner is set.

Parameters:

partitionId - the partitionId

Returns:

owner of partition

Throws:

InterruptedException

NoDataMemberInClusterException - if all nodes are lite members and partitions can't be assigned

getPartition

InternalPartition getPartition(int partitionId)

Returns the InternalPartition for a given partitionId. If owner of the partition is not set yet, it will trigger partition assignment.

The InternalPartition for a given partitionId wil never change; so it can be cached safely.

Parameters:

partitionId - the partitionId

Returns:

the InternalPartition.

getPartition

InternalPartition getPartition(int partitionId,
                             boolean triggerOwnerAssignment)

Returns the InternalPartition for a given partitionId. If owner of the partition is not set yet and triggerOwnerAssignment is true, it will trigger partition assignment.

The InternalPartition for a given partitionId wil never change; so it can be cached safely.

Parameters:

partitionId - the partitionId

triggerOwnerAssignment - flag to trigger partition assignment

Returns:

the InternalPartition.

getPartitionId

int getPartitionId(Data key)

Returns the partition id for a Data key.

Parameters:

key - the Data key.

Returns:

the partition id.

Throws:

NullPointerException - if key is null.

getPartitionId

int getPartitionId(Object key)

Returns the partition id for a given object.

Parameters:

key - the object key.

Returns:

the partition id.

getPartitionCount

int getPartitionCount()

Returns the number of partitions.

Returns:

the number of partitions.

hasOnGoingMigration

boolean hasOnGoingMigration()

Checks if there currently are any migrations.

Returns:

true if there are migrations, false otherwise.

getMemberPartitions

List<Integer> getMemberPartitions(Address target)

getMemberPartitionsMap

Map<Address,List<Integer>> getMemberPartitionsMap()

Gets member partition IDs. Blocks until partitions are assigned.

Returns:

map of member address to partition Ids

getMemberGroupsSize

int getMemberGroupsSize()

getMaxBackupCount

int getMaxBackupCount()

addMigrationListener

String addMigrationListener(MigrationListener migrationListener)

removeMigrationListener

boolean removeMigrationListener(String registrationId)

addPartitionLostListener

String addPartitionLostListener(PartitionLostListener partitionLostListener)

addLocalPartitionLostListener

String addLocalPartitionLostListener(PartitionLostListener partitionLostListener)

removePartitionLostListener

boolean removePartitionLostListener(String registrationId)

getMember

Member getMember(Address address)

getMigrationQueueSize

long getMigrationQueueSize()

pauseMigration

void pauseMigration()

resumeMigration

void resumeMigration()

memberAdded

void memberAdded(MemberImpl newMember)

memberRemoved

void memberRemoved(MemberImpl deadMember)

prepareToSafeShutdown

boolean prepareToSafeShutdown(long timeout,
                            TimeUnit seconds)

isMemberStateSafe

boolean isMemberStateSafe()

Query and return if this member in a safe state or not. This method just checks for a safe state, it doesn't force this member to be in a safe state.

Returns:

true if this member in a safe state, otherwise false

getPartitions

InternalPartition[] getPartitions()

getActiveMigrations

Collection<MigrationInfo> getActiveMigrations()

firstArrangement

void firstArrangement()

getPartitionReplicaVersions

long[] getPartitionReplicaVersions(int partitionId)

updatePartitionReplicaVersions

void updatePartitionReplicaVersions(int partitionId,
                                  long[] replicaVersions,
                                  int replicaIndex)

incrementPartitionReplicaVersions

long[] incrementPartitionReplicaVersions(int partitionId,
                                       int totalBackupCount)

setPartitionReplicaVersions

void setPartitionReplicaVersions(int partitionId,
                               long[] versions,
                               int replicaOffset)

clearPartitionReplicaVersions

void clearPartitionReplicaVersions(int partitionId)

getPartitionServiceProxy

PartitionService getPartitionServiceProxy()

getPartitionStateVersion

int getPartitionStateVersion()

hasOnGoingMigrationLocal

boolean hasOnGoingMigrationLocal()

isPartitionOwner

boolean isPartitionOwner(int partitionId)

Check if this node is the owner of a partition

Parameters:

partitionId -

Returns:

true if it owns the partition. false if it doesn't or partition hasn't been assigned yet.