| 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.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
RecordStoreMutationObservers
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 | Class and Description |
|---|---|
class |
AbstractRecord<V> |
| Modifier and Type | Method and Description |
|---|---|
Record<Object> |
ObjectRecordFactory.newRecord(Object value) |
Record<Data> |
DataRecordFactory.newRecord(Object value) |
Record<T> |
RecordFactory.newRecord(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(Object value,
long ttlMillis,
long maxIdle,
long now) |
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 |
|---|---|
protected 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 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 |
EventJournalWriterRecordStoreMutationObserver.onLoadRecord(Data key,
Record record) |
void |
EventJournalWriterRecordStoreMutationObserver.onPutRecord(Data key,
Record record) |
void |
EventJournalWriterRecordStoreMutationObserver.onRemoveRecord(Data key,
Record record) |
void |
EventJournalWriterRecordStoreMutationObserver.onReplicationPutRecord(Data key,
Record record) |
protected void |
DefaultRecordStore.onStore(Record record) |
void |
EventJournalWriterRecordStoreMutationObserver.onUpdateRecord(Data key,
Record record,
Object newValue) |
void |
DefaultRecordStore.putRecord(Data key,
Record record) |
protected Object |
DefaultRecordStore.removeRecord(Data key,
Record record,
long now,
CallerProvenance provenance) |
| 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 © 2018 Hazelcast, Inc.. All Rights Reserved.