com.hazelcast.map.impl.recordstore

Class EnterpriseRecordStore

java.lang.Object

com.hazelcast.map.impl.recordstore.AbstractEvictableRecordStore

com.hazelcast.map.impl.recordstore.DefaultRecordStore

com.hazelcast.map.impl.recordstore.EnterpriseRecordStore

All Implemented Interfaces:

com.hazelcast.map.impl.recordstore.RecordStore<com.hazelcast.map.impl.record.Record>

public class EnterpriseRecordStore
extends com.hazelcast.map.impl.recordstore.DefaultRecordStore

Enterprise specific extensions for DefaultRecordStore.

Nested Class Summary

Nested classes/interfaces inherited from class com.hazelcast.map.impl.recordstore.AbstractEvictableRecordStore

com.hazelcast.map.impl.recordstore.AbstractEvictableRecordStore.ReadOnlyRecordIterator

Field Summary

Fields

Modifier and Type	Field and Description
static long	HD_RECORD_MAX_TTL_MILLIS
protected com.hazelcast.config.InMemoryFormat	inMemoryFormat
protected com.hazelcast.concurrent.lock.LockStore	lockStore
protected com.hazelcast.map.impl.MapContainer	mapContainer
protected com.hazelcast.map.impl.mapstore.MapDataStore<com.hazelcast.nio.serialization.Data,Object>	mapDataStore
protected com.hazelcast.map.impl.MapServiceContext	mapServiceContext
protected com.hazelcast.map.impl.mapstore.MapStoreContext	mapStoreContext
protected com.hazelcast.map.impl.recordstore.RecordStoreMutationObserver<com.hazelcast.map.impl.record.Record>	mutationObserver
protected String	name
protected int	partitionId
protected com.hazelcast.map.impl.record.RecordFactory	recordFactory
protected com.hazelcast.spi.serialization.SerializationService	serializationService
protected com.hazelcast.monitor.impl.LocalRecordStoreStatsImpl	stats
protected com.hazelcast.map.impl.recordstore.Storage<com.hazelcast.nio.serialization.Data,com.hazelcast.map.impl.record.Record>	storage
protected com.hazelcast.internal.util.comparators.ValueComparator	valueComparator

Fields inherited from class com.hazelcast.map.impl.recordstore.DefaultRecordStore

keyLoader, loadingFutures, logger, recordStoreLoader

Fields inherited from class com.hazelcast.map.impl.recordstore.AbstractEvictableRecordStore

clearExpiredRecordsTask, eventService, expirationIterator, expiredKeys, expiryDelayMillis, hasEntryWithCustomExpiration, mapEventPublisher, thisAddress

Fields inherited from interface com.hazelcast.map.impl.recordstore.RecordStore

DEFAULT_MAX_IDLE, DEFAULT_TTL

Constructor Summary

Constructors

Constructor and Description
EnterpriseRecordStore(com.hazelcast.map.impl.MapContainer mapContainer, int partitionId, com.hazelcast.map.impl.MapKeyLoader keyLoader, com.hazelcast.logging.ILogger logger, com.hazelcast.config.HotRestartConfig hotRestartConfig, long prefix)

Method Summary

Modifier and Type	Method and Description
protected com.hazelcast.concurrent.lock.LockStore	createLockStore()
HDRecord	createRecord(com.hazelcast.nio.serialization.Data keyData, Object value, long sequence)
com.hazelcast.map.impl.record.Record	createRecord(com.hazelcast.nio.serialization.Data key, Object value, long ttlMillis, long maxIdleMillis, long now)
protected com.hazelcast.map.impl.recordstore.RecordStoreLoader	createRecordStoreLoader(com.hazelcast.map.impl.mapstore.MapStoreContext arg0)
com.hazelcast.map.impl.recordstore.Storage	createStorage(com.hazelcast.map.impl.record.RecordFactory recordFactory, com.hazelcast.config.InMemoryFormat memoryFormat)
MetadataStore	getMetadataStore()
protected Collection<com.hazelcast.map.impl.record.Record>	getNotLockedRecords()
protected long	getNow()
long	getPrefix()
com.hazelcast.spi.hotrestart.RamStore	getRamStore()
long	incrementSequence()
void	init()
protected boolean	isTtlDefined(long ttl) The reason of overriding this method is an optimization which we did to fit a HDRecord size in a 64 bit HD block.
protected boolean	persistenceEnabledFor(com.hazelcast.wan.impl.CallerProvenance arg0)
com.hazelcast.nio.serialization.Data	readBackupData(com.hazelcast.nio.serialization.Data key) If in-memory-format is native, method is executed on partition thread.
protected void	removeIndex(Collection<com.hazelcast.map.impl.record.Record> arg0)
protected void	removeIndex(com.hazelcast.map.impl.record.Record arg0)
void	reset()
protected void	saveIndex(com.hazelcast.map.impl.record.Record arg0, Object arg1)
protected com.hazelcast.nio.serialization.Data	toData(Object arg0)
protected void	updateRecord(com.hazelcast.nio.serialization.Data arg0, com.hazelcast.map.impl.record.Record arg1, Object arg2, long arg3, boolean arg4)
protected void	updateStatsOnGet(long arg0)
protected void	updateStatsOnPut(boolean arg0, long arg1)
protected void	updateStatsOnPut(long arg0)

