Package | Description |
---|---|
com.hazelcast.map.impl |
Contains implementation specific classes of
com.hazelcast.map package. |
com.hazelcast.map.impl.eviction |
This package contains eviction classes.
|
com.hazelcast.map.impl.operation |
Package for map operations.
|
com.hazelcast.map.impl.query | |
com.hazelcast.map.impl.record |
Contains record specific classes.
|
com.hazelcast.map.impl.recordstore | |
com.hazelcast.spi.impl.merge |
This package contains split-brain related classes.
|
Modifier and Type | Method and Description |
---|---|
Collection<RecordStoreMutationObserver<Record>> |
MapServiceContext.createRecordStoreMutationObservers(String mapName,
int partitionId)
Returns the collection of the
RecordStoreMutationObserver s
for the given map's partition that need to be added in record
store construction time in order to ensure no RecordStore
mutations are missed. |
Modifier and Type | Method and Description |
---|---|
static <K,V> EntryView<K,V> |
EntryViews.createLazyEntryView(K key,
V value,
Record record,
SerializationService serializationService,
MapMergePolicy mergePolicy) |
static <K,V> EntryView<K,V> |
EntryViews.createSimpleEntryView(K key,
V value,
Record record) |
static long |
ExpirationTimeSetter.getIdlenessStartTime(Record record)
Returns last-access-time of an entry if it was accessed before, otherwise it returns creation-time of the entry.
|
static long |
ExpirationTimeSetter.getLifeStartTime(Record record)
Returns last-update-time of an entry if it was updated before, otherwise it returns creation-time of the entry.
|
static void |
ExpirationTimeSetter.setExpirationTime(Record record)
Sets expiration time if statistics are enabled.
|
static void |
ExpirationTimeSetter.setExpirationTimes(long operationTTLMillis,
long operationMaxIdleMillis,
Record record,
MapConfig mapConfig,
boolean consultMapConfig)
Updates records TTL and expiration time.
|
static EntryView<Data,Data> |
EntryViews.toSimpleEntryView(Record<Data> record) |
Modifier and Type | Method and Description |
---|---|
protected Record |
EvictorImpl.getRecordFromEntryView(EntryView selectedEntry) |
Modifier and Type | Field and Description |
---|---|
protected Map<String,RecordStore<Record>> |
MapReplicationStateHolder.storesByMapName |
Modifier and Type | Method and Description |
---|---|
protected Metadata |
PartitionScanRunner.getMetadataFromRecord(RecordStore recordStore,
Record record) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractRecord<V> |
Modifier and Type | Method and Description |
---|---|
Record<Object> |
ObjectRecordFactory.newRecord(Data key,
Object value) |
Record<Data> |
DataRecordFactory.newRecord(Data key,
Object value) |
Record<T> |
RecordFactory.newRecord(Data key,
Object value) |
Modifier and Type | Method and Description |
---|---|
static void |
Records.applyRecordInfo(Record record,
RecordInfo replicationInfo) |
static RecordInfo |
Records.buildRecordInfo(Record record) |
static Object |
Records.getCachedValue(Record record)
Get current cached value from the record.
|
static Object |
Records.getValueOrCachedValue(Record record,
SerializationService serializationService)
Return cached value where appropriate, otherwise return the actual value.
|
void |
DataRecordFactory.setValue(Record<Data> record,
Object value) |
void |
ObjectRecordFactory.setValue(Record<Object> record,
Object value) |
void |
RecordFactory.setValue(Record<T> record,
Object value) |
Modifier and Type | Class and Description |
---|---|
class |
LazyEntryViewFromRecord<R extends Record>
Internally used
EntryView implementation for sampling based eviction specific purposes. |
interface |
RecordStore<R extends Record>
Defines a record-store.
|
interface |
RecordStoreMutationObserver<R extends Record>
Interface for observing
RecordStore mutations |
class |
StorageImpl<R extends Record>
Default implementation of
Storage layer used by a RecordStore |
class |
StorageSCHM<R extends Record>
An extended
SampleableConcurrentHashMap with IMap specifics. |
Modifier and Type | Field and Description |
---|---|
protected Iterator<Record> |
AbstractEvictableRecordStore.expirationIterator
Iterates over a pre-set entry count/percentage in one round.
|
Modifier and Type | Method and Description |
---|---|
Record |
RecordStore.createRecord(Data key,
Object value,
long ttlMillis,
long maxIdle,
long now) |
Record |
StorageImpl.extractRecordFromLazy(EntryView entryView) |
Record |
Storage.extractRecordFromLazy(EntryView entryView) |
protected Record |
AbstractEvictableRecordStore.getOrNullIfExpired(Record record,
long now,
boolean backup)
Check if record is reachable according to TTL or idle times.
|
Record |
LazyEntryViewFromRecord.getRecord() |
Record |
DefaultRecordStore.getRecord(Data key) |
Record |
DefaultRecordStore.getRecordOrNull(Data key) |
protected Record |
DefaultRecordStore.getRecordOrNull(Data key,
long now,
boolean backup) |
Record |
RecordStore.loadRecordOrNull(Data key,
boolean backup,
Address callerAddress) |
Record |
DefaultRecordStore.loadRecordOrNull(Data key,
boolean backup,
Address callerAddress) |
Record |
AbstractEvictableRecordStore.ReadOnlyRecordIterator.next() |
Record |
DefaultRecordStore.putBackup(Data key,
Object value,
CallerProvenance provenance) |
Record |
DefaultRecordStore.putBackup(Data key,
Object value,
long ttl,
long maxIdle,
boolean putTransient,
CallerProvenance provenance) |
Modifier and Type | Method and Description |
---|---|
protected Collection<Record> |
DefaultRecordStore.getNotLockedRecords() |
Iterator<Record> |
RecordStore.iterator()
Iterates over record store entries.
|
Iterator<Record> |
DefaultRecordStore.iterator() |
Iterator<Record> |
RecordStore.iterator(long now,
boolean backup)
Iterates over record store entries by respecting expiration.
|
Iterator<Record> |
DefaultRecordStore.iterator(long now,
boolean backup) |
Iterator<Record> |
RecordStore.loadAwareIterator(long now,
boolean backup)
Iterates over record store entries but first waits map store to load.
|
Iterator<Record> |
DefaultRecordStore.loadAwareIterator(long now,
boolean backup) |
Modifier and Type | Method and Description |
---|---|
void |
RecordStore.accessRecord(Record record,
long now)
Touches the given record, updating its last access time to
now and
maintaining statistics. |
void |
AbstractEvictableRecordStore.accessRecord(Record record,
long now) |
void |
RecordStore.doPostEvictionOperations(Record record)
Does post eviction operations like sending events
|
void |
AbstractEvictableRecordStore.doPostEvictionOperations(Record record) |
protected Metadata |
JsonMetadataRecordStoreMutationObserver.getMetadata(Record record) |
protected Record |
AbstractEvictableRecordStore.getOrNullIfExpired(Record record,
long now,
boolean backup)
Check if record is reachable according to TTL or idle times.
|
boolean |
AbstractEvictableRecordStore.isExpired(Record record,
long now,
boolean backup) |
protected void |
AbstractEvictableRecordStore.mergeRecordExpiration(Record record,
EntryView mergingEntry) |
protected void |
AbstractEvictableRecordStore.mergeRecordExpiration(Record record,
SplitBrainMergeTypes.MapMergeTypes mergingEntry) |
void |
EventJournalWriterRecordStoreMutationObserver.onEvictRecord(Data key,
Record record) |
void |
JsonMetadataRecordStoreMutationObserver.onEvictRecord(Data key,
Record record) |
void |
EventJournalWriterRecordStoreMutationObserver.onLoadRecord(Data key,
Record record) |
void |
JsonMetadataRecordStoreMutationObserver.onLoadRecord(Data key,
Record record) |
void |
EventJournalWriterRecordStoreMutationObserver.onPutRecord(Data key,
Record record) |
void |
JsonMetadataRecordStoreMutationObserver.onPutRecord(Data key,
Record record) |
void |
EventJournalWriterRecordStoreMutationObserver.onRemoveRecord(Data key,
Record record) |
void |
JsonMetadataRecordStoreMutationObserver.onRemoveRecord(Data key,
Record record) |
void |
EventJournalWriterRecordStoreMutationObserver.onReplicationPutRecord(Data key,
Record record) |
void |
JsonMetadataRecordStoreMutationObserver.onReplicationPutRecord(Data key,
Record record) |
protected void |
DefaultRecordStore.onStore(Record record) |
void |
EventJournalWriterRecordStoreMutationObserver.onUpdateRecord(Data key,
Record record,
Object newValue) |
void |
JsonMetadataRecordStoreMutationObserver.onUpdateRecord(Data key,
Record record,
Object newValue) |
void |
DefaultRecordStore.putRecord(Data key,
Record record) |
protected void |
JsonMetadataRecordStoreMutationObserver.removeMetadata(Record record) |
protected Object |
DefaultRecordStore.removeRecord(Data key,
Record record,
long now,
CallerProvenance provenance) |
protected void |
JsonMetadataRecordStoreMutationObserver.setMetadata(Record record,
Metadata metadata) |
Modifier and Type | Method and Description |
---|---|
protected int |
DefaultRecordStore.evictRecords(Collection<Record> recordsToEvict) |
protected List<Data> |
DefaultRecordStore.getKeysFromRecords(Collection<Record> clearableRecords) |
protected int |
DefaultRecordStore.removeRecords(Collection<Record> recordsToRemove) |
Constructor and Description |
---|
ReadOnlyRecordIterator(Collection<Record> values) |
ReadOnlyRecordIterator(Collection<Record> values,
long now,
boolean backup) |
Modifier and Type | Method and Description |
---|---|
static SplitBrainMergeTypes.MapMergeTypes |
MergingValueFactory.createMergingEntry(SerializationService serializationService,
Data dataKey,
Data dataValue,
Record record) |
static SplitBrainMergeTypes.MapMergeTypes |
MergingValueFactory.createMergingEntry(SerializationService serializationService,
Record record) |
Copyright © 2022 Hazelcast, Inc.. All Rights Reserved.