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

Methods

Modifier and Type	Method and Description
void	clear()
ICacheRecordStore	createNew(String name)
void	deleteRecordStore(String name, boolean destroy)
Collection<CacheConfig>	getCacheConfigs()
ICacheRecordStore	getOrCreateRecordStore(String name)
int	getPartitionId()
ICacheRecordStore	getRecordStore(String name)
boolean	hasAnyRecordStore()
boolean	hasRecordStore(String name)
void	init()
Iterator<ICacheRecordStore>	recordStoreIterator()
void	shutdown()

Methods inherited from class java.lang.Object

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

Field Detail

cacheService

protected final AbstractCacheService cacheService

partitionId

protected final int partitionId

recordStores

protected final ConcurrentMap<String,ICacheRecordStore> recordStores

mutex

protected final Object mutex

Constructor Detail

CachePartitionSegment

public CachePartitionSegment(AbstractCacheService cacheService,
                     int partitionId)

Method Detail

createNew

public ICacheRecordStore createNew(String name)

Specified by:

createNew in interface ConstructorFunction<String,ICacheRecordStore>

recordStoreIterator

public Iterator<ICacheRecordStore> recordStoreIterator()

getCacheConfigs

public Collection<CacheConfig> getCacheConfigs()

getPartitionId

public int getPartitionId()

getOrCreateRecordStore

public ICacheRecordStore getOrCreateRecordStore(String name)

getRecordStore

public ICacheRecordStore getRecordStore(String name)

deleteRecordStore

public void deleteRecordStore(String name,
                     boolean destroy)

hasAnyRecordStore

public boolean hasAnyRecordStore()

hasRecordStore

public boolean hasRecordStore(String name)

init

public void init()

clear

public void clear()

shutdown

public void shutdown()