Methods inherited from class com.hazelcast.map.impl.recordstore.DefaultRecordStore

addMapEntrySet, addMapEntrySet, canAcquireLock, checkIfLoaded, clear, clearOtherDataThanStorage, clearPartition, containsKey, containsValue, delete, destroy, destroyStorageAfterClear, evict, evictAll, evictRecords, existInMemory, extendLock, fetchEntries, fetchKeys, forceUnlock, get, getAll, getKeysFromRecords, getLoadingFutures, getLockOwnerInfo, getMapDataStore, getRecord, getRecordOrNull, getRecordOrNull, hasQueryCache, isEmpty, isKeyAndValueLoadable, isKeyLoadFinished, isLoaded, isLocked, isLockedBy, isTransactionallyLocked, iterator, iterator, loadAll, loadAllFromStore, loadAwareIterator, loadEntries, loadRecordOrNull, localLock, lock, maybeDoInitialLoad, merge, merge, merge, merge, onStore, put, putBackup, putBackup, putFromLoad, putFromLoadBackup, putIfAbsent, putInternal, putRecord, putTransient, remove, remove, removeBackup, removeRecord, removeRecords, replace, replace, set, setPreMigrationLoadedStatus, setTtl, setWithUncountedAccess, size, softFlush, startLoading, txnLock, unlock, updateLoadStatus

Methods inherited from class com.hazelcast.map.impl.recordstore.AbstractEvictableRecordStore

accessRecord, doPostEvictionOperations, evictEntries, evictExpiredEntries, get, getExpiredKeysQueue, getOrNullIfExpired, isExpirable, isExpired, isMaxIdleDefined, markRecordStoreExpirable, mergeRecordExpiration, mergeRecordExpiration, sampleAndForceRemoveEntries, shouldEvict

Methods inherited from class java.lang.Object

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

Field Detail

HD_RECORD_MAX_TTL_MILLIS

public static final long HD_RECORD_MAX_TTL_MILLIS

See Also:

AbstractEvictableRecordStore.markRecordStoreExpirable(long, long)

partitionId

protected final int partitionId

name

protected final String name

lockStore

protected final com.hazelcast.concurrent.lock.LockStore lockStore

mapContainer

protected final com.hazelcast.map.impl.MapContainer mapContainer

recordFactory

protected final com.hazelcast.map.impl.record.RecordFactory recordFactory

inMemoryFormat

protected final com.hazelcast.config.InMemoryFormat inMemoryFormat

mapStoreContext

protected final com.hazelcast.map.impl.mapstore.MapStoreContext mapStoreContext

valueComparator

protected final com.hazelcast.internal.util.comparators.ValueComparator valueComparator

mapServiceContext

protected final com.hazelcast.map.impl.MapServiceContext mapServiceContext

serializationService

protected final com.hazelcast.spi.serialization.SerializationService serializationService

mapDataStore

protected final com.hazelcast.map.impl.mapstore.MapDataStore<com.hazelcast.nio.serialization.Data,Object> mapDataStore

stats

protected final com.hazelcast.monitor.impl.LocalRecordStoreStatsImpl stats

mutationObserver

protected final com.hazelcast.map.impl.recordstore.RecordStoreMutationObserver<com.hazelcast.map.impl.record.Record> mutationObserver

storage

protected com.hazelcast.map.impl.recordstore.Storage<com.hazelcast.nio.serialization.Data,com.hazelcast.map.impl.record.Record> storage

Constructor Detail

EnterpriseRecordStore

public EnterpriseRecordStore(com.hazelcast.map.impl.MapContainer mapContainer,
                             int partitionId,
                             com.hazelcast.map.impl.MapKeyLoader keyLoader,
                             com.hazelcast.logging.ILogger logger,
                             com.hazelcast.config.HotRestartConfig hotRestartConfig,
                             long prefix)

