com.hazelcast.internal.partition

Interface InternalPartitionService

All Superinterfaces:

CoreService, GracefulShutdownAwareService, IPartitionService

All Known Implementing Classes:

InternalPartitionServiceImpl

public interface InternalPartitionService
extends IPartitionService, 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()
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()
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..
boolean	isMemberAllowedToJoin(Address address)
void	memberAdded(MemberImpl newMember)
void	memberRemoved(MemberImpl deadMember)
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.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()

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)

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

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