Examples of com.hazelcast.partition.InternalPartition

com.hazelcast.partition.InternalPartition
Represents a Partition. It is comparable to the {@link com.hazelcast.core.Partition} but it is optimized for internalusage, so it exposes method not meant for regular Hazelcast users.
The InternalPartition provides access to information about a partition, most importantly the addresses of the replica's and this information will be updated. So one can cache the InternalPartition and keep asking for partition information. @author mdogan 6/17/13

        final MapServiceContext mapServiceContext = mapService.getMapServiceContext();
        final NodeEngine nodeEngine = mapServiceContext.getNodeEngine();
        final InternalPartitionService partitionService = nodeEngine.getPartitionService();
        final Address thisAddress = nodeEngine.getThisAddress();
        final int partitionId = partitionService.getPartitionId(key);
        final InternalPartition partition = partitionService.getPartition(partitionId, false);
        if (!partition.isOwnerOrBackup(thisAddress)) {
            return null;
        }
        final PartitionContainer partitionContainer = mapServiceContext.getPartitionContainer(partitionId);
        final RecordStore recordStore = partitionContainer.getExistingRecordStore(name);
        if (recordStore == null) {

View Full Code Here


    @Override
    public boolean shouldBackup() {
        final NodeEngine nodeEngine = getNodeEngine();
        InternalPartitionService partitionService = nodeEngine.getPartitionService();
        InternalPartition partition = partitionService.getPartition(getPartitionId());
        return nodeEngine.getThisAddress().equals(partition.getOwnerOrNull())
                && Boolean.TRUE.equals(response);
    }

View Full Code Here

0 1 2 3 4

TOP

Related Classes of com.hazelcast.partition.InternalPartition

com.hazelcast.concurrent.lock.operations.LocalLockCleanupOperation

com.hazelcast.concurrent.semaphore.SemaphoreService

com.hazelcast.map.eviction.EvictionHelper

com.hazelcast.map.eviction.ExpirationManager$ClearExpiredRecordsTask

com.hazelcast.map.impl.eviction.ExpirationManager$ClearExpiredRecordsTask

com.hazelcast.map.impl.eviction.MaxSizeChecker

com.hazelcast.map.impl.LocalMapStatsProvider

com.hazelcast.map.impl.mapstore.writebehind.StoreWorker

com.hazelcast.map.impl.proxy.MapProxySupport

com.hazelcast.map.LocalMapStatsProvider

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.