| 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.query.impl |
Contains the implementation classes of the query functionality.
|
| 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.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.
|
| 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) |
Record |
AbstractEvictableRecordStore.getOrNullIfExpired(Record record,
long now,
boolean backup) |
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) |
Record |
DefaultRecordStore.putBackupTxn(Data key,
Data value,
long ttl,
long maxIdle,
boolean putTransient,
CallerProvenance provenance,
UUID transactionId) |
| 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)
Callback which is called when the record is being accessed from the record or index store.
|
void |
AbstractEvictableRecordStore.accessRecord(Record record,
long now) |
void |
RecordStore.doPostEvictionOperations(Record record)
Does post eviction operations like sending events
|
void |
AbstractEvictableRecordStore.doPostEvictionOperations(Record record) |
boolean |
RecordStoreAdapter.evictIfExpired(Record record,
long now,
boolean backup) |
protected Metadata |
JsonMetadataRecordStoreMutationObserver.getMetadata(Record record) |
Record |
AbstractEvictableRecordStore.getOrNullIfExpired(Record record,
long now,
boolean backup) |
boolean |
AbstractEvictableRecordStore.isExpired(Record record,
long now,
boolean backup) |
boolean |
RecordStore.isTtlOrMaxIdleDefined(Record record)
Checks whether ttl or maxIdle are set on the record.
|
boolean |
RecordStoreAdapter.isTtlOrMaxIdleDefined(Record record) |
boolean |
AbstractEvictableRecordStore.isTtlOrMaxIdleDefined(Record record) |
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,
UUID transactionId) |
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 |
|---|---|
Record |
QueryableEntry.getRecord() |
| Modifier and Type | Method and Description |
|---|---|
void |
QueryableEntry.setRecord(Record record) |
| 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 © 2019 Hazelcast, Inc.. All rights reserved.