Package | Description |
---|---|
com.hazelcast.map.impl.mapstore |
Contains map store operations.
|
com.hazelcast.map.impl.mapstore.writebehind |
Package for processing write behind store operations.
|
com.hazelcast.map.impl.mapstore.writebehind.entry | |
com.hazelcast.map.impl.mapstore.writethrough |
Package for processing write through store operations.
|
Modifier and Type | Method and Description |
---|---|
void |
MapDataStore.addForcibly(DelayedEntry<Data,Object> delayedEntry)
Adds delayed-entry without doing capacity checks.
|
Modifier and Type | Method and Description |
---|---|
static WriteBehindQueue<DelayedEntry> |
WriteBehindQueues.createBoundedWriteBehindQueue(MapStoreContext mapStoreContext) |
static WriteBehindQueue<DelayedEntry> |
WriteBehindQueues.createDefaultWriteBehindQueue() |
WriteBehindQueue<DelayedEntry> |
WriteBehindStore.getWriteBehindQueue() |
Modifier and Type | Method and Description |
---|---|
void |
WriteBehindStore.add(DelayedEntry<Data,Object> delayedEntry) |
void |
WriteBehindStore.addForcibly(DelayedEntry<Data,Object> delayedEntry) |
protected void |
WriteBehindStore.removeFromStagingArea(DelayedEntry delayedEntry) |
Modifier and Type | Method and Description |
---|---|
static <K,V> DelayedEntry<K,V> |
DelayedEntries.emptyDelayedEntry() |
static <K,V> DelayedEntry<K,V> |
DelayedEntries.newAddedDelayedEntry(K key) |
static <K,V> DelayedEntry<K,V> |
DelayedEntries.newAddedDelayedEntry(K key,
V value,
long expirationTime,
long storeTime,
int partitionId,
UUID txnId) |
static <K,V> DelayedEntry<K,V> |
DelayedEntries.newDeletedEntry(K key,
long storeTime,
int partitionId,
UUID txnId) |
static <K,V> DelayedEntry<K,V> |
DelayedEntries.newNullEntry(K key) |
Modifier and Type | Method and Description |
---|---|
void |
WriteThroughStore.addForcibly(DelayedEntry delayedEntry) |
Copyright © 2019 Hazelcast, Inc.. All rights reserved.