Method Detail

init

public void init()

Specified by:

init in interface com.hazelcast.map.impl.recordstore.RecordStore<com.hazelcast.map.impl.record.Record>

Overrides:

init in class com.hazelcast.map.impl.recordstore.AbstractEvictableRecordStore

getRamStore

public com.hazelcast.spi.hotrestart.RamStore getRamStore()

isTtlDefined

protected boolean isTtlDefined(long ttl)

The reason of overriding this method is an optimization which we did to fit a HDRecord size in a 64 bit HD block. One of the changes for this was converting a long ttl to an int ttl. As a result of that change, an infinite ttl is represented with an HD_RECORD_MAX_TTL_MILLIS instead of Long.MAX_VALUE.

When marking a record-store as expirable we should also take care of this new case and should not mark a record-store as expirable if a ttl was set to HD_RECORD_MAX_TTL_MILLIS.

Overrides:

isTtlDefined in class com.hazelcast.map.impl.recordstore.AbstractEvictableRecordStore

Parameters:

ttl - ttl in milliseconds.

createStorage

public com.hazelcast.map.impl.recordstore.Storage createStorage(com.hazelcast.map.impl.record.RecordFactory recordFactory,
                                                                com.hazelcast.config.InMemoryFormat memoryFormat)

Specified by:

createStorage in interface com.hazelcast.map.impl.recordstore.RecordStore<com.hazelcast.map.impl.record.Record>

Overrides:

createStorage in class com.hazelcast.map.impl.recordstore.AbstractEvictableRecordStore

createRecord

public HDRecord createRecord(com.hazelcast.nio.serialization.Data keyData,
                             Object value,
                             long sequence)

createRecord

public com.hazelcast.map.impl.record.Record createRecord(com.hazelcast.nio.serialization.Data key,
                                                         Object value,
                                                         long ttlMillis,
                                                         long maxIdleMillis,
                                                         long now)

Specified by:

createRecord in interface com.hazelcast.map.impl.recordstore.RecordStore<com.hazelcast.map.impl.record.Record>

Overrides:

createRecord in class com.hazelcast.map.impl.recordstore.AbstractEvictableRecordStore

reset

public void reset()

Specified by:

reset in interface com.hazelcast.map.impl.recordstore.RecordStore<com.hazelcast.map.impl.record.Record>

Overrides:

reset in class com.hazelcast.map.impl.recordstore.DefaultRecordStore

getNotLockedRecords

protected Collection<com.hazelcast.map.impl.record.Record> getNotLockedRecords()

Overrides:

getNotLockedRecords in class com.hazelcast.map.impl.recordstore.DefaultRecordStore

readBackupData

public com.hazelcast.nio.serialization.Data readBackupData(com.hazelcast.nio.serialization.Data key)

If in-memory-format is native, method is executed on partition thread.

Specified by:

readBackupData in interface com.hazelcast.map.impl.recordstore.RecordStore<com.hazelcast.map.impl.record.Record>

Overrides:

readBackupData in class com.hazelcast.map.impl.recordstore.DefaultRecordStore

getMetadataStore

public MetadataStore getMetadataStore()

getPrefix

public long getPrefix()

incrementSequence

public long incrementSequence()

persistenceEnabledFor

protected boolean persistenceEnabledFor(@Nonnull
                                        com.hazelcast.wan.impl.CallerProvenance arg0)

getNow

protected long getNow()

updateRecord

protected void updateRecord(com.hazelcast.nio.serialization.Data arg0,
                            com.hazelcast.map.impl.record.Record arg1,
                            Object arg2,
                            long arg3,
                            boolean arg4)

saveIndex

protected void saveIndex(com.hazelcast.map.impl.record.Record arg0,
                         Object arg1)

removeIndex

protected void removeIndex(com.hazelcast.map.impl.record.Record arg0)

removeIndex

protected void removeIndex(Collection<com.hazelcast.map.impl.record.Record> arg0)

createLockStore

protected com.hazelcast.concurrent.lock.LockStore createLockStore()

createRecordStoreLoader

protected com.hazelcast.map.impl.recordstore.RecordStoreLoader createRecordStoreLoader(com.hazelcast.map.impl.mapstore.MapStoreContext arg0)

toData

protected com.hazelcast.nio.serialization.Data toData(Object arg0)

updateStatsOnPut

protected void updateStatsOnPut(boolean arg0,
                                long arg1)

updateStatsOnPut

protected void updateStatsOnPut(long arg0)

updateStatsOnGet

protected void updateStatsOnGet(long arg0)