com.hazelcast.partition

Class PartitionServiceProxy

java.lang.Object

com.hazelcast.partition.PartitionServiceProxy

All Implemented Interfaces:

PartitionService

public class PartitionServiceProxy
extends Object
implements PartitionService

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	PartitionServiceProxy.PartitionProxy

Constructor Summary

Constructors

Constructor and Description
PartitionServiceProxy(InternalPartitionService partitionService)

Method Summary

Methods

Modifier and Type	Method and Description
String	addMigrationListener(MigrationListener migrationListener)
boolean	forceLocalMemberToBeSafe(long timeout, TimeUnit unit) Force local member to be safe by checking and syncing owned partitions with 1st backups.
PartitionServiceProxy.PartitionProxy	getPartition(int partitionId)
PartitionServiceProxy.PartitionProxy	getPartition(Object key) Returns partition which given key belongs to.
Set<Partition>	getPartitions() Returns all partitions.
boolean	isClusterSafe() Checks whether the cluster is in a safe state.
boolean	isLocalMemberSafe() Check if local member is safe to shutdown, means check if 1st backups of partitions those owned by local member are sync with primary.
boolean	isMemberSafe(Member member) Check if the given member is safe to shutdown, means check if 1st backups of partitions those owned by given member are sync with primary.
String	randomPartitionKey() Generates a random partition key.
boolean	removeMigrationListener(String registrationId)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

PartitionServiceProxy

public PartitionServiceProxy(InternalPartitionService partitionService)

Method Detail

randomPartitionKey

public String randomPartitionKey()

Description copied from interface: PartitionService

Generates a random partition key. This is useful if you want to partition data in the same partition, but don't care which partition it is going to be.

The returned value will never be null.

Specified by:

randomPartitionKey in interface PartitionService

Returns:

the random partition key.

getPartitions

public Set<Partition> getPartitions()

Description copied from interface: PartitionService

Returns all partitions.

Specified by:

getPartitions in interface PartitionService

Returns:

all partitions

getPartition

public PartitionServiceProxy.PartitionProxy getPartition(Object key)

Description copied from interface: PartitionService

Returns partition which given key belongs to.

Specified by:

getPartition in interface PartitionService

Parameters:

key - key

Returns:

partition which given key belongs to

addMigrationListener

public String addMigrationListener(MigrationListener migrationListener)

Specified by:

addMigrationListener in interface PartitionService

Parameters:

migrationListener - listener

Returns:

returns registration id.

removeMigrationListener

public boolean removeMigrationListener(String registrationId)

Specified by:

removeMigrationListener in interface PartitionService

Parameters:

registrationId - Id of listener registration.

Returns:

true if registration is removed, false otherwise

isClusterSafe

public boolean isClusterSafe()

Description copied from interface: PartitionService

Checks whether the cluster is in a safe state. When in a safe state it is permissible to shut down a server instance.

Specified by:

isClusterSafe in interface PartitionService

Returns:

true if there are no partitions being migrated, and there are sufficient backups for each partition per the configuration, otherwise false.

isMemberSafe

public boolean isMemberSafe(Member member)

Description copied from interface: PartitionService

Check if the given member is safe to shutdown, means check if 1st backups of partitions those owned by given member are sync with primary.

Specified by:

isMemberSafe in interface PartitionService

Parameters:

member - Cluster member to query.

Returns:

true if member in a safe state, other wise false.

isLocalMemberSafe

public boolean isLocalMemberSafe()

Description copied from interface: PartitionService

Check if local member is safe to shutdown, means check if 1st backups of partitions those owned by local member are sync with primary.

Specified by:

isLocalMemberSafe in interface PartitionService

forceLocalMemberToBeSafe

public boolean forceLocalMemberToBeSafe(long timeout,
                               TimeUnit unit)

Description copied from interface: PartitionService

Force local member to be safe by checking and syncing owned partitions with 1st backups.

Specified by:

forceLocalMemberToBeSafe in interface PartitionService

getPartition

public PartitionServiceProxy.PartitionProxy getPartition(int partitionId)