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 |
---|---|
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,
long maxIdleMillis)
Sets expiration time if statistics are enabled.
|
static void |
ExpirationTimeSetter.setTTLAndUpdateExpiryTime(long operationTTLMillis,
Record record,
MapConfig mapConfig,
boolean entryCreated)
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 boolean |
EvictBatchBackupOperation.canEvictRecord(Record existingRecord,
ExpiredKey expiredKey) |
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.
|
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 | Method and Description |
---|---|
Record |
RecordStore.createRecord(Object value,
long ttlMillis,
long now) |
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) |
Record |
DefaultRecordStore.loadRecordOrNull(Data key,
boolean backup) |
Record |
DefaultRecordStore.putBackup(Data key,
Object value) |
Record |
DefaultRecordStore.putBackup(Data key,
Object value,
long ttl,
boolean putTransient) |
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.doPostEvictionOperations(Record record,
boolean backup)
Does post eviction operations like sending events
|
protected void |
DefaultRecordStore.onStore(Record record) |
void |
DefaultRecordStore.putRecord(Data key,
Record record) |
protected Object |
DefaultRecordStore.removeRecord(Data key,
Record record,
long now) |
Modifier and Type | Method and Description |
---|---|
protected void |
DefaultRecordStore.flush(Collection<Record> recordsToBeFlushed,
boolean backup)
Flushes evicted records to map store.
|
protected List<Data> |
DefaultRecordStore.getKeysFromRecords(Collection<Record> clearableRecords) |
protected int |
DefaultRecordStore.removeRecords(Collection<Record> recordsToRemove) |
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.