com.hazelcast.internal.partition

Interface InternalPartitionService

All Superinterfaces:

CoreService, IPartitionService

All Known Implementing Classes:

InternalPartitionServiceImpl

public interface InternalPartitionService
extends IPartitionService

Field Summary

Fields

Modifier and Type	Field and Description
static String	MIGRATION_EVENT_TOPIC Static constant for dispatching and listening migration events
static int	MIGRATION_RETRY_COUNT Retry count for migration operations.
static long	MIGRATION_RETRY_PAUSE Retry pause for migration operations in milliseconds.
static String	PARTITION_LOST_EVENT_TOPIC Static constant for dispatching and listening internal partition lost events

Fields inherited from interface com.hazelcast.spi.partition.IPartitionService

SERVICE_NAME

Method Summary

Modifier and Type	Method and Description
PartitionRuntimeState	createPartitionState() Creates the current partition runtime state.
PartitionTableView	createPartitionTableView()
void	firstArrangement() Causes the partition table to be arranged and published to members if : the instance has started the cluster is ClusterState.ACTIVE if it has not already been arranged if there is no cluster membership change If this node is not the master, it will trigger the master to assign the partitions.
InternalPartition[]	getInternalPartitions()
int	getMemberGroupsSize()
List<Integer>	getMemberPartitionsIfAssigned(Address target) Returns partition ID list assigned to given target if partitions are assigned when method is called.
InternalPartition	getPartition(int partitionId) Returns the IPartition for a given partition ID.
InternalPartition	getPartition(int partitionId, boolean triggerOwnerAssignment) Returns the IPartition for a given partition ID.
PartitionReplicaVersionManager	getPartitionReplicaVersionManager()
boolean	isMemberAllowedToJoin(Address address)
void	memberAdded(MemberImpl newMember)
void	memberRemoved(MemberImpl deadMember)
void	pauseMigration() Pause all migrations
boolean	prepareToSafeShutdown(long timeout, TimeUnit seconds)
void	resumeMigration() Resume all migrations

Methods inherited from interface com.hazelcast.spi.partition.IPartitionService

addLocalPartitionLostListener, addMigrationListener, addPartitionLostListener, getMaxAllowedBackupCount, getMemberPartitions, getMemberPartitionsMap, getMigrationQueueSize, getPartitionCount, getPartitionId, getPartitionId, getPartitionOwner, getPartitionOwnerOrWait, getPartitions, getPartitionStateVersion, hasOnGoingMigration, hasOnGoingMigrationLocal, isMemberStateSafe, isPartitionOwner, removeMigrationListener, removePartitionLostListener

Field Detail

MIGRATION_RETRY_COUNT

static final int MIGRATION_RETRY_COUNT

Retry count for migration operations.

Current Invocation mechanism retries first 5 invocations without pausing.

See Also:

Constant Field Values

MIGRATION_RETRY_PAUSE

static final long MIGRATION_RETRY_PAUSE

Retry pause for migration operations in milliseconds.

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

getPartition

InternalPartition getPartition(int partitionId)

Description copied from interface: IPartitionService

Returns the IPartition for a given partition ID.

If the owner of the partition is not set yet, it will trigger partition assignment.

The IPartition for a given partition ID will never change, so the result can be cached safely.

Specified by:

getPartition in interface IPartitionService

Parameters:

partitionId - the partition ID

Returns:

the IPartition

getPartition

InternalPartition getPartition(int partitionId,
                               boolean triggerOwnerAssignment)

Description copied from interface: IPartitionService

Returns the IPartition for a given partition ID.

If the owner of the partition is not set yet and triggerOwnerAssignment is true, it will trigger partition assignment.

The IPartition for a given partition ID will never change, so the result can be cached safely.

Specified by:

getPartition in interface IPartitionService

Parameters:

partitionId - the partition ID

triggerOwnerAssignment - flag to trigger the partition assignment

Returns:

the IPartition

getMemberGroupsSize

int getMemberGroupsSize()

pauseMigration

void pauseMigration()

Pause all migrations

resumeMigration

void resumeMigration()

Resume all migrations

isMemberAllowedToJoin

boolean isMemberAllowedToJoin(Address address)

memberAdded

void memberAdded(MemberImpl newMember)

memberRemoved

void memberRemoved(MemberImpl deadMember)

prepareToSafeShutdown

boolean prepareToSafeShutdown(long timeout,
                              TimeUnit seconds)

getInternalPartitions

InternalPartition[] getInternalPartitions()

firstArrangement

void firstArrangement()

Causes the partition table to be arranged and published to members if :

• the instance has started
• the cluster is ClusterState.ACTIVE
• if it has not already been arranged
• if there is no cluster membership change

If this node is not the master, it will trigger the master to assign the partitions.

Throws:

HazelcastException - if the partition state generator failed to arrange the partitions

See Also:

PartitionStateManager.initializePartitionAssignments(java.util.Set)

createPartitionState

PartitionRuntimeState createPartitionState()

Creates the current partition runtime state. May return null if the node should fetch the most recent partition table (e.g. this node is a newly appointed master) or if the partition state manager is not initialized.

Returns:

the current partition state

See Also:

InternalPartitionServiceImpl.isFetchMostRecentPartitionTableTaskRequired(), FetchPartitionStateOperation, PartitionStateManager.isInitialized()

getPartitionReplicaVersionManager

PartitionReplicaVersionManager getPartitionReplicaVersionManager()

createPartitionTableView

PartitionTableView createPartitionTableView()

getMemberPartitionsIfAssigned

List<Integer> getMemberPartitionsIfAssigned(Address target)

Returns partition ID list assigned to given target if partitions are assigned when method is called. Does not trigger partition assignment otherwise.

Returns:

partition ID list assigned to given target if partitions are assigned already