com.hazelcast.internal.partition

Interface InternalPartitionService

All Superinterfaces:

CoreService, GracefulShutdownAwareService, IPartitionService, ManagedService

All Known Implementing Classes:

InternalPartitionServiceImpl

public interface InternalPartitionService
extends IPartitionService, ManagedService, GracefulShutdownAwareService

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() Creates an immutable/readonly view of partition table.
PartitionRuntimeState	firstArrangement() Causes the partition table to be arranged and published to members if : this instance has started this instance is the master the cluster is ClusterState.ACTIVE if the partition table has not already been arranged if there is no cluster membership change If this instance is not the master, it will trigger the master to assign the partitions.
InternalPartition[]	getInternalPartitions()
int	getMemberGroupsSize() Number of the member groups to be used in partition assignments.
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.
PartitionReplicaStateChecker	getPartitionReplicaStateChecker()
PartitionReplicaVersionManager	getPartitionReplicaVersionManager()
PartitionServiceProxy	getPartitionServiceProxy() Returns the PartitionServiceProxy of the partition service..
void	memberAdded(Member member) Called when a member is added to the cluster.
void	memberRemoved(Member member) Called when a member is removed from the cluster.
void	pauseMigration() Pause all migrations
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

Methods inherited from interface com.hazelcast.spi.ManagedService

init, reset, shutdown

Methods inherited from interface com.hazelcast.spi.GracefulShutdownAwareService

onShutdown

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()

Number of the member groups to be used in partition assignments.

Returns:

number of member groups

See Also:

MemberGroupFactory, PartitionGroupConfig

pauseMigration

void pauseMigration()

Pause all migrations

resumeMigration

void resumeMigration()

Resume all migrations

memberAdded

void memberAdded(Member member)

Called when a member is added to the cluster. Triggers partition rebalancing.

Parameters:

member - new member

memberRemoved

void memberRemoved(Member member)

Called when a member is removed from the cluster. Executes maintenance tasks, removes the member from partition table and triggers promotions.

Parameters:

member - removed member

getInternalPartitions

InternalPartition[] getInternalPartitions()

firstArrangement

PartitionRuntimeState firstArrangement()

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

• this instance has started
• this instance is the master
• the cluster is ClusterState.ACTIVE
• if the partition table has not already been arranged
• if there is no cluster membership change

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

Returns:

PartitionRuntimeState if this node is the master and the partition table is initialized

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()

Creates an immutable/readonly view of partition table.

Returns:

immutable view of partition table

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

getPartitionServiceProxy

PartitionServiceProxy getPartitionServiceProxy()

Returns the PartitionServiceProxy of the partition service..

Returns:

the PartitionServiceProxy

getPartitionReplicaStateChecker

PartitionReplicaStateChecker getPartitionReplicaStateChecker()