com.hazelcast.cache.impl

Class CachePartitionSegment

java.lang.Object

com.hazelcast.cache.impl.CachePartitionSegment

All Implemented Interfaces:

ConstructorFunction<String,ICacheRecordStore>

public class CachePartitionSegment
extends Object
implements ConstructorFunction<String,ICacheRecordStore>

Responsible for all cache data of a partition. Creates and looks up CacheRecordStores by name.

A CacheService manages all CachePartitionSegments.

Field Summary

Fields

Modifier and Type	Field and Description
protected AbstractCacheService	cacheService
protected Object	mutex
protected int	partitionId
protected ConcurrentMap<String,ICacheRecordStore>	recordStores

Constructor Summary

Constructors

Constructor and Description
CachePartitionSegment(AbstractCacheService cacheService, int partitionId)

Method Summary

Modifier and Type	Method and Description
ICacheRecordStore	createNew(String cacheNameWithPrefix) Creates a new instance of an object given the construction argument
void	deleteRecordStore(String name, boolean destroy)
Collection<ServiceNamespace>	getAllNamespaces(int replicaIndex)
Collection<CacheConfig>	getCacheConfigs()
ICacheService	getCacheService()
ICacheRecordStore	getOrCreateRecordStore(String cacheNameWithPrefix) Gets or creates a cache record store with the prefixed cacheNameWithPrefix.
int	getPartitionId()
ICacheRecordStore	getRecordStore(String cacheNameWithPrefix) Returns a cache record store with the prefixed cacheNameWithPrefix or null if one doesn't exist.
boolean	hasAnyRecordStore()
boolean	hasRecordStore(String name)
void	init()
Iterator<ICacheRecordStore>	recordStoreIterator()
void	reset()
void	shutdown()

Methods inherited from class java.lang.Object

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

Field Detail

partitionId

protected final int partitionId

mutex

protected final Object mutex

cacheService

protected final AbstractCacheService cacheService

recordStores

protected final ConcurrentMap<String,ICacheRecordStore> recordStores

Constructor Detail

CachePartitionSegment

public CachePartitionSegment(AbstractCacheService cacheService,
                             int partitionId)

Method Detail

createNew

public ICacheRecordStore createNew(String cacheNameWithPrefix)

Description copied from interface: ConstructorFunction

Creates a new instance of an object given the construction argument

Specified by:

createNew in interface ConstructorFunction<String,ICacheRecordStore>

Parameters:

cacheNameWithPrefix - construction argument

Returns:

a new instance of an object

recordStoreIterator

public Iterator<ICacheRecordStore> recordStoreIterator()

getCacheConfigs

public Collection<CacheConfig> getCacheConfigs()

getPartitionId

public int getPartitionId()

getOrCreateRecordStore

public ICacheRecordStore getOrCreateRecordStore(String cacheNameWithPrefix)

Gets or creates a cache record store with the prefixed cacheNameWithPrefix.

Parameters:

cacheNameWithPrefix - the full name of the ICache, including the manager scope prefix

Returns:

the cache partition record store

getRecordStore

public ICacheRecordStore getRecordStore(String cacheNameWithPrefix)

Returns a cache record store with the prefixed cacheNameWithPrefix or null if one doesn't exist.

Parameters:

cacheNameWithPrefix - the full name of the ICache, including the manager scope prefix

Returns:

the cache partition record store or null if it doesn't exist

getCacheService

public ICacheService getCacheService()

deleteRecordStore

public void deleteRecordStore(String name,
                              boolean destroy)

hasAnyRecordStore

public boolean hasAnyRecordStore()

hasRecordStore

public boolean hasRecordStore(String name)

init

public void init()

reset

public void reset()

shutdown

public void shutdown()

getAllNamespaces

public Collection<ServiceNamespace> getAllNamespaces(int replicaIndex)