Package | Description |
---|---|
com.hazelcast.cache.impl |
Hazelcast JSR-107 aka JCache implementation
|
com.hazelcast.cache.impl.event |
Event classes to define listenters for JCache other than EntryListener
|
com.hazelcast.cache.impl.journal | |
com.hazelcast.cache.impl.merge.entry |
This package contains merge entry internal interfaces and functionality for Hazelcast cache.
|
com.hazelcast.cache.impl.operation |
Hazelcast JSR-107 aka JCache implementation
|
com.hazelcast.cache.impl.record |
Hazelcast JSR-107 aka JCache implementation
Internal record store
|
com.hazelcast.client.cache.impl |
Hazelcast JSR-107 aka JCache implementation client side
|
com.hazelcast.client.impl.protocol.codec | |
com.hazelcast.client.impl.protocol.codec.builtin | |
com.hazelcast.client.impl.protocol.codec.custom | |
com.hazelcast.client.impl.protocol.codec.holder | |
com.hazelcast.client.impl.protocol.task.dynamicconfig | |
com.hazelcast.client.impl.protocol.task.map |
Client protocol tasks implementations for map
|
com.hazelcast.client.impl.protocol.task.multimap |
Client protocol tasks implementations for multi map
|
com.hazelcast.client.impl.protocol.task.replicatedmap |
Client protocol tasks implementations for ReplicatedMap
|
com.hazelcast.client.impl.proxy |
This package contains client side proxy implementations of the different Hazelcast data structures
and operation types
|
com.hazelcast.client.impl.spi |
Contains classes/interfaces related to the Hazelcast client Service Provider Interface.
|
com.hazelcast.client.impl.spi.impl |
Provides util classes for the Hazelcast client SPI.
|
com.hazelcast.client.map.impl | |
com.hazelcast.collection.impl.collection | |
com.hazelcast.collection.impl.collection.operations | |
com.hazelcast.collection.impl.common | |
com.hazelcast.collection.impl.list |
This package contains IList functionality for Hazelcast.
|
com.hazelcast.collection.impl.list.operations | |
com.hazelcast.collection.impl.queue | |
com.hazelcast.collection.impl.queue.operations |
This package contains the IQueue operations
|
com.hazelcast.collection.impl.set |
This package contains ISet functionality for Hazelcast.
|
com.hazelcast.collection.impl.txncollection.operations | |
com.hazelcast.collection.impl.txnqueue | |
com.hazelcast.collection.impl.txnqueue.operations | |
com.hazelcast.cp.internal.datastructures.atomicref |
Contains service classes for the Raft-based
IAtomicReference implementation |
com.hazelcast.cp.internal.datastructures.atomicref.operation |
Contains operations for the Raft-based
IAtomicReference implementation |
com.hazelcast.durableexecutor.impl.operations |
This package contains operations for the DurableExecutorService.
|
com.hazelcast.executor.impl.operations |
This package contains operations for the IExecutorService.
|
com.hazelcast.internal.eviction |
Eviction policy implementations.
|
com.hazelcast.internal.journal |
This package contains supporting classes for data structure specific event journals.
|
com.hazelcast.internal.locksupport | |
com.hazelcast.internal.locksupport.operations |
This package contains the operations for the Lock support.
|
com.hazelcast.internal.nearcache |
Near Cache support.
|
com.hazelcast.internal.nearcache.impl |
Near Cache implementations.
|
com.hazelcast.internal.nearcache.impl.invalidation |
Invalidations for Near Cache.
|
com.hazelcast.internal.nearcache.impl.record |
Near Cache record implementations.
|
com.hazelcast.internal.nearcache.impl.store |
Near Cache store implementations.
|
com.hazelcast.internal.nio | |
com.hazelcast.internal.partition.impl |
Contains the actual implementation of the
InternalPartitionService . |
com.hazelcast.internal.serialization |
Contains the private serialization API + implementation.
|
com.hazelcast.internal.serialization.impl | |
com.hazelcast.internal.serialization.impl.bufferpool |
Contains the logic for the BufferPool.
|
com.hazelcast.internal.util |
This package contains classes to support the inner workings of Hazelcast
as well as some backports of newer Java features / data structures to
support older Java versions in a clean and nice way.
|
com.hazelcast.map.impl |
Contains implementation specific classes of
com.hazelcast.map package. |
com.hazelcast.map.impl.event | |
com.hazelcast.map.impl.eviction |
This package contains eviction classes.
|
com.hazelcast.map.impl.iterator | |
com.hazelcast.map.impl.journal | |
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.writethrough |
Package for processing write through store operations.
|
com.hazelcast.map.impl.nearcache |
Contains Near Cache specific classes.
|
com.hazelcast.map.impl.operation |
Package for map operations.
|
com.hazelcast.map.impl.proxy |
Contains map proxy implementation and support classes.
|
com.hazelcast.map.impl.query | |
com.hazelcast.map.impl.querycache.event |
This package contains classes for query cache events.
|
com.hazelcast.map.impl.querycache.subscriber |
This package contains classes which are used for
QueryCache
event subscription side. |
com.hazelcast.map.impl.querycache.subscriber.record |
This package contains classes for
QueryCacheRecord . |
com.hazelcast.map.impl.record |
Contains record specific classes.
|
com.hazelcast.map.impl.recordstore | |
com.hazelcast.map.impl.tx |
Contains implementation classes for
TransactionalMap |
com.hazelcast.map.impl.wan |
Contains wan replication event classes
|
com.hazelcast.multimap.impl |
Contains classes for Hazelcast MultiMap module.
|
com.hazelcast.multimap.impl.operations |
Contains operations for Hazelcast MultiMap module.
|
com.hazelcast.multimap.impl.txn |
This package contains the Transaction behavior for the Multimap.
|
com.hazelcast.nio |
This package contains classes related to New IO
|
com.hazelcast.query.impl |
Contains the implementation classes of the query functionality.
|
com.hazelcast.replicatedmap.impl |
This package contains the implementation of the replicated map service itself and some connection interfaces only used
internally.
|
com.hazelcast.replicatedmap.impl.client |
This package contains classes for client communication on replicated map implementation
|
com.hazelcast.replicatedmap.impl.operation |
This package contains replicated map operations which are executed on remote nodes
|
com.hazelcast.replicatedmap.impl.record |
This package contains the implementation of the backing data storage for the replicated map implementation
|
com.hazelcast.ringbuffer.impl |
Contains the
Ringbuffer implementation classes. |
com.hazelcast.ringbuffer.impl.client | |
com.hazelcast.ringbuffer.impl.operations | |
com.hazelcast.security |
Provides interfaces/classes for Hazelcast security implementation.
|
com.hazelcast.spi.impl |
Contains implementations for Hazelcast SPI.
|
com.hazelcast.spi.impl.merge |
This package contains split-brain related classes.
|
com.hazelcast.spi.impl.operationservice |
Contains the
com.hazelcast.spi.impl.operationservice.InternalOperationService API. |
com.hazelcast.spi.impl.operationservice.impl.operations |
Contains the Operations being used by the
OperationServiceImpl . |
com.hazelcast.spi.partition |
Contains the SPI for partition logic for Hazelcast.
|
com.hazelcast.topic.impl |
This package contains ITopic functionality for Hazelcast.
With the ITopic it is possible to create publish subscribe solutions similar to JMS Topics. |
com.hazelcast.topic.impl.reliable | |
com.hazelcast.transaction.impl.xa.operations | |
com.hazelcast.wan.impl |
This package contains the opensource implementation of WAN replication
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractCacheRecordStore<R extends CacheRecord,CRM extends SampleableCacheRecordMap<Data,R>> |
Modifier and Type | Field and Description |
---|---|
protected Data |
CacheEntryProcessorEntry.keyData |
Modifier and Type | Field and Description |
---|---|
protected EvictionPolicyEvaluator<Data,R> |
AbstractCacheRecordStore.evictionPolicyEvaluator |
protected SamplingEvictionStrategy<Data,R,CRM> |
AbstractCacheRecordStore.evictionStrategy |
protected Iterator<Map.Entry<Data,R>> |
AbstractCacheRecordStore.expirationIterator |
Modifier and Type | Method and Description |
---|---|
Data |
CacheEventContext.getDataKey() |
Data |
CacheEventData.getDataKey()
Gets cache entry key as
Data . |
Data |
CacheEventDataImpl.getDataKey() |
Data |
CacheEventContext.getDataOldValue() |
Data |
CacheEventData.getDataOldValue()
Gets the old value of entry as
Data , if available. |
Data |
CacheEventDataImpl.getDataOldValue() |
Data |
CacheEventContext.getDataValue() |
Data |
CacheEventData.getDataValue()
Gets cache entry value as
Data . |
Data |
CacheEventDataImpl.getDataValue() |
Data |
CacheEventContext.getExpiryPolicy() |
Data |
CacheKeyIterationResult.getKey(int index) |
Data |
DeferredValue.getSerializedValue(SerializationService serializationService) |
protected Data |
CacheRecordStore.recordToData(CacheRecord record) |
protected abstract Data |
AbstractCacheRecordStore.recordToData(R record) |
Data |
AbstractCacheService.toData(Object object) |
protected abstract Data |
AbstractClusterWideIterator.toData(Object obj) |
protected Data |
ClusterWideIterator.toData(Object obj) |
protected Data |
AbstractCacheRecordStore.toData(Object obj) |
Data |
AbstractCacheRecordStore.toEventData(Object obj) |
protected Data |
CacheRecordStore.toHeapData(Object obj) |
protected abstract Data |
AbstractCacheRecordStore.toHeapData(Object obj) |
protected Data |
CacheRecordStore.valueToData(Object value) |
protected abstract Data |
AbstractCacheRecordStore.valueToData(Object value) |
Modifier and Type | Method and Description |
---|---|
static CacheEntryView<Data,Data> |
CacheEntryViews.createDefaultEntryView(Data key,
Data value,
Data expiryPolicy,
CacheRecord<Object,Data> record)
Creates a
DefaultCacheEntryView instance. |
static CacheEntryView<Data,Data> |
CacheEntryViews.createDefaultEntryView(Data key,
Data value,
Data expiryPolicy,
CacheRecord<Object,Data> record)
Creates a
DefaultCacheEntryView instance. |
static CacheEntryView<Data,Data> |
CacheEntryViews.createEntryView(Data key,
Data expiryPolicy,
CacheRecord record) |
static CacheEntryView<Data,Data> |
CacheEntryViews.createEntryView(Data key,
Data expiryPolicy,
CacheRecord record) |
static CacheEntryView<Data,Data> |
CacheEntryViews.createEntryView(Data key,
Data value,
Data expiryPolicy,
CacheRecord record,
CacheEntryViews.CacheEntryViewType cacheEntryViewType)
Creates a
CacheEntryView instance. |
static CacheEntryView<Data,Data> |
CacheEntryViews.createEntryView(Data key,
Data value,
Data expiryPolicy,
CacheRecord record,
CacheEntryViews.CacheEntryViewType cacheEntryViewType)
Creates a
CacheEntryView instance. |
protected EvictionPolicyEvaluator<Data,R> |
AbstractCacheRecordStore.createEvictionPolicyEvaluator(EvictionConfig evictionConfig) |
protected SamplingEvictionStrategy<Data,R,CRM> |
AbstractCacheRecordStore.createEvictionStrategy(EvictionConfig cacheEvictionConfig) |
static CacheEntryView<Data,Data> |
CacheEntryViews.createLazyEntryView(Data key,
Data value,
Data expiryPolicy,
CacheRecord record)
Creates a
LazyCacheEntryView instance. |
static CacheEntryView<Data,Data> |
CacheEntryViews.createLazyEntryView(Data key,
Data value,
Data expiryPolicy,
CacheRecord record)
Creates a
LazyCacheEntryView instance. |
List<Map.Entry<Data,Data>> |
CacheEntryIterationResult.getEntries() |
List<Map.Entry<Data,Data>> |
CacheEntryIterationResult.getEntries() |
List<Data> |
CacheKeyIterationResult.getKeys() |
Map<Data,CacheRecord> |
ICacheRecordStore.getReadOnlyRecords()
Returns a readonly map of the internal key value store.
|
Map<Data,CacheRecord> |
AbstractCacheRecordStore.getReadOnlyRecords() |
Set<Data> |
ICacheRecordStore.loadAll(Set<Data> keys,
boolean replaceExistingValues)
Synchronously loads the specified entries into the cache using the
configured
CacheLoader for the given keys. |
Set<Data> |
AbstractCacheRecordStore.loadAll(Set<Data> keys,
boolean replaceExistingValues) |
protected Map<Data,Object> |
AbstractCacheRecordStore.loadAllCacheEntry(Set<Data> keys) |
Modifier and Type | Method and Description |
---|---|
R |
AbstractCacheRecordStore.accessRecord(Data key,
R record,
javax.cache.expiry.ExpiryPolicy expiryPolicy,
long now) |
protected void |
AbstractCacheRecordStore.accumulateOrSendExpiredKeysToBackup(Data key,
R record) |
boolean |
ICacheRecordStore.contains(Data key)
Determines if this store contains an entry for the specified key.
|
boolean |
AbstractCacheRecordStore.contains(Data key) |
static CacheEventContext |
CacheEventContextUtil.createBaseEventContext(CacheEventType eventType,
Data dataKey,
Data dataValue,
long expirationTime,
UUID origin,
int completionId) |
static CacheEventContext |
CacheEventContextUtil.createCacheCompleteEvent(Data dataKey,
int completionId) |
static CacheEventContext |
CacheEventContextUtil.createCacheCompleteEvent(Data dataKey,
long expirationTime,
UUID origin,
int completionId) |
static CacheEventContext |
CacheEventContextUtil.createCacheCreatedEvent(Data dataKey,
Data dataValue,
long expirationTime,
UUID origin,
int completionId) |
protected CacheEntryProcessorEntry |
CacheRecordStore.createCacheEntryProcessorEntry(Data key,
CacheRecord record,
long now,
int completionId) |
protected abstract CacheEntryProcessorEntry |
AbstractCacheRecordStore.createCacheEntryProcessorEntry(Data key,
R record,
long now,
int completionId) |
static CacheEventContext |
CacheEventContextUtil.createCacheExpiredEvent(Data dataKey,
Data dataValue,
long expirationTime,
UUID origin,
int completionId) |
static CacheEventContext |
CacheEventContextUtil.createCacheRemovedEvent(Data dataKey) |
static CacheEventContext |
CacheEventContextUtil.createCacheRemovedEvent(Data dataKey,
Data dataValue,
long expirationTime,
UUID origin,
int completionId) |
static CacheEventContext |
CacheEventContextUtil.createCacheUpdatedEvent(Data dataKey,
Data dataValue,
Data dataOldValue,
long creationTime,
long expirationTime,
long lastAccessTime,
long accessHit,
Data expiryPolicy) |
static CacheEventContext |
CacheEventContextUtil.createCacheUpdatedEvent(Data dataKey,
Data dataValue,
Data dataOldValue,
long creationTime,
long expirationTime,
long lastAccessTime,
long accessHit,
UUID origin,
int completionId,
Data expiryPolicy) |
Operation |
CacheOperationProvider.createContainsKeyOperation(Data key) |
Operation |
DefaultOperationProvider.createContainsKeyOperation(Data key) |
static CacheEntryView<Data,Data> |
CacheEntryViews.createDefaultEntryView(Data key,
Data value,
Data expiryPolicy,
CacheRecord<Object,Data> record)
Creates a
DefaultCacheEntryView instance. |
Operation |
CacheOperationProvider.createEntryProcessorOperation(Data key,
Integer completionId,
javax.cache.processor.EntryProcessor entryProcessor,
Object... args) |
Operation |
DefaultOperationProvider.createEntryProcessorOperation(Data key,
Integer completionId,
javax.cache.processor.EntryProcessor entryProcessor,
Object... arguments) |
static CacheEntryView<Data,Data> |
CacheEntryViews.createEntryView(Data key,
Data expiryPolicy,
CacheRecord record) |
static CacheEntryView<Data,Data> |
CacheEntryViews.createEntryView(Data key,
Data value,
Data expiryPolicy,
CacheRecord record,
CacheEntryViews.CacheEntryViewType cacheEntryViewType)
Creates a
CacheEntryView instance. |
Operation |
CacheOperationProvider.createGetAndRemoveOperation(Data key,
int completionId) |
Operation |
DefaultOperationProvider.createGetAndRemoveOperation(Data key,
int completionId) |
Operation |
CacheOperationProvider.createGetAndReplaceOperation(Data key,
Data value,
javax.cache.expiry.ExpiryPolicy policy,
int completionId) |
Operation |
DefaultOperationProvider.createGetAndReplaceOperation(Data key,
Data value,
javax.cache.expiry.ExpiryPolicy policy,
int completionId) |
Operation |
CacheOperationProvider.createGetOperation(Data key,
javax.cache.expiry.ExpiryPolicy policy) |
Operation |
DefaultOperationProvider.createGetOperation(Data key,
javax.cache.expiry.ExpiryPolicy policy) |
static CacheEntryView<Data,Data> |
CacheEntryViews.createLazyEntryView(Data key,
Data value,
Data expiryPolicy,
CacheRecord record)
Creates a
LazyCacheEntryView instance. |
Operation |
CacheOperationProvider.createPutIfAbsentOperation(Data key,
Data value,
javax.cache.expiry.ExpiryPolicy policy,
int completionId) |
Operation |
DefaultOperationProvider.createPutIfAbsentOperation(Data key,
Data value,
javax.cache.expiry.ExpiryPolicy policy,
int completionId) |
Operation |
CacheOperationProvider.createPutOperation(Data key,
Data value,
javax.cache.expiry.ExpiryPolicy policy,
boolean get,
int completionId) |
Operation |
DefaultOperationProvider.createPutOperation(Data key,
Data value,
javax.cache.expiry.ExpiryPolicy policy,
boolean get,
int completionId) |
protected R |
AbstractCacheRecordStore.createRecord(Data keyData,
Object value,
long expirationTime,
int completionId) |
protected R |
AbstractCacheRecordStore.createRecord(Data key,
Object value,
long expiryTime,
long now,
boolean disableWriteThrough,
int completionId,
UUID origin) |
protected R |
AbstractCacheRecordStore.createRecordWithExpiry(Data key,
Object value,
javax.cache.expiry.ExpiryPolicy expiryPolicy,
long now,
boolean disableWriteThrough,
int completionId) |
protected R |
AbstractCacheRecordStore.createRecordWithExpiry(Data key,
Object value,
javax.cache.expiry.ExpiryPolicy expiryPolicy,
long now,
boolean disableWriteThrough,
int completionId,
UUID origin) |
protected R |
AbstractCacheRecordStore.createRecordWithExpiry(Data key,
Object value,
long expiryTime,
long now,
boolean disableWriteThrough,
int completionId) |
protected R |
AbstractCacheRecordStore.createRecordWithExpiry(Data key,
Object value,
long expiryTime,
long now,
boolean disableWriteThrough,
int completionId,
UUID origin) |
Operation |
CacheOperationProvider.createRemoveOperation(Data key,
Data value,
int completionId) |
Operation |
DefaultOperationProvider.createRemoveOperation(Data key,
Data oldValue,
int completionId) |
Operation |
CacheOperationProvider.createReplaceOperation(Data key,
Data oldValue,
Data newValue,
javax.cache.expiry.ExpiryPolicy policy,
int completionId) |
Operation |
DefaultOperationProvider.createReplaceOperation(Data key,
Data oldValue,
Data newValue,
javax.cache.expiry.ExpiryPolicy policy,
int completionId) |
Operation |
CacheOperationProvider.createSetExpiryPolicyOperation(List<Data> keys,
Data expiryPolicy) |
Operation |
DefaultOperationProvider.createSetExpiryPolicyOperation(List<Data> keys,
Data expiryPolicy) |
protected Object |
CacheRecordStore.dataToValue(Data data) |
protected abstract Object |
AbstractCacheRecordStore.dataToValue(Data data) |
protected void |
AbstractCacheRecordStore.deleteCacheEntry(Data key) |
protected void |
AbstractCacheRecordStore.deleteCacheEntry(Data key,
CallerProvenance provenance) |
protected boolean |
AbstractCacheRecordStore.deleteRecord(Data key,
int completionId) |
protected boolean |
AbstractCacheRecordStore.deleteRecord(Data key,
int completionId,
UUID source) |
protected boolean |
AbstractCacheRecordStore.deleteRecord(Data key,
int completionId,
UUID source,
UUID origin) |
protected R |
AbstractCacheRecordStore.doPutRecord(Data key,
R record,
UUID source,
boolean updateJournal) |
protected R |
AbstractCacheRecordStore.doRemoveRecord(Data key,
UUID source) |
protected boolean |
AbstractCacheRecordStore.evictIfExpired(Data key,
R record,
long now) |
protected void |
AbstractCacheRecordStore.forceRemoveRecord(Data key) |
Object |
ICacheRecordStore.get(Data key,
javax.cache.expiry.ExpiryPolicy expiryPolicy)
Gets the value to which the specified key is mapped,
or
null if this cache contains no mapping for the key. |
Object |
AbstractCacheRecordStore.get(Data key,
javax.cache.expiry.ExpiryPolicy expiryPolicy) |
Object |
ICacheRecordStore.getAndPut(Data key,
Object value,
javax.cache.expiry.ExpiryPolicy expiryPolicy,
UUID caller,
int completionId)
Associates the specified value with the specified key in this cache,
returning an existing value if one existed.
|
Object |
AbstractCacheRecordStore.getAndPut(Data key,
Object value,
javax.cache.expiry.ExpiryPolicy expiryPolicy,
UUID source,
int completionId) |
Object |
ICacheRecordStore.getAndRemove(Data key,
UUID caller,
int completionId)
Atomically removes the entry for a key only if it is currently mapped to some
value.
|
Object |
AbstractCacheRecordStore.getAndRemove(Data key,
UUID source,
int completionId) |
Object |
AbstractCacheRecordStore.getAndRemove(Data key,
UUID source,
int completionId,
UUID origin) |
Object |
ICacheRecordStore.getAndReplace(Data key,
Object value,
javax.cache.expiry.ExpiryPolicy expiryPolicy,
UUID caller,
int completionId)
Atomically replaces the value for a given key if and only if there is a
value currently mapped by the key.
|
Object |
AbstractCacheRecordStore.getAndReplace(Data key,
Object value,
javax.cache.expiry.ExpiryPolicy expiryPolicy,
UUID source,
int completionId) |
Object |
ICacheRecordStore.getExpiryPolicy(Data key) |
Object |
AbstractCacheRecordStore.getExpiryPolicy(Data key) |
static int |
CacheProxyUtil.getPartitionId(NodeEngine nodeEngine,
Data key) |
CacheRecord |
ICacheRecordStore.getRecord(Data key)
Gets internal record of the store by key.
|
CacheRecord |
AbstractCacheRecordStore.getRecord(Data key) |
protected void |
AbstractCacheRecordStore.invalidateEntry(Data key) |
protected void |
AbstractCacheRecordStore.invalidateEntry(Data key,
UUID source) |
Object |
ICacheRecordStore.invoke(Data key,
javax.cache.processor.EntryProcessor entryProcessor,
Object[] arguments,
int completionId)
Invokes an
EntryProcessor against the Cache.Entry specified by
the provided key. |
Object |
AbstractCacheRecordStore.invoke(Data key,
javax.cache.processor.EntryProcessor entryProcessor,
Object[] arguments,
int completionId) |
protected void |
CacheEntryProcessorEntry.onCreate(Data key,
Object value,
javax.cache.expiry.ExpiryPolicy expiryPolicy,
long now,
boolean disableWriteThrough,
int completionId,
boolean saved) |
protected void |
AbstractCacheRecordStore.onCreateRecordError(Data key,
Object value,
long expiryTime,
long now,
boolean disableWriteThrough,
int completionId,
UUID origin,
R record,
Throwable error) |
protected void |
AbstractCacheRecordStore.onDeleteRecord(Data key,
R record,
boolean deleted) |
void |
AbstractCacheRecordStore.onEvict(Data key,
R record,
boolean wasExpired) |
protected void |
AbstractCacheRecordStore.onGet(Data key,
javax.cache.expiry.ExpiryPolicy expiryPolicy,
Object value,
R record) |
protected void |
AbstractCacheRecordStore.onGetError(Data key,
javax.cache.expiry.ExpiryPolicy expiryPolicy,
Object value,
R record,
Throwable error) |
protected void |
CacheEntryProcessorEntry.onLoad(Data key,
Object value,
javax.cache.expiry.ExpiryPolicy expiryPolicy,
long now,
boolean disableWriteThrough,
int completionId,
boolean saved) |
protected void |
AbstractCacheRecordStore.onProcessExpiredEntry(Data key,
R record,
long expiryTime,
long now,
UUID source,
UUID origin) |
protected void |
AbstractCacheRecordStore.onPut(Data key,
Object value,
javax.cache.expiry.ExpiryPolicy expiryPolicy,
UUID source,
boolean getValue,
boolean disableWriteThrough,
R record,
Object oldValue,
boolean isExpired,
boolean isNewPut,
boolean isSaveSucceed) |
protected void |
AbstractCacheRecordStore.onPutError(Data key,
Object value,
javax.cache.expiry.ExpiryPolicy expiryPolicy,
UUID source,
boolean getValue,
boolean disableWriteThrough,
R record,
Object oldValue,
boolean wouldBeNewPut,
Throwable error) |
protected void |
AbstractCacheRecordStore.onPutIfAbsent(Data key,
Object value,
javax.cache.expiry.ExpiryPolicy expiryPolicy,
UUID source,
boolean disableWriteThrough,
R record,
boolean isExpired,
boolean isSaveSucceed) |
protected void |
AbstractCacheRecordStore.onPutIfAbsentError(Data key,
Object value,
javax.cache.expiry.ExpiryPolicy expiryPolicy,
UUID source,
boolean disableWriteThrough,
R record,
Throwable error) |
protected long |
AbstractCacheRecordStore.onRecordAccess(Data key,
R record,
javax.cache.expiry.ExpiryPolicy expiryPolicy,
long now) |
protected void |
AbstractCacheRecordStore.onRemove(Data key,
Object value,
UUID source,
boolean getValue,
R record,
boolean removed) |
protected void |
CacheEntryProcessorEntry.onRemove(Data key,
String source,
int completionId,
boolean removed) |
protected void |
AbstractCacheRecordStore.onRemoveError(Data key,
Object value,
UUID source,
boolean getValue,
R record,
boolean removed,
Throwable error) |
protected void |
AbstractCacheRecordStore.onReplace(Data key,
Object oldValue,
Object newValue,
javax.cache.expiry.ExpiryPolicy expiryPolicy,
UUID source,
boolean getValue,
R record,
boolean isExpired,
boolean replaced) |
protected void |
AbstractCacheRecordStore.onReplaceError(Data key,
Object oldValue,
Object newValue,
javax.cache.expiry.ExpiryPolicy expiryPolicy,
UUID source,
boolean getValue,
R record,
boolean isExpired,
boolean replaced,
Throwable error) |
protected void |
CacheEntryProcessorEntry.onUpdate(Data key,
Object value,
R record,
javax.cache.expiry.ExpiryPolicy expiryPolicy,
long now,
boolean disableWriteThrough,
int completionId,
boolean saved) |
protected void |
AbstractCacheRecordStore.onUpdateExpiryPolicy(Data key,
R record,
Data oldDataExpiryPolicy) |
protected void |
AbstractCacheRecordStore.onUpdateExpiryPolicyError(Data key,
R record,
Data oldDataExpiryPolicy) |
protected void |
AbstractCacheRecordStore.onUpdateRecord(Data key,
R record,
Object value,
Data oldDataValue) |
protected void |
AbstractCacheRecordStore.onUpdateRecordError(Data key,
R record,
Object value,
Data newDataValue,
Data oldDataValue,
Throwable error) |
protected boolean |
AbstractCacheRecordStore.processExpiredEntry(Data key,
R record,
long now) |
protected R |
AbstractCacheRecordStore.processExpiredEntry(Data key,
R record,
long expiryTime,
long now,
UUID source) |
protected R |
AbstractCacheRecordStore.processExpiredEntry(Data key,
R record,
long expiryTime,
long now,
UUID source,
UUID origin) |
protected boolean |
AbstractCacheRecordStore.processExpiredEntry(Data key,
R record,
long now,
UUID source) |
protected boolean |
AbstractCacheRecordStore.processExpiredEntry(Data key,
R record,
long now,
UUID source,
UUID origin) |
protected Object |
AbstractCacheRecordStore.put(Data key,
Object value,
javax.cache.expiry.ExpiryPolicy expiryPolicy,
UUID source,
boolean getValue,
boolean disableWriteThrough,
int completionId) |
protected Object |
AbstractCacheRecordStore.put(Data key,
Object value,
javax.cache.expiry.ExpiryPolicy expiryPolicy,
UUID source,
boolean getValue,
int completionId) |
CacheRecord |
ICacheRecordStore.put(Data key,
Object value,
javax.cache.expiry.ExpiryPolicy expiryPolicy,
UUID caller,
int completionId)
Associates the specified value with the specified key in this cache,
returning an existing value if one existed.
|
R |
AbstractCacheRecordStore.put(Data key,
Object value,
javax.cache.expiry.ExpiryPolicy expiryPolicy,
UUID source,
int completionId) |
protected boolean |
AbstractCacheRecordStore.putIfAbsent(Data key,
Object value,
javax.cache.expiry.ExpiryPolicy expiryPolicy,
UUID source,
boolean disableWriteThrough,
int completionId) |
boolean |
ICacheRecordStore.putIfAbsent(Data key,
Object value,
javax.cache.expiry.ExpiryPolicy expiryPolicy,
UUID caller,
int completionId)
Removes the mapping for a key from this cache if it is present.
|
boolean |
AbstractCacheRecordStore.putIfAbsent(Data key,
Object value,
javax.cache.expiry.ExpiryPolicy expiryPolicy,
UUID source,
int completionId) |
void |
ICacheRecordStore.putRecord(Data key,
CacheRecord record,
boolean updateJournal)
Associates the specified record with the specified key.
|
void |
AbstractCacheRecordStore.putRecord(Data key,
CacheRecord record,
boolean updateJournal) |
Object |
AbstractCacheRecordStore.readThroughCache(Data key) |
R |
AbstractCacheRecordStore.readThroughRecord(Data key,
long now) |
boolean |
ICacheRecordStore.remove(Data key,
Object value,
UUID caller,
UUID origin,
int completionId)
Atomically removes the mapping for a key only if currently mapped to the
given value.
|
boolean |
AbstractCacheRecordStore.remove(Data key,
Object value,
UUID source,
UUID origin,
int completionId) |
boolean |
ICacheRecordStore.remove(Data key,
UUID caller,
UUID origin,
int completionId) |
boolean |
AbstractCacheRecordStore.remove(Data key,
UUID source,
UUID origin,
int completionId) |
boolean |
ICacheRecordStore.remove(Data key,
UUID caller,
UUID origin,
int completionId,
CallerProvenance provenance)
Removes the mapping for a key from this cache if it is present.
|
boolean |
AbstractCacheRecordStore.remove(Data key,
UUID source,
UUID origin,
int completionId,
CallerProvenance provenance) |
CacheRecord |
ICacheRecordStore.removeRecord(Data key)
Removes the record for a key.
|
CacheRecord |
AbstractCacheRecordStore.removeRecord(Data key) |
boolean |
ICacheRecordStore.replace(Data key,
Object value,
javax.cache.expiry.ExpiryPolicy expiryPolicy,
UUID caller,
int completionId)
Atomically replaces the entry for a key only if currently mapped to some
value.
|
boolean |
AbstractCacheRecordStore.replace(Data key,
Object value,
javax.cache.expiry.ExpiryPolicy expiryPolicy,
UUID source,
int completionId) |
boolean |
ICacheRecordStore.replace(Data key,
Object oldValue,
Object newValue,
javax.cache.expiry.ExpiryPolicy expiryPolicy,
UUID caller,
int completionId)
Atomically replaces the entry for a key only if currently mapped to a
given value.
|
boolean |
AbstractCacheRecordStore.replace(Data key,
Object oldValue,
Object newValue,
javax.cache.expiry.ExpiryPolicy expiryPolicy,
UUID source,
int completionId) |
void |
AbstractCacheService.sendInvalidationEvent(String cacheNameWithPrefix,
Data key,
UUID sourceUuid)
Sends an invalidation event for given
cacheName with specified key
from mentioned source with sourceUuid . |
void |
ICacheService.sendInvalidationEvent(String cacheNameWithPrefix,
Data key,
UUID sourceUuid) |
CacheEventContext |
CacheEventContext.setDataKey(Data dataKey) |
CacheEventContext |
CacheEventContext.setDataOldValue(Data dataOldValue) |
CacheEventContext |
CacheEventContext.setDataValue(Data dataValue) |
CacheEventContext |
CacheEventContext.setExpiryPolicy(Data expiryPolicy) |
protected long |
AbstractCacheRecordStore.updateAccessDuration(Data key,
R record,
javax.cache.expiry.ExpiryPolicy expiryPolicy,
long now) |
protected void |
AbstractCacheRecordStore.updateExpiryPolicyOfRecord(Data key,
R record,
Object expiryPolicy) |
protected void |
AbstractCacheRecordStore.updateRecord(Data key,
CacheRecord record,
long expiryTime,
long now,
UUID origin) |
protected void |
AbstractCacheRecordStore.updateRecord(Data key,
R record,
Object value,
long expiryTime,
long now,
boolean disableWriteThrough,
int completionId,
UUID source,
UUID origin) |
protected void |
AbstractCacheRecordStore.updateRecordWithExpiry(Data key,
CacheRecord record,
javax.cache.expiry.ExpiryPolicy expiryPolicy,
long now,
UUID source) |
protected boolean |
AbstractCacheRecordStore.updateRecordWithExpiry(Data key,
Object value,
R record,
javax.cache.expiry.ExpiryPolicy expiryPolicy,
long now,
boolean disableWriteThrough,
int completionId) |
protected boolean |
AbstractCacheRecordStore.updateRecordWithExpiry(Data key,
Object value,
R record,
javax.cache.expiry.ExpiryPolicy expiryPolicy,
long now,
boolean disableWriteThrough,
int completionId,
UUID source) |
protected boolean |
AbstractCacheRecordStore.updateRecordWithExpiry(Data key,
Object value,
R record,
javax.cache.expiry.ExpiryPolicy expiryPolicy,
long now,
boolean disableWriteThrough,
int completionId,
UUID source,
UUID origin) |
protected boolean |
AbstractCacheRecordStore.updateRecordWithExpiry(Data key,
Object value,
R record,
long expiryTime,
long now,
boolean disableWriteThrough,
int completionId) |
protected boolean |
AbstractCacheRecordStore.updateRecordWithExpiry(Data key,
Object value,
R record,
long expiryTime,
long now,
boolean disableWriteThrough,
int completionId,
UUID source) |
protected boolean |
AbstractCacheRecordStore.updateRecordWithExpiry(Data key,
Object value,
R record,
long expiryTime,
long now,
boolean disableWriteThrough,
int completionId,
UUID source,
UUID origin) |
static <V> DeferredValue<V> |
DeferredValue.withSerializedValue(Data serializedValue) |
void |
AbstractCacheRecordStore.writeThroughCache(Data key,
Object value) |
Modifier and Type | Method and Description |
---|---|
static CacheEntryView<Data,Data> |
CacheEntryViews.createDefaultEntryView(Data key,
Data value,
Data expiryPolicy,
CacheRecord<Object,Data> record)
Creates a
DefaultCacheEntryView instance. |
OperationFactory |
CacheOperationProvider.createGetAllOperationFactory(Set<Data> keySet,
javax.cache.expiry.ExpiryPolicy policy) |
OperationFactory |
DefaultOperationProvider.createGetAllOperationFactory(Set<Data> keySet,
javax.cache.expiry.ExpiryPolicy policy) |
OperationFactory |
CacheOperationProvider.createLoadAllOperationFactory(Set<Data> keySet,
boolean replaceExistingValues) |
OperationFactory |
DefaultOperationProvider.createLoadAllOperationFactory(Set<Data> keySet,
boolean replaceExistingValues) |
Operation |
CacheOperationProvider.createMergeOperation(String name,
List<SplitBrainMergeTypes.CacheMergeTypes> mergingEntries,
SplitBrainMergePolicy<Data,SplitBrainMergeTypes.CacheMergeTypes> policy) |
Operation |
DefaultOperationProvider.createMergeOperation(String name,
List<SplitBrainMergeTypes.CacheMergeTypes> mergingEntries,
SplitBrainMergePolicy<Data,SplitBrainMergeTypes.CacheMergeTypes> policy) |
OperationFactory |
CacheOperationProvider.createMergeOperationFactory(String name,
int[] partitions,
List<SplitBrainMergeTypes.CacheMergeTypes>[] mergingEntries,
SplitBrainMergePolicy<Data,SplitBrainMergeTypes.CacheMergeTypes> policy) |
OperationFactory |
DefaultOperationProvider.createMergeOperationFactory(String name,
int[] partitions,
List<SplitBrainMergeTypes.CacheMergeTypes>[] mergingEntries,
SplitBrainMergePolicy<Data,SplitBrainMergeTypes.CacheMergeTypes> policy) |
Operation |
CacheOperationProvider.createPutAllOperation(List<Map.Entry<Data,Data>> entries,
javax.cache.expiry.ExpiryPolicy policy,
int completionId) |
Operation |
CacheOperationProvider.createPutAllOperation(List<Map.Entry<Data,Data>> entries,
javax.cache.expiry.ExpiryPolicy policy,
int completionId) |
Operation |
DefaultOperationProvider.createPutAllOperation(List<Map.Entry<Data,Data>> entries,
javax.cache.expiry.ExpiryPolicy policy,
int completionId) |
Operation |
DefaultOperationProvider.createPutAllOperation(List<Map.Entry<Data,Data>> entries,
javax.cache.expiry.ExpiryPolicy policy,
int completionId) |
OperationFactory |
CacheOperationProvider.createRemoveAllOperationFactory(Set<Data> keySet,
Integer completionId) |
OperationFactory |
DefaultOperationProvider.createRemoveAllOperationFactory(Set<Data> keySet,
Integer completionId) |
Operation |
CacheOperationProvider.createSetExpiryPolicyOperation(List<Data> keys,
Data expiryPolicy) |
Operation |
DefaultOperationProvider.createSetExpiryPolicyOperation(List<Data> keys,
Data expiryPolicy) |
protected void |
AbstractCacheRecordStore.deleteAllCacheEntry(Set<Data> keys) |
MapEntries |
ICacheRecordStore.getAll(Set<Data> keySet,
javax.cache.expiry.ExpiryPolicy expiryPolicy)
Gets a collection of entries from the store, returning them as
Map of the values associated with the set of keys requested. |
MapEntries |
AbstractCacheRecordStore.getAll(Set<Data> keySet,
javax.cache.expiry.ExpiryPolicy expiryPolicy) |
Set<Data> |
ICacheRecordStore.loadAll(Set<Data> keys,
boolean replaceExistingValues)
Synchronously loads the specified entries into the cache using the
configured
CacheLoader for the given keys. |
Set<Data> |
AbstractCacheRecordStore.loadAll(Set<Data> keys,
boolean replaceExistingValues) |
protected Map<Data,Object> |
AbstractCacheRecordStore.loadAllCacheEntry(Set<Data> keys) |
CacheRecord |
ICacheRecordStore.merge(SplitBrainMergeTypes.CacheMergeTypes mergingEntry,
SplitBrainMergePolicy<Data,SplitBrainMergeTypes.CacheMergeTypes> mergePolicy,
CallerProvenance callerProvenance)
Merges the given
SplitBrainMergeTypes.CacheMergeTypes via the given SplitBrainMergePolicy . |
CacheRecord |
AbstractCacheRecordStore.merge(SplitBrainMergeTypes.CacheMergeTypes mergingEntry,
SplitBrainMergePolicy<Data,SplitBrainMergeTypes.CacheMergeTypes> mergePolicy,
CallerProvenance callerProvenance) |
void |
ICacheRecordStore.removeAll(Set<Data> keys,
int completionId)
records of keys will be deleted one by one and will publish a REMOVE event
for each key.
|
void |
AbstractCacheRecordStore.removeAll(Set<Data> keys,
int completionId) |
boolean |
ICacheRecordStore.setExpiryPolicy(Collection<Data> keys,
Object expiryPolicy,
UUID source)
Sets expiry policy for the records with given keys if and only if there is a
value currently mapped by the key
|
boolean |
AbstractCacheRecordStore.setExpiryPolicy(Collection<Data> keys,
Object expiryPolicy,
UUID source) |
Constructor and Description |
---|
CacheEntryProcessorEntry(Data keyData,
R record,
AbstractCacheRecordStore cacheRecordStore,
long now,
int completionId) |
CacheEventDataImpl(String name,
CacheEventType eventType,
Data dataKey,
Data dataNewValue,
Data dataOldValue,
boolean isOldValueAvailable) |
Constructor and Description |
---|
CacheEntryIterationResult(List<Map.Entry<Data,Data>> entries,
int tableIndex) |
CacheEntryIterationResult(List<Map.Entry<Data,Data>> entries,
int tableIndex) |
CacheKeyIterationResult(List<Data> keys,
int tableIndex) |
Modifier and Type | Method and Description |
---|---|
void |
CacheWanEventPublisher.publishWanRemove(String cacheNameWithPrefix,
Data key)
This method will create a wrapper object using the given
CacheEntryView
and place it to wan replication queues. |
Modifier and Type | Method and Description |
---|---|
void |
CacheWanEventPublisher.publishWanUpdate(String cacheNameWithPrefix,
CacheEntryView<Data,Data> entryView)
This method will create a wrapper object using the given
CacheEntryView
and place it to wan replication queues. |
void |
CacheWanEventPublisher.publishWanUpdate(String cacheNameWithPrefix,
CacheEntryView<Data,Data> entryView)
This method will create a wrapper object using the given
CacheEntryView
and place it to wan replication queues. |
Modifier and Type | Field and Description |
---|---|
protected Data |
InternalEventJournalCacheEvent.dataKey |
protected Data |
InternalEventJournalCacheEvent.dataNewValue |
protected Data |
InternalEventJournalCacheEvent.dataOldValue |
Modifier and Type | Method and Description |
---|---|
Data |
InternalEventJournalCacheEvent.getDataKey() |
Data |
InternalEventJournalCacheEvent.getDataNewValue() |
Data |
InternalEventJournalCacheEvent.getDataOldValue() |
protected Data |
RingbufferCacheEventJournalImpl.toData(Object val) |
Modifier and Type | Method and Description |
---|---|
void |
RingbufferCacheEventJournalImpl.writeCreatedEvent(EventJournalConfig journalConfig,
ObjectNamespace namespace,
int partitionId,
Data key,
Object value) |
void |
CacheEventJournal.writeCreatedEvent(EventJournalConfig journalConfig,
ObjectNamespace namespace,
int partitionId,
Data key,
Object value)
Writes an
CacheEventType.CREATED to the event journal. |
void |
RingbufferCacheEventJournalImpl.writeEvictEvent(EventJournalConfig journalConfig,
ObjectNamespace namespace,
int partitionId,
Data key,
Object value) |
void |
CacheEventJournal.writeEvictEvent(EventJournalConfig journalConfig,
ObjectNamespace namespace,
int partitionId,
Data key,
Object value)
Writes an
CacheEventType.EVICTED to the event journal. |
void |
RingbufferCacheEventJournalImpl.writeExpiredEvent(EventJournalConfig journalConfig,
ObjectNamespace namespace,
int partitionId,
Data key,
Object value) |
void |
CacheEventJournal.writeExpiredEvent(EventJournalConfig journalConfig,
ObjectNamespace namespace,
int partitionId,
Data key,
Object value)
Writes an
CacheEventType.EXPIRED to the event journal. |
void |
RingbufferCacheEventJournalImpl.writeRemoveEvent(EventJournalConfig journalConfig,
ObjectNamespace namespace,
int partitionId,
Data key,
Object value) |
void |
CacheEventJournal.writeRemoveEvent(EventJournalConfig journalConfig,
ObjectNamespace namespace,
int partitionId,
Data key,
Object value)
Writes an
CacheEventType.REMOVED to the event journal. |
void |
RingbufferCacheEventJournalImpl.writeUpdateEvent(EventJournalConfig journalConfig,
ObjectNamespace namespace,
int partitionId,
Data key,
Object oldValue,
Object newValue) |
void |
CacheEventJournal.writeUpdateEvent(EventJournalConfig journalConfig,
ObjectNamespace namespace,
int partitionId,
Data key,
Object oldValue,
Object newValue)
Writes an
CacheEventType.UPDATED to the event journal. |
Constructor and Description |
---|
InternalEventJournalCacheEvent(Data dataKey,
Data dataNewValue,
Data dataOldValue,
int eventType) |
Modifier and Type | Method and Description |
---|---|
Data |
DefaultCacheEntryView.getExpiryPolicy()
Gets the expiry policy associated with this entry if any
|
Data |
DefaultCacheEntryView.getKey() |
Data |
DefaultCacheEntryView.getValue() |
Constructor and Description |
---|
DefaultCacheEntryView(Data key,
Data value,
long creationTime,
long expirationTime,
long lastAccessTime,
long accessHit,
Data expiryPolicy) |
Modifier and Type | Field and Description |
---|---|
protected Data |
KeyBasedCacheOperation.key |
Modifier and Type | Method and Description |
---|---|
protected void |
CacheOperation.publishWanRemove(Data dataKey) |
protected void |
CacheOperation.publishWanUpdate(Data dataKey,
CacheRecord record) |
protected void |
CacheOperation.publishWanUpdate(Data dataKey,
Data dataValue,
CacheRecord record) |
protected void |
CacheOperation.publishWanUpdate(Data dataKey,
Data dataValue,
Data dataExpiryPolicy,
CacheRecord record) |
Constructor and Description |
---|
CacheBackupEntryProcessorOperation(String cacheNameWithPrefix,
Data key,
javax.cache.processor.EntryProcessor entryProcessor,
Object... arguments) |
CacheContainsKeyOperation(String name,
Data key) |
CacheEntryProcessorOperation(String cacheNameWithPrefix,
Data key,
int completionId,
javax.cache.processor.EntryProcessor entryProcessor,
Object... arguments) |
CacheGetAndRemoveOperation(String name,
Data key,
int completionId) |
CacheGetAndReplaceOperation(String cacheNameWithPrefix,
Data key,
Data value,
javax.cache.expiry.ExpiryPolicy expiryPolicy,
int completionId) |
CacheGetOperation(String cacheNameWithPrefix,
Data key,
javax.cache.expiry.ExpiryPolicy expiryPolicy) |
CachePutBackupOperation(String name,
Data key,
CacheRecord cacheRecord) |
CachePutBackupOperation(String name,
Data key,
CacheRecord cacheRecord,
boolean wanOriginated) |
CachePutIfAbsentOperation(String cacheNameWithPrefix,
Data key,
Data value,
javax.cache.expiry.ExpiryPolicy expiryPolicy,
int completionId) |
CachePutOperation(String cacheNameWithPrefix,
Data key,
Data value,
javax.cache.expiry.ExpiryPolicy expiryPolicy,
boolean get,
int completionId) |
CacheRemoveBackupOperation(String name,
Data key) |
CacheRemoveBackupOperation(String name,
Data key,
boolean wanOriginated) |
CacheRemoveOperation(String cacheNameWithPrefix,
Data key,
Data oldValue,
int completionId) |
CacheReplaceOperation(String cacheNameWithPrefix,
Data key,
Data oldValue,
Data newValue,
javax.cache.expiry.ExpiryPolicy expiryPolicy,
int completionId) |
CacheSetExpiryPolicyBackupOperation(String name,
List<Data> keys,
Data expiryPolicy) |
CacheSetExpiryPolicyOperation(String name,
List<Data> keys,
Data expiryPolicy) |
KeyBasedCacheOperation(String name,
Data key) |
KeyBasedCacheOperation(String name,
Data key,
boolean dontCreateCacheRecordStoreIfNotExist) |
MutatingCacheOperation(String name,
Data key,
int completionId) |
Modifier and Type | Interface and Description |
---|---|
interface |
CacheRecordMap<K extends Data,V extends CacheRecord>
Contract point for storing
CacheRecord s. |
interface |
SampleableCacheRecordMap<K extends Data,V extends CacheRecord> |
Modifier and Type | Method and Description |
---|---|
<C extends EvictionCandidate<Data,CacheRecord>> |
CacheRecordHashMap.tryEvict(C evictionCandidate,
EvictionListener<Data,CacheRecord> evictionListener) |
Modifier and Type | Method and Description |
---|---|
Data |
CacheDataRecord.getExpiryPolicy() |
Data |
CacheDataRecord.getValue() |
Modifier and Type | Method and Description |
---|---|
protected CacheRecord |
CacheRecordFactory.createCacheDataRecord(Data dataValue,
long creationTime,
long expiryTime) |
protected com.hazelcast.cache.impl.record.CacheRecordHashMap.CacheEvictableSamplingEntry |
CacheRecordHashMap.createSamplingEntry(Data key,
CacheRecord value) |
CacheRecord |
CacheRecordHashMap.put(Data key,
CacheRecord value) |
CacheRecord |
CacheRecordHashMap.putIfAbsent(Data key,
CacheRecord value) |
void |
CacheDataRecord.setExpiryPolicy(Data expiryPolicy) |
void |
CacheDataRecord.setValue(Data value) |
Modifier and Type | Method and Description |
---|---|
<C extends EvictionCandidate<Data,CacheRecord>> |
CacheRecordHashMap.tryEvict(C evictionCandidate,
EvictionListener<Data,CacheRecord> evictionListener) |
Constructor and Description |
---|
CacheDataRecord(Data value,
long creationTime,
long expiryTime) |
Modifier and Type | Method and Description |
---|---|
protected Data |
ClientClusterWideIterator.toData(Object obj) |
Modifier and Type | Method and Description |
---|---|
protected Object |
NearCachedClientCacheProxy.invokeInternal(Object key,
Data epData,
Object[] arguments) |
protected <T> void |
NearCachedClientCacheProxy.onGetAndRemoveAsyncInternal(K key,
Data keyData,
ClientDelegatingFuture<T> delegatingFuture,
BiConsumer<T,Throwable> callback) |
protected void |
NearCachedClientCacheProxy.onPutIfAbsentAsyncInternal(K key,
V value,
Data keyData,
Data valueData,
ClientDelegatingFuture<Boolean> delegatingFuture,
BiConsumer<Boolean,Throwable> callback) |
protected void |
NearCachedClientCacheProxy.onPutIfAbsentSyncInternal(K key,
V value,
Data keyData,
Data valueData) |
protected void |
NearCachedClientCacheProxy.onPutSyncInternal(K key,
V value,
Data keyData,
Data valueData) |
protected void |
NearCachedClientCacheProxy.onRemoveAsyncInternal(Object key,
Data keyData,
ClientDelegatingFuture future,
BiConsumer<Object,Throwable> callback) |
void |
NearCachedClientCacheProxy.onRemoveSyncInternal(Object key,
Data keyData) |
protected <T> void |
NearCachedClientCacheProxy.onReplaceAndGetAsync(K key,
V value,
Data keyData,
Data valueData,
ClientDelegatingFuture<T> delegatingFuture,
BiConsumer<T,Throwable> callback) |
protected <T> void |
NearCachedClientCacheProxy.onReplaceInternalAsync(K key,
V value,
Data keyData,
Data valueData,
ClientDelegatingFuture<T> delegatingFuture,
BiConsumer<T,Throwable> callback) |
protected ClientDelegatingFuture<V> |
NearCachedClientCacheProxy.wrapPutAsyncFuture(K key,
V value,
Data keyData,
Data valueData,
ClientInvocationFuture invocationFuture,
BiConsumer<V,Throwable> callback) |
Modifier and Type | Method and Description |
---|---|
protected void |
NearCachedClientCacheProxy.getAllInternal(Set<? extends K> keys,
Collection<Data> dataKeys,
javax.cache.expiry.ExpiryPolicy expiryPolicy,
List<Object> resultingKeyValuePairs,
long startNanos) |
protected void |
NearCachedClientCacheProxy.loadAllInternal(Set<? extends K> keys,
List<Data> dataKeys,
boolean replaceExistingValues,
javax.cache.integration.CompletionListener completionListener) |
protected void |
ClientCacheProxy.onLoadAll(List<Data> keys,
Object response,
long startNanos) |
protected void |
NearCachedClientCacheProxy.putAllInternal(Map<? extends K,? extends V> map,
javax.cache.expiry.ExpiryPolicy expiryPolicy,
Map<Object,Data> keyMap,
List<Map.Entry<Data,Data>>[] entriesPerPartition,
long startNanos) |
protected void |
NearCachedClientCacheProxy.removeAllKeysInternal(Set<? extends K> keys,
Collection<Data> dataKeys,
long startNanos) |
Modifier and Type | Field and Description |
---|---|
Data |
MapAggregateCodec.RequestParameters.aggregator
aggregator to aggregate the entries with
|
Data |
MapAggregateWithPredicateCodec.RequestParameters.aggregator
aggregator to aggregate the entries with
|
Data |
ExecutorServiceSubmitToAddressCodec.RequestParameters.callable
The callable object to be executed.
|
Data |
DurableExecutorSubmitToPartitionCodec.RequestParameters.callable
The callable object to be executed.
|
Data |
ExecutorServiceSubmitToPartitionCodec.RequestParameters.callable
The callable object to be executed.
|
Data |
ClientAuthenticationCustomCodec.RequestParameters.credentials
Secret byte array for authentication.
|
Data |
CacheRemoveCodec.RequestParameters.currentValue
value expected to be associated with the specified key.
|
Data |
MapExecuteWithPredicateCodec.RequestParameters.entryProcessor
entry processor to be executed.
|
Data |
MapSubmitToKeyCodec.RequestParameters.entryProcessor
entry processor to be executed on the entry.
|
Data |
CacheEntryProcessorCodec.RequestParameters.entryProcessor
Entry processor to invoke.
|
Data |
MapExecuteOnKeysCodec.RequestParameters.entryProcessor
entry processor to be executed.
|
Data |
MapExecuteOnAllKeysCodec.RequestParameters.entryProcessor
entry processor to be executed.
|
Data |
MapExecuteOnKeyCodec.RequestParameters.entryProcessor
processor to execute on the map entry
|
Data |
DynamicConfigAddReliableTopicConfigCodec.RequestParameters.executor
a serialized
Executor instance to use for executing
message listeners or null |
Data |
CacheGetAllCodec.RequestParameters.expiryPolicy
Expiry policy for the entry.
|
Data |
CachePutCodec.RequestParameters.expiryPolicy
Expiry policy for the entry.
|
Data |
CacheGetCodec.RequestParameters.expiryPolicy
Expiry policy for the entry.
|
Data |
CacheSetExpiryPolicyCodec.RequestParameters.expiryPolicy
custom expiry policy for this operation
|
Data |
CachePutAllCodec.RequestParameters.expiryPolicy
expiry policy for the entry.
|
Data |
CacheGetAndReplaceCodec.RequestParameters.expiryPolicy
Expiry policy for the entry.
|
Data |
CacheReplaceCodec.RequestParameters.expiryPolicy
Expiry policy for the entry.
|
Data |
CachePutIfAbsentCodec.RequestParameters.expiryPolicy
The custom expiry policy for this operation.
|
Data |
RingbufferReadManyCodec.RequestParameters.filter
Filter is allowed to be null, indicating there is no filter.
|
Data |
AtomicLongAlterCodec.RequestParameters.function
The function applied to the currently stored value.
|
Data |
AtomicRefApplyCodec.RequestParameters.function
The function applied to the value.
|
Data |
AtomicLongApplyCodec.RequestParameters.function
The function applied to the value and the value is not
changed.
|
Data |
MapAddInterceptorCodec.RequestParameters.interceptor
interceptor to add
|
Data |
TransactionalSetRemoveCodec.RequestParameters.item
Item removed from Transactional Set
|
Data |
TransactionalListAddCodec.RequestParameters.item
The new item added to the transactionalList
|
Data |
TransactionalSetAddCodec.RequestParameters.item
Item added to transactional set
|
Data |
TransactionalQueueOfferCodec.RequestParameters.item
The element to add
|
Data |
TransactionalListRemoveCodec.RequestParameters.item
Item to remove to transactional List
|
Data |
TransactionalMapReplaceIfSameCodec.RequestParameters.key
The specified key.
|
Data |
TransactionalMultiMapGetCodec.RequestParameters.key
The key whose associated values are returned
|
Data |
TransactionalMapReplaceCodec.RequestParameters.key
The specified key
|
Data |
MultiMapContainsEntryCodec.RequestParameters.key
The key whose existence is checked.
|
Data |
TransactionalMapRemoveIfSameCodec.RequestParameters.key
The specified key
|
Data |
MapForceUnlockCodec.RequestParameters.key
the key of the map entry.
|
Data |
ReplicatedMapPutCodec.RequestParameters.key
Key with which the specified value is to be associated.
|
Data |
CachePutCodec.RequestParameters.key
The key that has the specified value associated with it.
|
Data |
MapSetWithMaxIdleCodec.RequestParameters.key
Key for the map entry.
|
Data |
MultiMapUnlockCodec.RequestParameters.key
The key to Lock
|
Data |
TransactionalMultiMapRemoveCodec.RequestParameters.key
The key whose associated values are returned
|
Data |
TransactionalMapGetForUpdateCodec.RequestParameters.key
The value to which the specified key is mapped
|
Data |
ReplicatedMapAddEntryListenerToKeyWithPredicateCodec.RequestParameters.key
Key with which the specified value is to be associated.
|
Data |
MultiMapForceUnlockCodec.RequestParameters.key
The key to Lock
|
Data |
MapAddEntryListenerToKeyCodec.RequestParameters.key
Key for the map entry.
|
Data |
ReplicatedMapRemoveCodec.RequestParameters.key
Key with which the specified value is to be associated.
|
Data |
TransactionalMapRemoveCodec.RequestParameters.key
Remove the mapping for this key.
|
Data |
MapGetEntryViewCodec.RequestParameters.key
the key of the entry.
|
Data |
MapLockCodec.RequestParameters.key
Key for the map entry.
|
Data |
MapPutTransientWithMaxIdleCodec.RequestParameters.key
Key for the map entry.
|
Data |
MapSubmitToKeyCodec.RequestParameters.key
the key of the map entry.
|
Data |
CacheEntryProcessorCodec.RequestParameters.key
the key to the entry
|
Data |
MapRemoveCodec.RequestParameters.key
Key for the map entry.
|
Data |
TransactionalMapContainsKeyCodec.RequestParameters.key
The specified key.
|
Data |
TransactionalMultiMapRemoveEntryCodec.RequestParameters.key
The key whose associated values are returned
|
Data |
MapGetCodec.RequestParameters.key
Key for the map entry.
|
Data |
MapPutTransientCodec.RequestParameters.key
Key for the map entry.
|
Data |
ReplicatedMapContainsKeyCodec.RequestParameters.key
The key whose associated value is to be returned.
|
Data |
MapTryRemoveCodec.RequestParameters.key
Key for the map entry.
|
Data |
MultiMapDeleteCodec.RequestParameters.key
The key of the entry to remove
|
Data |
CacheGetCodec.RequestParameters.key
The key whose mapped value is to be returned.
|
Data |
MapEvictCodec.RequestParameters.key
the specified key to evict from this map.
|
Data |
TransactionalMapDeleteCodec.RequestParameters.key
Remove the mapping for this key.
|
Data |
MultiMapPutCodec.RequestParameters.key
The key to be stored
|
Data |
TransactionalMapPutIfAbsentCodec.RequestParameters.key
The specified key
|
Data |
MapTryPutCodec.RequestParameters.key
Key for the map entry.
|
Data |
MapReplaceIfSameCodec.RequestParameters.key
Key for the map entry.
|
Data |
MultiMapLockCodec.RequestParameters.key
The key the Lock
|
Data |
CacheContainsKeyCodec.RequestParameters.key
The key whose presence in this cache is to be tested.
|
Data |
CacheRemoveCodec.RequestParameters.key
key whose mapping is to be removed from the cache
|
Data |
MapContainsKeyCodec.RequestParameters.key
Key for the map entry.
|
Data |
MultiMapRemoveEntryCodec.RequestParameters.key
The key of the entry to remove
|
Data |
TransactionalMapSetCodec.RequestParameters.key
The specified key
|
Data |
MapSetCodec.RequestParameters.key
Key for the map entry.
|
Data |
MapPutIfAbsentWithMaxIdleCodec.RequestParameters.key
Key for the map entry.
|
Data |
ReplicatedMapGetCodec.RequestParameters.key
The key whose associated value is to be returned
|
Data |
MapAddEntryListenerToKeyWithPredicateCodec.RequestParameters.key
Key for the map entry.
|
Data |
MapSetTtlCodec.RequestParameters.key
Key for the map entry
|
Data |
MultiMapRemoveCodec.RequestParameters.key
The key of the entry to remove
|
Data |
MultiMapContainsKeyCodec.RequestParameters.key
The key whose existence is checked.
|
Data |
CacheGetAndReplaceCodec.RequestParameters.key
The key whose value is replaced.
|
Data |
ReplicatedMapAddEntryListenerToKeyCodec.RequestParameters.key
Key with which the specified value is to be associated.
|
Data |
TransactionalMapPutCodec.RequestParameters.key
The specified key
|
Data |
MapRemoveIfSameCodec.RequestParameters.key
Key for the map entry.
|
Data |
MapExecuteOnKeyCodec.RequestParameters.key
the key of the map entry.
|
Data |
MultiMapGetCodec.RequestParameters.key
The key whose associated values are to be returned
|
Data |
CacheReplaceCodec.RequestParameters.key
The key whose value is replaced.
|
Data |
CacheGetAndRemoveCodec.RequestParameters.key
key with which the specified value is associated
|
Data |
MultiMapAddEntryListenerToKeyCodec.RequestParameters.key
The key to listen to
|
Data |
MapPutWithMaxIdleCodec.RequestParameters.key
Key for the map entry.
|
Data |
MapReplaceCodec.RequestParameters.key
Key for the map entry.
|
Data |
MapPutCodec.RequestParameters.key
Key for the map entry.
|
Data |
MapIsLockedCodec.RequestParameters.key
Key for the map entry to check if it is locked.
|
Data |
MultiMapValueCountCodec.RequestParameters.key
The key whose values count is to be returned
|
Data |
TransactionalMultiMapPutCodec.RequestParameters.key
The key to be stored
|
Data |
MultiMapIsLockedCodec.RequestParameters.key
Key to lock to be checked.
|
Data |
MapDeleteCodec.RequestParameters.key
Key for the map entry.
|
Data |
MapUnlockCodec.RequestParameters.key
Key for the map entry to unlock
|
Data |
TransactionalMapGetCodec.RequestParameters.key
The specified key
|
Data |
TransactionalMultiMapValueCountCodec.RequestParameters.key
The key whose number of values are returned
|
Data |
MultiMapTryLockCodec.RequestParameters.key
Key to lock in this map.
|
Data |
MapTryLockCodec.RequestParameters.key
Key for the map entry.
|
Data |
MapPutIfAbsentCodec.RequestParameters.key
Key for the map entry.
|
Data |
CachePutIfAbsentCodec.RequestParameters.key
The key that is associated with the specified value.
|
Data |
CacheListenerRegistrationCodec.RequestParameters.listenerConfig
The listener configuration.
|
Data |
DynamicConfigAddMapConfigCodec.RequestParameters.mapEvictionPolicy
custom
com.hazelcast.map.eviction.MapEvictionPolicy implementation
or null |
Data |
TopicPublishCodec.RequestParameters.message
The message to publish to all subscribers of this topic
|
Data |
TransactionalMapReplaceIfSameCodec.RequestParameters.newValue
The new value to replace the old value.
|
Data |
AtomicRefSetCodec.RequestParameters.newValue
The value to set
|
Data |
AtomicRefCompareAndSetCodec.RequestParameters.newValue
The new value
|
Data |
CacheReplaceCodec.RequestParameters.newValue
The new value to be associated with the specified key.
|
Data |
TransactionalMapReplaceIfSameCodec.RequestParameters.oldValue
Replace the key value if it is the old value.
|
Data |
AtomicRefCompareAndSetCodec.RequestParameters.oldValue
The expected value
|
Data |
CacheReplaceCodec.RequestParameters.oldValue
Old value to match if exists before removing.
|
Data |
DynamicConfigAddMapConfigCodec.RequestParameters.partitioningStrategyImplementation
a serialized instance of a partitioning strategy
|
Data |
MapEntriesWithPagingPredicateCodec.RequestParameters.predicate
specified query criteria.
|
Data |
MapExecuteWithPredicateCodec.RequestParameters.predicate
specified query criteria.
|
Data |
MapValuesWithPagingPredicateCodec.RequestParameters.predicate
specified query criteria.
|
Data |
ReplicatedMapAddEntryListenerToKeyWithPredicateCodec.RequestParameters.predicate
The predicate for filtering entries
|
Data |
ReplicatedMapAddEntryListenerWithPredicateCodec.RequestParameters.predicate
The predicate for filtering entries
|
Data |
MapFetchWithQueryCodec.RequestParameters.predicate
predicate to filter the entries with
|
Data |
MapAggregateWithPredicateCodec.RequestParameters.predicate
predicate to filter the entries with
|
Data |
CacheEventJournalReadCodec.RequestParameters.predicate
the predicate to apply before processing events
|
Data |
MapValuesWithPredicateCodec.RequestParameters.predicate
specified query criteria.
|
Data |
TransactionalMapKeySetWithPredicateCodec.RequestParameters.predicate
Specified query criteria.
|
Data |
MapAddEntryListenerWithPredicateCodec.RequestParameters.predicate
predicate for filtering entries.
|
Data |
MapKeySetWithPredicateCodec.RequestParameters.predicate
specified query criteria.
|
Data |
MapRemoveAllCodec.RequestParameters.predicate
used to select entries to be removed from map.
|
Data |
MapEntriesWithPredicateCodec.RequestParameters.predicate
specified query criteria.
|
Data |
MapEventJournalReadCodec.RequestParameters.predicate
the predicate to apply before processing events
|
Data |
MapAddEntryListenerToKeyWithPredicateCodec.RequestParameters.predicate
predicate for filtering entries.
|
Data |
MapProjectWithPredicateCodec.RequestParameters.predicate
predicate to filter the entries with
|
Data |
TransactionalMapValuesWithPredicateCodec.RequestParameters.predicate
Specified query criteria.
|
Data |
MapKeySetWithPagingPredicateCodec.RequestParameters.predicate
specified query criteria.
|
Data |
ContinuousQueryPublisherCreateCodec.RequestParameters.predicate
The predicate to filter events which will be applied to the QueryCache.
|
Data |
ContinuousQueryPublisherCreateWithValueCodec.RequestParameters.predicate
The predicate to filter events which will be applied to the QueryCache.
|
Data |
MapFetchWithQueryCodec.RequestParameters.projection
projection to transform the entries with
|
Data |
MapProjectCodec.RequestParameters.projection
projection to transform the entries with.
|
Data |
CacheEventJournalReadCodec.RequestParameters.projection
the projection to apply to journal events
|
Data |
MapEventJournalReadCodec.RequestParameters.projection
the projection to apply to journal events
|
Data |
MapProjectWithPredicateCodec.RequestParameters.projection
projection to transform the entries with.
|
Data |
TransactionalMapReplaceCodec.ResponseParameters.response
The previous value associated with key, or null if there was no mapping for key.
|
Data |
ListGetCodec.ResponseParameters.response
The element at the specified position in this list
|
Data |
MapAggregateCodec.ResponseParameters.response
the aggregation result
|
Data |
ReplicatedMapPutCodec.ResponseParameters.response
The old value if existed for the key.
|
Data |
CachePutCodec.ResponseParameters.response
The value previously assigned to the given key, or null if not assigned.
|
Data |
MapSetWithMaxIdleCodec.ResponseParameters.response
old value of the entry
|
Data |
DurableExecutorRetrieveResultCodec.ResponseParameters.response
The result of the callable execution with the given sequence.
|
Data |
TransactionalMapGetForUpdateCodec.ResponseParameters.response
The value for the specified key
|
Data |
MapAggregateWithPredicateCodec.ResponseParameters.response
the aggregation result
|
Data |
TransactionalQueueTakeCodec.ResponseParameters.response
The head of this queue
|
Data |
AtomicRefSetCodec.ResponseParameters.response
the old value or null, depending on
the {
|
Data |
ReplicatedMapRemoveCodec.ResponseParameters.response
the previous value associated with key, or null if there was no mapping for key.
|
Data |
AtomicRefGetCodec.ResponseParameters.response
The current value
|
Data |
TransactionalMapRemoveCodec.ResponseParameters.response
The previous value associated with key, or null if there was no mapping for key
|
Data |
MapPutTransientWithMaxIdleCodec.ResponseParameters.response
old value of the entry
|
Data |
MapSubmitToKeyCodec.ResponseParameters.response
result of entry process.
|
Data |
CacheEntryProcessorCodec.ResponseParameters.response
the result of the processing, if any, defined by the EntryProcessor implementation
|
Data |
QueueTakeCodec.ResponseParameters.response
The head of this queue
|
Data |
MapRemoveCodec.ResponseParameters.response
Clone of the removed value, not the original (identically equal) value previously put into the map.
|
Data |
QueuePollCodec.ResponseParameters.response
The head of this queue, or null if this queue is empty
|
Data |
MapGetCodec.ResponseParameters.response
The value for the key if exists
|
Data |
CacheGetCodec.ResponseParameters.response
The value assigned to the given key, or null if not assigned.
|
Data |
TransactionalMapPutIfAbsentCodec.ResponseParameters.response
The previous value associated with key, or null if there was no mapping for key.
|
Data |
ScheduledExecutorGetResultFromPartitionCodec.ResponseParameters.response
The result of the completed task, in serialized form ({
|
Data |
MapPutIfAbsentWithMaxIdleCodec.ResponseParameters.response
old value of the entry
|
Data |
ReplicatedMapGetCodec.ResponseParameters.response
The value to which the specified key is mapped, or null if this map contains no mapping for the key
|
Data |
TransactionalQueuePollCodec.ResponseParameters.response
The head of this queue, or null if the specified waiting time elapses before an element is available
|
Data |
ListRemoveWithIndexCodec.ResponseParameters.response
The element previously at the specified position
|
Data |
ExecutorServiceSubmitToAddressCodec.ResponseParameters.response
The result of the callable execution.
|
Data |
ScheduledExecutorGetResultFromAddressCodec.ResponseParameters.response
The result of the completed task, in serialized form ({
|
Data |
ExecutorServiceSubmitToPartitionCodec.ResponseParameters.response
The result of the callable execution.
|
Data |
RingbufferReadOneCodec.ResponseParameters.response
the read item
|
Data |
CacheGetAndReplaceCodec.ResponseParameters.response
The old value previously assigned to the given key.
|
Data |
QueuePeekCodec.ResponseParameters.response
The head of this queue, or null if this queue is empty
|
Data |
TransactionalMapPutCodec.ResponseParameters.response
Previous value associated with key or null if there was no mapping for key
|
Data |
MapExecuteOnKeyCodec.ResponseParameters.response
result of entry process.
|
Data |
CacheReplaceCodec.ResponseParameters.response
The replaced value.
|
Data |
TransactionalQueuePeekCodec.ResponseParameters.response
The value at the head of the queue.
|
Data |
CacheGetAndRemoveCodec.ResponseParameters.response
the value if one existed or null if no mapping existed for this key
|
Data |
AtomicRefApplyCodec.ResponseParameters.response
The result of the function application.
|
Data |
MapPutWithMaxIdleCodec.ResponseParameters.response
old value of the entry
|
Data |
MapReplaceCodec.ResponseParameters.response
Clone of the previous value, not the original (identically equal) value previously put into the map.
|
Data |
ListSetCodec.ResponseParameters.response
The element previously at the specified position
|
Data |
MapPutCodec.ResponseParameters.response
old value of the entry
|
Data |
AtomicLongApplyCodec.ResponseParameters.response
The result of the function application.
|
Data |
TransactionalMapGetCodec.ResponseParameters.response
The value for the specified key
|
Data |
MapPutIfAbsentCodec.ResponseParameters.response
returns a clone of the previous value, not the original (identically equal) value previously put into the map.
|
Data |
DurableExecutorRetrieveAndDisposeResultCodec.ResponseParameters.response
The result of the callable execution with the given sequence.
|
Data |
ScheduledExecutorSubmitToAddressCodec.RequestParameters.task
Name The name of the task
|
Data |
ScheduledExecutorSubmitToPartitionCodec.RequestParameters.task
Name The name of the task
|
Data |
MapReplaceIfSameCodec.RequestParameters.testValue
Test the existing value against this value to find if equal to this value.
|
Data |
TransactionalMapContainsValueCodec.RequestParameters.value
The specified value.
|
Data |
TransactionalMapReplaceCodec.RequestParameters.value
The value replaced the previous value
|
Data |
MultiMapContainsEntryCodec.RequestParameters.value
The value whose existence is checked.
|
Data |
TransactionalMapRemoveIfSameCodec.RequestParameters.value
Remove the key if it has this value.
|
Data |
ListAddWithIndexCodec.RequestParameters.value
Value to be inserted.
|
Data |
QueueContainsCodec.RequestParameters.value
Element whose presence in this collection is to be tested
|
Data |
ReplicatedMapPutCodec.RequestParameters.value
Value to be associated with the specified key
|
Data |
CachePutCodec.RequestParameters.value
The value to be associated with the key.
|
Data |
MapSetWithMaxIdleCodec.RequestParameters.value
Value for the map entry.
|
Data |
ListLastIndexOfCodec.RequestParameters.value
Element to search for
|
Data |
MapContainsValueCodec.RequestParameters.value
Value to check if exists in the map.
|
Data |
RingbufferAddCodec.RequestParameters.value
to item to add
|
Data |
MapPutTransientWithMaxIdleCodec.RequestParameters.value
Value for the map entry.
|
Data |
AtomicRefContainsCodec.RequestParameters.value
The value to check (is allowed to be null).
|
Data |
TransactionalMultiMapRemoveEntryCodec.RequestParameters.value
The value to be stored
|
Data |
MultiMapContainsValueCodec.RequestParameters.value
The value whose existence is checked.
|
Data |
MapPutTransientCodec.RequestParameters.value
New value for the map entry.
|
Data |
SetAddCodec.RequestParameters.value
Element to be added to this set
|
Data |
QueueRemoveCodec.RequestParameters.value
Element to be removed from this queue, if present
|
Data |
MultiMapPutCodec.RequestParameters.value
The value to be stored
|
Data |
TransactionalMapPutIfAbsentCodec.RequestParameters.value
The value to associate with the key when there is no previous value.
|
Data |
ListAddCodec.RequestParameters.value
Element to be appended to this list
|
Data |
MapTryPutCodec.RequestParameters.value
New value for the map entry.
|
Data |
QueuePutCodec.RequestParameters.value
The element to add
|
Data |
MapReplaceIfSameCodec.RequestParameters.value
New value for the map entry.
|
Data |
ReplicatedMapContainsValueCodec.RequestParameters.value
value whose presence in this map is to be tested
|
Data |
QueueOfferCodec.RequestParameters.value
The element to add
|
Data |
ListContainsCodec.RequestParameters.value
Element whose presence in this list is to be tested
|
Data |
MultiMapRemoveEntryCodec.RequestParameters.value
The value of the entry to remove
|
Data |
TransactionalMapSetCodec.RequestParameters.value
The value to associate with key
|
Data |
MapSetCodec.RequestParameters.value
New value for the map entry.
|
Data |
MapPutIfAbsentWithMaxIdleCodec.RequestParameters.value
Value for the map entry.
|
Data |
SetRemoveCodec.RequestParameters.value
Object to be removed from this set, if present
|
Data |
CacheGetAndReplaceCodec.RequestParameters.value
The new value to be associated with the specified key.
|
Data |
ListIndexOfCodec.RequestParameters.value
Element to search for
|
Data |
TransactionalMapPutCodec.RequestParameters.value
The value to associate with the key.
|
Data |
MapRemoveIfSameCodec.RequestParameters.value
Test the existing value against this value to find if equal to this value.
|
Data |
ListRemoveCodec.RequestParameters.value
Element to be removed from this list, if present
|
Data |
MapPutWithMaxIdleCodec.RequestParameters.value
Value for the map entry.
|
Data |
MapReplaceCodec.RequestParameters.value
New value for the map entry.
|
Data |
ListSetCodec.RequestParameters.value
Element to be stored at the specified position
|
Data |
MapPutCodec.RequestParameters.value
Value for the map entry.
|
Data |
TransactionalMultiMapPutCodec.RequestParameters.value
The value to be stored
|
Data |
MapPutIfAbsentCodec.RequestParameters.value
New value for the map entry.
|
Data |
SetContainsCodec.RequestParameters.value
Element whose presence in this set is to be tested
|
Data |
CachePutIfAbsentCodec.RequestParameters.value
The value that has the specified key associated with it.
|
Modifier and Type | Field and Description |
---|---|
List<Data> |
CacheEntryProcessorCodec.RequestParameters.arguments
additional arguments to pass to the EntryProcessor
|
List<Data> |
QueueCompareAndRetainAllCodec.RequestParameters.dataList
collection containing elements to be retained in this collection
|
List<Data> |
QueueCompareAndRemoveAllCodec.RequestParameters.dataList
Collection containing elements to be removed from this collection
|
List<Data> |
QueueContainsAllCodec.RequestParameters.dataList
Collection to be checked for containment in this collection
|
List<Data> |
QueueAddAllCodec.RequestParameters.dataList
Collection containing elements to be added to this collection
|
List<Map.Entry<Data,Data>> |
CacheIterateEntriesCodec.ResponseParameters.entries
TODO DOC
|
List<Map.Entry<Data,Data>> |
CacheIterateEntriesCodec.ResponseParameters.entries
TODO DOC
|
List<Map.Entry<Data,Data>> |
MapPutAllCodec.RequestParameters.entries
mappings to be stored in this map
|
List<Map.Entry<Data,Data>> |
MapPutAllCodec.RequestParameters.entries
mappings to be stored in this map
|
List<Map.Entry<Data,Data>> |
ReplicatedMapPutAllCodec.RequestParameters.entries
entries to be stored in this map
|
List<Map.Entry<Data,Data>> |
ReplicatedMapPutAllCodec.RequestParameters.entries
entries to be stored in this map
|
List<Map.Entry<Data,Data>> |
CachePutAllCodec.RequestParameters.entries
entries to be put as batch
|
List<Map.Entry<Data,Data>> |
CachePutAllCodec.RequestParameters.entries
entries to be put as batch
|
List<Map.Entry<Data,Data>> |
MapFetchEntriesCodec.ResponseParameters.entries
TODO DOC
|
List<Map.Entry<Data,Data>> |
MapFetchEntriesCodec.ResponseParameters.entries
TODO DOC
|
List<Data> |
CacheEventJournalReadCodec.ResponseParameters.items
TODO DOC
|
List<Data> |
SetContainsAllCodec.RequestParameters.items
Collection to be checked for containment in this list
|
List<Data> |
RingbufferReadManyCodec.ResponseParameters.items
TODO DOC
|
List<Data> |
MapEventJournalReadCodec.ResponseParameters.items
TODO DOC
|
List<Data> |
CacheIterateCodec.ResponseParameters.keys
TODO DOC
|
List<Data> |
CacheGetAllCodec.RequestParameters.keys
The keys whose associated values are to be returned.
|
List<Data> |
CacheSetExpiryPolicyCodec.RequestParameters.keys
The keys that are associated with the specified expiry policy.
|
List<Data> |
MapFetchKeysCodec.ResponseParameters.keys
TODO DOC
|
List<Data> |
MapExecuteOnKeysCodec.RequestParameters.keys
The keys for the entries for which the entry processor shall be executed on.
|
List<Data> |
MapLoadGivenKeysCodec.RequestParameters.keys
keys to load
|
List<Data> |
CacheRemoveAllKeysCodec.RequestParameters.keys
The keys to remove.
|
List<Data> |
MapGetAllCodec.RequestParameters.keys
keys to get
|
List<Data> |
CacheLoadAllCodec.RequestParameters.keys
the keys to load
|
List<Data> |
TransactionalMultiMapGetCodec.ResponseParameters.response
The collection of the values associated with the key
|
List<Map.Entry<Data,Data>> |
MapEntriesWithPagingPredicateCodec.ResponseParameters.response
key-value pairs for the query.
|
List<Map.Entry<Data,Data>> |
MapEntriesWithPagingPredicateCodec.ResponseParameters.response
key-value pairs for the query.
|
List<Map.Entry<Data,Data>> |
MapExecuteWithPredicateCodec.ResponseParameters.response
results of entry process on the entries matching the query criteria
|
List<Map.Entry<Data,Data>> |
MapExecuteWithPredicateCodec.ResponseParameters.response
results of entry process on the entries matching the query criteria
|
List<Data> |
QueueDrainToMaxSizeCodec.ResponseParameters.response
list of all removed data in result of this method
|
List<Map.Entry<Data,Data>> |
CacheGetAllCodec.ResponseParameters.response
A map of entries that were found for the given keys.
|
List<Map.Entry<Data,Data>> |
CacheGetAllCodec.ResponseParameters.response
A map of entries that were found for the given keys.
|
List<Map.Entry<Data,Data>> |
MapValuesWithPagingPredicateCodec.ResponseParameters.response
values for the query.
|
List<Map.Entry<Data,Data>> |
MapValuesWithPagingPredicateCodec.ResponseParameters.response
values for the query.
|
List<Data> |
TransactionalMultiMapRemoveCodec.ResponseParameters.response
True if the size of the multimap changed after the remove operation, false otherwise.
|
List<Data> |
MapProjectCodec.ResponseParameters.response
the resulted collection upon transformation to the type of the projection
|
SimpleEntryView<Data,Data> |
MapGetEntryViewCodec.ResponseParameters.response
TODO DOC
|
SimpleEntryView<Data,Data> |
MapGetEntryViewCodec.ResponseParameters.response
TODO DOC
|
List<Data> |
MapValuesWithPredicateCodec.ResponseParameters.response
result value collection of the query.
|
List<Data> |
TransactionalMapKeySetWithPredicateCodec.ResponseParameters.response
Result key set for the query.
|
List<Data> |
SetGetAllCodec.ResponseParameters.response
Array of all values in the Set
|
List<Map.Entry<Data,Data>> |
MultiMapEntrySetCodec.ResponseParameters.response
The set of key-value pairs in the multimap.
|
List<Map.Entry<Data,Data>> |
MultiMapEntrySetCodec.ResponseParameters.response
The set of key-value pairs in the multimap.
|
List<Data> |
MultiMapValuesCodec.ResponseParameters.response
The collection of values in the multimap.
|
List<Data> |
ListListIteratorCodec.ResponseParameters.response
a list iterator over the elements in this list (in proper
sequence), starting at the specified position in the list
|
List<Data> |
ListSubCodec.ResponseParameters.response
A view of the specified range within this list
|
List<Data> |
QueueIteratorCodec.ResponseParameters.response
list of all data in queue
|
List<Data> |
TransactionalMapKeySetCodec.ResponseParameters.response
A set clone of the keys contained in this map.
|
List<Data> |
MapKeySetWithPredicateCodec.ResponseParameters.response
result key set for the query.
|
List<Data> |
MapKeySetCodec.ResponseParameters.response
a set clone of the keys contained in this map.
|
List<Map.Entry<Data,Data>> |
MapEntriesWithPredicateCodec.ResponseParameters.response
result key-value entry collection of the query.
|
List<Map.Entry<Data,Data>> |
MapEntriesWithPredicateCodec.ResponseParameters.response
result key-value entry collection of the query.
|
List<Map.Entry<Data,Data>> |
MapEntrySetCodec.ResponseParameters.response
a set clone of the keys mappings in this map
|
List<Map.Entry<Data,Data>> |
MapEntrySetCodec.ResponseParameters.response
a set clone of the keys mappings in this map
|
List<Data> |
MapValuesCodec.ResponseParameters.response
All values in the map
|
List<Map.Entry<Data,Data>> |
MapExecuteOnKeysCodec.ResponseParameters.response
results of entry process on the entries with the provided keys
|
List<Map.Entry<Data,Data>> |
MapExecuteOnKeysCodec.ResponseParameters.response
results of entry process on the entries with the provided keys
|
List<Map.Entry<Data,Data>> |
MapExecuteOnAllKeysCodec.ResponseParameters.response
results of entry process on the entries
|
List<Map.Entry<Data,Data>> |
MapExecuteOnAllKeysCodec.ResponseParameters.response
results of entry process on the entries
|
List<Data> |
QueueDrainToCodec.ResponseParameters.response
list of all removed data in queue
|
List<Data> |
MultiMapRemoveCodec.ResponseParameters.response
True if the size of the multimap changed after the remove operation, false otherwise.
|
List<Data> |
MapProjectWithPredicateCodec.ResponseParameters.response
the resulted collection upon transformation to the type of the projection
|
List<Data> |
ListIteratorCodec.ResponseParameters.response
An iterator over the elements in this list in proper sequence
|
List<Map.Entry<Data,Data>> |
MapGetAllCodec.ResponseParameters.response
values for the provided keys.
|
List<Map.Entry<Data,Data>> |
MapGetAllCodec.ResponseParameters.response
values for the provided keys.
|
List<Data> |
TransactionalMapValuesWithPredicateCodec.ResponseParameters.response
Result value collection of the query.
|
List<Data> |
MultiMapGetCodec.ResponseParameters.response
The collection of the values associated with the key.
|
List<Data> |
MapKeySetWithPagingPredicateCodec.ResponseParameters.response
result keys for the query.
|
List<Data> |
ContinuousQueryPublisherCreateCodec.ResponseParameters.response
Array of keys.
|
List<Data> |
TransactionalMapValuesCodec.ResponseParameters.response
All values in the map
|
List<Data> |
ReplicatedMapKeySetCodec.ResponseParameters.response
A lazy set view of the keys contained in this map.
|
List<Data> |
ListGetAllCodec.ResponseParameters.response
An array of all item values in the list.
|
List<Map.Entry<Data,Data>> |
ContinuousQueryPublisherCreateWithValueCodec.ResponseParameters.response
Array of key-value pairs.
|
List<Map.Entry<Data,Data>> |
ContinuousQueryPublisherCreateWithValueCodec.ResponseParameters.response
Array of key-value pairs.
|
List<Data> |
ReplicatedMapValuesCodec.ResponseParameters.response
A collection view of the values contained in this map.
|
List<Map.Entry<Data,Data>> |
ReplicatedMapEntrySetCodec.ResponseParameters.response
A lazy set view of the mappings contained in this map.
|
List<Map.Entry<Data,Data>> |
ReplicatedMapEntrySetCodec.ResponseParameters.response
A lazy set view of the mappings contained in this map.
|
List<Data> |
MultiMapKeySetCodec.ResponseParameters.response
The set of keys in the multimap.
|
List<Data> |
MapFetchWithQueryCodec.ResponseParameters.results
TODO DOC
|
List<Data> |
RingbufferAddAllCodec.RequestParameters.valueList
the batch of items to add
|
List<Data> |
ListAddAllCodec.RequestParameters.valueList
Collection containing elements to be added to this list
|
List<Data> |
ListAddAllWithIndexCodec.RequestParameters.valueList
The list of value to insert into the list.
|
List<Data> |
SetAddAllCodec.RequestParameters.valueList
Collection containing elements to be added to this set
|
List<Data> |
ListContainsAllCodec.RequestParameters.values
Collection to be checked for containment in this list
|
List<Data> |
SetCompareAndRemoveAllCodec.RequestParameters.values
The list of values to test for matching the item to remove.
|
List<Data> |
SetCompareAndRetainAllCodec.RequestParameters.values
The list of values to test for matching the item to retain.
|
List<Data> |
ListCompareAndRemoveAllCodec.RequestParameters.values
The list of values to compare for removal.
|
List<Data> |
ListCompareAndRetainAllCodec.RequestParameters.values
The list of values to compare for retaining.
|
Modifier and Type | Method and Description |
---|---|
static ClientMessage |
CacheAddInvalidationListenerCodec.encodeCacheInvalidationEvent(String name,
Data key,
UUID sourceUuid,
UUID partitionUuid,
long sequence) |
static ClientMessage |
CacheAddNearCacheInvalidationListenerCodec.encodeCacheInvalidationEvent(String name,
Data key,
UUID sourceUuid,
UUID partitionUuid,
long sequence) |
static ClientMessage |
ReplicatedMapAddEntryListenerToKeyWithPredicateCodec.encodeEntryEvent(Data key,
Data value,
Data oldValue,
Data mergingValue,
int eventType,
UUID uuid,
int numberOfAffectedEntries) |
static ClientMessage |
ReplicatedMapAddEntryListenerWithPredicateCodec.encodeEntryEvent(Data key,
Data value,
Data oldValue,
Data mergingValue,
int eventType,
UUID uuid,
int numberOfAffectedEntries) |
static ClientMessage |
MapAddEntryListenerToKeyCodec.encodeEntryEvent(Data key,
Data value,
Data oldValue,
Data mergingValue,
int eventType,
UUID uuid,
int numberOfAffectedEntries) |
static ClientMessage |
MultiMapAddEntryListenerCodec.encodeEntryEvent(Data key,
Data value,
Data oldValue,
Data mergingValue,
int eventType,
UUID uuid,
int numberOfAffectedEntries) |
static ClientMessage |
ReplicatedMapAddNearCacheEntryListenerCodec.encodeEntryEvent(Data key,
Data value,
Data oldValue,
Data mergingValue,
int eventType,
UUID uuid,
int numberOfAffectedEntries) |
static ClientMessage |
MapAddEntryListenerCodec.encodeEntryEvent(Data key,
Data value,
Data oldValue,
Data mergingValue,
int eventType,
UUID uuid,
int numberOfAffectedEntries) |
static ClientMessage |
MapAddEntryListenerWithPredicateCodec.encodeEntryEvent(Data key,
Data value,
Data oldValue,
Data mergingValue,
int eventType,
UUID uuid,
int numberOfAffectedEntries) |
static ClientMessage |
MapAddEntryListenerToKeyWithPredicateCodec.encodeEntryEvent(Data key,
Data value,
Data oldValue,
Data mergingValue,
int eventType,
UUID uuid,
int numberOfAffectedEntries) |
static ClientMessage |
ReplicatedMapAddEntryListenerToKeyCodec.encodeEntryEvent(Data key,
Data value,
Data oldValue,
Data mergingValue,
int eventType,
UUID uuid,
int numberOfAffectedEntries) |
static ClientMessage |
MultiMapAddEntryListenerToKeyCodec.encodeEntryEvent(Data key,
Data value,
Data oldValue,
Data mergingValue,
int eventType,
UUID uuid,
int numberOfAffectedEntries) |
static ClientMessage |
ReplicatedMapAddEntryListenerCodec.encodeEntryEvent(Data key,
Data value,
Data oldValue,
Data mergingValue,
int eventType,
UUID uuid,
int numberOfAffectedEntries) |
static ClientMessage |
MapAddNearCacheEntryListenerCodec.encodeIMapInvalidationEvent(Data key,
UUID sourceUuid,
UUID partitionUuid,
long sequence) |
static ClientMessage |
MapAddNearCacheInvalidationListenerCodec.encodeIMapInvalidationEvent(Data key,
UUID sourceUuid,
UUID partitionUuid,
long sequence) |
static ClientMessage |
ListAddListenerCodec.encodeItemEvent(Data item,
UUID uuid,
int eventType) |
static ClientMessage |
QueueAddListenerCodec.encodeItemEvent(Data item,
UUID uuid,
int eventType) |
static ClientMessage |
SetAddListenerCodec.encodeItemEvent(Data item,
UUID uuid,
int eventType) |
static ClientMessage |
ClientAuthenticationCustomCodec.encodeRequest(Data credentials,
UUID uuid,
String clientType,
byte serializationVersion,
String clientHazelcastVersion,
String clientName,
Collection<String> labels,
int partitionCount,
UUID clusterId) |
static ClientMessage |
AtomicRefContainsCodec.encodeRequest(RaftGroupId groupId,
String name,
Data value) |
static ClientMessage |
AtomicLongApplyCodec.encodeRequest(RaftGroupId groupId,
String name,
Data function) |
static ClientMessage |
AtomicRefSetCodec.encodeRequest(RaftGroupId groupId,
String name,
Data newValue,
boolean returnOldValue) |
static ClientMessage |
AtomicRefCompareAndSetCodec.encodeRequest(RaftGroupId groupId,
String name,
Data oldValue,
Data newValue) |
static ClientMessage |
AtomicLongAlterCodec.encodeRequest(RaftGroupId groupId,
String name,
Data function,
int returnValueType) |
static ClientMessage |
AtomicRefApplyCodec.encodeRequest(RaftGroupId groupId,
String name,
Data function,
int returnValueType,
boolean alter) |
static ClientMessage |
ScheduledExecutorSubmitToAddressCodec.encodeRequest(String schedulerName,
Address address,
byte type,
String taskName,
Data task,
long initialDelayInMillis,
long periodInMillis) |
static ClientMessage |
ScheduledExecutorSubmitToPartitionCodec.encodeRequest(String schedulerName,
byte type,
String taskName,
Data task,
long initialDelayInMillis,
long periodInMillis) |
static ClientMessage |
CacheGetAllCodec.encodeRequest(String name,
Collection<Data> keys,
Data expiryPolicy) |
static ClientMessage |
CacheSetExpiryPolicyCodec.encodeRequest(String name,
Collection<Data> keys,
Data expiryPolicy) |
static ClientMessage |
DynamicConfigAddReliableTopicConfigCodec.encodeRequest(String name,
Collection<ListenerConfigHolder> listenerConfigs,
int readBatchSize,
boolean statisticsEnabled,
String topicOverloadPolicy,
Data executor) |
static ClientMessage |
CachePutAllCodec.encodeRequest(String name,
Collection<Map.Entry<Data,Data>> entries,
Data expiryPolicy,
int completionId) |
static ClientMessage |
MapEntriesWithPagingPredicateCodec.encodeRequest(String name,
Data predicate) |
static ClientMessage |
MapAggregateCodec.encodeRequest(String name,
Data aggregator) |
static ClientMessage |
QueueContainsCodec.encodeRequest(String name,
Data value) |
static ClientMessage |
MapValuesWithPagingPredicateCodec.encodeRequest(String name,
Data predicate) |
static ClientMessage |
ListLastIndexOfCodec.encodeRequest(String name,
Data value) |
static ClientMessage |
MapContainsValueCodec.encodeRequest(String name,
Data value) |
static ClientMessage |
MapProjectCodec.encodeRequest(String name,
Data projection) |
static ClientMessage |
MapAddInterceptorCodec.encodeRequest(String name,
Data interceptor) |
static ClientMessage |
TopicPublishCodec.encodeRequest(String name,
Data message) |
static ClientMessage |
ReplicatedMapRemoveCodec.encodeRequest(String name,
Data key) |
static ClientMessage |
MultiMapContainsValueCodec.encodeRequest(String name,
Data value) |
static ClientMessage |
ReplicatedMapContainsKeyCodec.encodeRequest(String name,
Data key) |
static ClientMessage |
SetAddCodec.encodeRequest(String name,
Data value) |
static ClientMessage |
MapValuesWithPredicateCodec.encodeRequest(String name,
Data predicate) |
static ClientMessage |
QueueRemoveCodec.encodeRequest(String name,
Data value) |
static ClientMessage |
ListAddCodec.encodeRequest(String name,
Data value) |
static ClientMessage |
QueuePutCodec.encodeRequest(String name,
Data value) |
static ClientMessage |
ReplicatedMapContainsValueCodec.encodeRequest(String name,
Data value) |
static ClientMessage |
ListContainsCodec.encodeRequest(String name,
Data value) |
static ClientMessage |
CacheContainsKeyCodec.encodeRequest(String name,
Data key) |
static ClientMessage |
MapKeySetWithPredicateCodec.encodeRequest(String name,
Data predicate) |
static ClientMessage |
MapRemoveAllCodec.encodeRequest(String name,
Data predicate) |
static ClientMessage |
ReplicatedMapGetCodec.encodeRequest(String name,
Data key) |
static ClientMessage |
MapEntriesWithPredicateCodec.encodeRequest(String name,
Data predicate) |
static ClientMessage |
DurableExecutorSubmitToPartitionCodec.encodeRequest(String name,
Data callable) |
static ClientMessage |
MapExecuteOnAllKeysCodec.encodeRequest(String name,
Data entryProcessor) |
static ClientMessage |
SetRemoveCodec.encodeRequest(String name,
Data value) |
static ClientMessage |
ListIndexOfCodec.encodeRequest(String name,
Data value) |
static ClientMessage |
MapKeySetWithPagingPredicateCodec.encodeRequest(String name,
Data predicate) |
static ClientMessage |
ListRemoveCodec.encodeRequest(String name,
Data value) |
static ClientMessage |
MapIsLockedCodec.encodeRequest(String name,
Data key) |
static ClientMessage |
MultiMapIsLockedCodec.encodeRequest(String name,
Data key) |
static ClientMessage |
SetContainsCodec.encodeRequest(String name,
Data value) |
static ClientMessage |
ReplicatedMapAddEntryListenerWithPredicateCodec.encodeRequest(String name,
Data predicate,
boolean localOnly) |
static ClientMessage |
ReplicatedMapAddEntryListenerToKeyCodec.encodeRequest(String name,
Data key,
boolean localOnly) |
static ClientMessage |
CacheListenerRegistrationCodec.encodeRequest(String name,
Data listenerConfig,
boolean shouldRegister,
Address address) |
static ClientMessage |
MultiMapAddEntryListenerToKeyCodec.encodeRequest(String name,
Data key,
boolean includeValue,
boolean localOnly) |
static ClientMessage |
MapAddEntryListenerToKeyCodec.encodeRequest(String name,
Data key,
boolean includeValue,
int listenerFlags,
boolean localOnly) |
static ClientMessage |
MapAddEntryListenerWithPredicateCodec.encodeRequest(String name,
Data predicate,
boolean includeValue,
int listenerFlags,
boolean localOnly) |
static ClientMessage |
MapExecuteOnKeysCodec.encodeRequest(String name,
Data entryProcessor,
Collection<Data> keys) |
static ClientMessage |
MapExecuteWithPredicateCodec.encodeRequest(String name,
Data entryProcessor,
Data predicate) |
static ClientMessage |
MapAggregateWithPredicateCodec.encodeRequest(String name,
Data aggregator,
Data predicate) |
static ClientMessage |
CacheGetCodec.encodeRequest(String name,
Data key,
Data expiryPolicy) |
static ClientMessage |
MapProjectWithPredicateCodec.encodeRequest(String name,
Data projection,
Data predicate) |
static ClientMessage |
ReplicatedMapAddEntryListenerToKeyWithPredicateCodec.encodeRequest(String name,
Data key,
Data predicate,
boolean localOnly) |
static ClientMessage |
MapAddEntryListenerToKeyWithPredicateCodec.encodeRequest(String name,
Data key,
Data predicate,
boolean includeValue,
int listenerFlags,
boolean localOnly) |
static ClientMessage |
CacheEntryProcessorCodec.encodeRequest(String name,
Data key,
Data entryProcessor,
Collection<Data> arguments,
int completionId) |
static ClientMessage |
CachePutCodec.encodeRequest(String name,
Data key,
Data value,
Data expiryPolicy,
boolean get,
int completionId) |
static ClientMessage |
CacheReplaceCodec.encodeRequest(String name,
Data key,
Data oldValue,
Data newValue,
Data expiryPolicy,
int completionId) |
static ClientMessage |
CacheGetAndReplaceCodec.encodeRequest(String name,
Data key,
Data value,
Data expiryPolicy,
int completionId) |
static ClientMessage |
CachePutIfAbsentCodec.encodeRequest(String name,
Data key,
Data value,
Data expiryPolicy,
int completionId) |
static ClientMessage |
MapReplaceIfSameCodec.encodeRequest(String name,
Data key,
Data testValue,
Data value,
long threadId) |
static ClientMessage |
CacheRemoveCodec.encodeRequest(String name,
Data key,
Data currentValue,
int completionId) |
static ClientMessage |
MultiMapContainsEntryCodec.encodeRequest(String name,
Data key,
Data value,
long threadId) |
static ClientMessage |
ReplicatedMapPutCodec.encodeRequest(String name,
Data key,
Data value,
long ttl) |
static ClientMessage |
MapSubmitToKeyCodec.encodeRequest(String name,
Data entryProcessor,
Data key,
long threadId) |
static ClientMessage |
MultiMapPutCodec.encodeRequest(String name,
Data key,
Data value,
long threadId) |
static ClientMessage |
MultiMapRemoveEntryCodec.encodeRequest(String name,
Data key,
Data value,
long threadId) |
static ClientMessage |
MapRemoveIfSameCodec.encodeRequest(String name,
Data key,
Data value,
long threadId) |
static ClientMessage |
MapExecuteOnKeyCodec.encodeRequest(String name,
Data entryProcessor,
Data key,
long threadId) |
static ClientMessage |
MapReplaceCodec.encodeRequest(String name,
Data key,
Data value,
long threadId) |
static ClientMessage |
MapPutTransientCodec.encodeRequest(String name,
Data key,
Data value,
long threadId,
long ttl) |
static ClientMessage |
MapTryPutCodec.encodeRequest(String name,
Data key,
Data value,
long threadId,
long timeout) |
static ClientMessage |
MapSetCodec.encodeRequest(String name,
Data key,
Data value,
long threadId,
long ttl) |
static ClientMessage |
MapPutCodec.encodeRequest(String name,
Data key,
Data value,
long threadId,
long ttl) |
static ClientMessage |
MapPutIfAbsentCodec.encodeRequest(String name,
Data key,
Data value,
long threadId,
long ttl) |
static ClientMessage |
MapSetWithMaxIdleCodec.encodeRequest(String name,
Data key,
Data value,
long threadId,
long ttl,
long maxIdle) |
static ClientMessage |
MapPutTransientWithMaxIdleCodec.encodeRequest(String name,
Data key,
Data value,
long threadId,
long ttl,
long maxIdle) |
static ClientMessage |
MapPutIfAbsentWithMaxIdleCodec.encodeRequest(String name,
Data key,
Data value,
long threadId,
long ttl,
long maxIdle) |
static ClientMessage |
MapPutWithMaxIdleCodec.encodeRequest(String name,
Data key,
Data value,
long threadId,
long ttl,
long maxIdle) |
static ClientMessage |
CacheGetAndRemoveCodec.encodeRequest(String name,
Data key,
int completionId) |
static ClientMessage |
MapForceUnlockCodec.encodeRequest(String name,
Data key,
long referenceId) |
static ClientMessage |
MultiMapForceUnlockCodec.encodeRequest(String name,
Data key,
long referenceId) |
static ClientMessage |
MapGetEntryViewCodec.encodeRequest(String name,
Data key,
long threadId) |
static ClientMessage |
MapRemoveCodec.encodeRequest(String name,
Data key,
long threadId) |
static ClientMessage |
MapGetCodec.encodeRequest(String name,
Data key,
long threadId) |
static ClientMessage |
MultiMapDeleteCodec.encodeRequest(String name,
Data key,
long threadId) |
static ClientMessage |
MapEvictCodec.encodeRequest(String name,
Data key,
long threadId) |
static ClientMessage |
QueueOfferCodec.encodeRequest(String name,
Data value,
long timeoutMillis) |
static ClientMessage |
MapContainsKeyCodec.encodeRequest(String name,
Data key,
long threadId) |
static ClientMessage |
MapSetTtlCodec.encodeRequest(String name,
Data key,
long ttl) |
static ClientMessage |
MultiMapRemoveCodec.encodeRequest(String name,
Data key,
long threadId) |
static ClientMessage |
MultiMapContainsKeyCodec.encodeRequest(String name,
Data key,
long threadId) |
static ClientMessage |
MultiMapGetCodec.encodeRequest(String name,
Data key,
long threadId) |
static ClientMessage |
MultiMapValueCountCodec.encodeRequest(String name,
Data key,
long threadId) |
static ClientMessage |
MapDeleteCodec.encodeRequest(String name,
Data key,
long threadId) |
static ClientMessage |
MultiMapUnlockCodec.encodeRequest(String name,
Data key,
long threadId,
long referenceId) |
static ClientMessage |
MapTryRemoveCodec.encodeRequest(String name,
Data key,
long threadId,
long timeout) |
static ClientMessage |
MapUnlockCodec.encodeRequest(String name,
Data key,
long threadId,
long referenceId) |
static ClientMessage |
MapLockCodec.encodeRequest(String name,
Data key,
long threadId,
long ttl,
long referenceId) |
static ClientMessage |
MultiMapLockCodec.encodeRequest(String name,
Data key,
long threadId,
long ttl,
long referenceId) |
static ClientMessage |
MultiMapTryLockCodec.encodeRequest(String name,
Data key,
long threadId,
long lease,
long timeout,
long referenceId) |
static ClientMessage |
MapTryLockCodec.encodeRequest(String name,
Data key,
long threadId,
long lease,
long timeout,
long referenceId) |
static ClientMessage |
ListAddWithIndexCodec.encodeRequest(String name,
int index,
Data value) |
static ClientMessage |
RingbufferAddCodec.encodeRequest(String name,
int overflowPolicy,
Data value) |
static ClientMessage |
ListSetCodec.encodeRequest(String name,
int index,
Data value) |
static ClientMessage |
MapFetchWithQueryCodec.encodeRequest(String name,
int tableIndex,
int batch,
Data projection,
Data predicate) |
static ClientMessage |
DynamicConfigAddMapConfigCodec.encodeRequest(String name,
int backupCount,
int asyncBackupCount,
int timeToLiveSeconds,
int maxIdleSeconds,
String evictionPolicy,
boolean readBackupData,
String cacheDeserializedValues,
String mergePolicy,
String inMemoryFormat,
Collection<ListenerConfigHolder> listenerConfigs,
Collection<ListenerConfigHolder> partitionLostListenerConfigs,
boolean statisticsEnabled,
String splitBrainProtectionName,
Data mapEvictionPolicy,
String maxSizeConfigMaxSizePolicy,
int maxSizeConfigSize,
MapStoreConfigHolder mapStoreConfig,
NearCacheConfigHolder nearCacheConfig,
WanReplicationRef wanReplicationRef,
Collection<IndexConfig> indexConfigs,
Collection<AttributeConfig> attributeConfigs,
Collection<QueryCacheConfigHolder> queryCacheConfigs,
String partitioningStrategyClassName,
Data partitioningStrategyImplementation,
HotRestartConfig hotRestartConfig,
EventJournalConfig eventJournalConfig,
MerkleTreeConfig merkleTreeConfig,
int mergeBatchSize,
int metadataPolicy) |
static ClientMessage |
RingbufferReadManyCodec.encodeRequest(String name,
long startSequence,
int minCount,
int maxCount,
Data filter) |
static ClientMessage |
CacheEventJournalReadCodec.encodeRequest(String name,
long startSequence,
int minSize,
int maxSize,
Data predicate,
Data projection) |
static ClientMessage |
MapEventJournalReadCodec.encodeRequest(String name,
long startSequence,
int minSize,
int maxSize,
Data predicate,
Data projection) |
static ClientMessage |
ContinuousQueryPublisherCreateCodec.encodeRequest(String mapName,
String cacheName,
Data predicate,
int batchSize,
int bufferSize,
long delaySeconds,
boolean populate,
boolean coalesce) |
static ClientMessage |
ContinuousQueryPublisherCreateWithValueCodec.encodeRequest(String mapName,
String cacheName,
Data predicate,
int batchSize,
int bufferSize,
long delaySeconds,
boolean populate,
boolean coalesce) |
static ClientMessage |
ExecutorServiceSubmitToPartitionCodec.encodeRequest(String name,
UUID uuid,
Data callable) |
static ClientMessage |
ExecutorServiceSubmitToAddressCodec.encodeRequest(String name,
UUID uuid,
Data callable,
Address address) |
static ClientMessage |
TransactionalMapContainsValueCodec.encodeRequest(String name,
UUID txnId,
long threadId,
Data value) |
static ClientMessage |
TransactionalMultiMapGetCodec.encodeRequest(String name,
UUID txnId,
long threadId,
Data key) |
static ClientMessage |
TransactionalMultiMapRemoveCodec.encodeRequest(String name,
UUID txnId,
long threadId,
Data key) |
static ClientMessage |
TransactionalMapGetForUpdateCodec.encodeRequest(String name,
UUID txnId,
long threadId,
Data key) |
static ClientMessage |
TransactionalMapRemoveCodec.encodeRequest(String name,
UUID txnId,
long threadId,
Data key) |
static ClientMessage |
TransactionalMapContainsKeyCodec.encodeRequest(String name,
UUID txnId,
long threadId,
Data key) |
static ClientMessage |
TransactionalMapKeySetWithPredicateCodec.encodeRequest(String name,
UUID txnId,
long threadId,
Data predicate) |
static ClientMessage |
TransactionalMapDeleteCodec.encodeRequest(String name,
UUID txnId,
long threadId,
Data key) |
static ClientMessage |
TransactionalSetRemoveCodec.encodeRequest(String name,
UUID txnId,
long threadId,
Data item) |
static ClientMessage |
TransactionalListAddCodec.encodeRequest(String name,
UUID txnId,
long threadId,
Data item) |
static ClientMessage |
TransactionalSetAddCodec.encodeRequest(String name,
UUID txnId,
long threadId,
Data item) |
static ClientMessage |
TransactionalMapValuesWithPredicateCodec.encodeRequest(String name,
UUID txnId,
long threadId,
Data predicate) |
static ClientMessage |
TransactionalListRemoveCodec.encodeRequest(String name,
UUID txnId,
long threadId,
Data item) |
static ClientMessage |
TransactionalMapGetCodec.encodeRequest(String name,
UUID txnId,
long threadId,
Data key) |
static ClientMessage |
TransactionalMultiMapValueCountCodec.encodeRequest(String name,
UUID txnId,
long threadId,
Data key) |
static ClientMessage |
TransactionalMapReplaceCodec.encodeRequest(String name,
UUID txnId,
long threadId,
Data key,
Data value) |
static ClientMessage |
TransactionalMapRemoveIfSameCodec.encodeRequest(String name,
UUID txnId,
long threadId,
Data key,
Data value) |
static ClientMessage |
TransactionalMultiMapRemoveEntryCodec.encodeRequest(String name,
UUID txnId,
long threadId,
Data key,
Data value) |
static ClientMessage |
TransactionalMapPutIfAbsentCodec.encodeRequest(String name,
UUID txnId,
long threadId,
Data key,
Data value) |
static ClientMessage |
TransactionalMapSetCodec.encodeRequest(String name,
UUID txnId,
long threadId,
Data key,
Data value) |
static ClientMessage |
TransactionalMultiMapPutCodec.encodeRequest(String name,
UUID txnId,
long threadId,
Data key,
Data value) |
static ClientMessage |
TransactionalMapReplaceIfSameCodec.encodeRequest(String name,
UUID txnId,
long threadId,
Data key,
Data oldValue,
Data newValue) |
static ClientMessage |
TransactionalMapPutCodec.encodeRequest(String name,
UUID txnId,
long threadId,
Data key,
Data value,
long ttl) |
static ClientMessage |
TransactionalQueueOfferCodec.encodeRequest(String name,
UUID txnId,
long threadId,
Data item,
long timeout) |
static ClientMessage |
TransactionalMapReplaceCodec.encodeResponse(Data response) |
static ClientMessage |
ListGetCodec.encodeResponse(Data response) |
static ClientMessage |
MapAggregateCodec.encodeResponse(Data response) |
static ClientMessage |
ReplicatedMapPutCodec.encodeResponse(Data response) |
static ClientMessage |
CachePutCodec.encodeResponse(Data response) |
static ClientMessage |
MapSetWithMaxIdleCodec.encodeResponse(Data response) |
static ClientMessage |
DurableExecutorRetrieveResultCodec.encodeResponse(Data response) |
static ClientMessage |
TransactionalMapGetForUpdateCodec.encodeResponse(Data response) |
static ClientMessage |
MapAggregateWithPredicateCodec.encodeResponse(Data response) |
static ClientMessage |
TransactionalQueueTakeCodec.encodeResponse(Data response) |
static ClientMessage |
AtomicRefSetCodec.encodeResponse(Data response) |
static ClientMessage |
ReplicatedMapRemoveCodec.encodeResponse(Data response) |
static ClientMessage |
AtomicRefGetCodec.encodeResponse(Data response) |
static ClientMessage |
TransactionalMapRemoveCodec.encodeResponse(Data response) |
static ClientMessage |
MapPutTransientWithMaxIdleCodec.encodeResponse(Data response) |
static ClientMessage |
MapSubmitToKeyCodec.encodeResponse(Data response) |
static ClientMessage |
CacheEntryProcessorCodec.encodeResponse(Data response) |
static ClientMessage |
QueueTakeCodec.encodeResponse(Data response) |
static ClientMessage |
MapRemoveCodec.encodeResponse(Data response) |
static ClientMessage |
QueuePollCodec.encodeResponse(Data response) |
static ClientMessage |
MapGetCodec.encodeResponse(Data response) |
static ClientMessage |
CacheGetCodec.encodeResponse(Data response) |
static ClientMessage |
TransactionalMapPutIfAbsentCodec.encodeResponse(Data response) |
static ClientMessage |
ScheduledExecutorGetResultFromPartitionCodec.encodeResponse(Data response) |
static ClientMessage |
MapPutIfAbsentWithMaxIdleCodec.encodeResponse(Data response) |
static ClientMessage |
ReplicatedMapGetCodec.encodeResponse(Data response) |
static ClientMessage |
TransactionalQueuePollCodec.encodeResponse(Data response) |
static ClientMessage |
ListRemoveWithIndexCodec.encodeResponse(Data response) |
static ClientMessage |
ExecutorServiceSubmitToAddressCodec.encodeResponse(Data response) |
static ClientMessage |
ScheduledExecutorGetResultFromAddressCodec.encodeResponse(Data response) |
static ClientMessage |
ExecutorServiceSubmitToPartitionCodec.encodeResponse(Data response) |
static ClientMessage |
RingbufferReadOneCodec.encodeResponse(Data response) |
static ClientMessage |
CacheGetAndReplaceCodec.encodeResponse(Data response) |
static ClientMessage |
QueuePeekCodec.encodeResponse(Data response) |
static ClientMessage |
TransactionalMapPutCodec.encodeResponse(Data response) |
static ClientMessage |
MapExecuteOnKeyCodec.encodeResponse(Data response) |
static ClientMessage |
CacheReplaceCodec.encodeResponse(Data response) |
static ClientMessage |
TransactionalQueuePeekCodec.encodeResponse(Data response) |
static ClientMessage |
CacheGetAndRemoveCodec.encodeResponse(Data response) |
static ClientMessage |
AtomicRefApplyCodec.encodeResponse(Data response) |
static ClientMessage |
MapPutWithMaxIdleCodec.encodeResponse(Data response) |
static ClientMessage |
MapReplaceCodec.encodeResponse(Data response) |
static ClientMessage |
ListSetCodec.encodeResponse(Data response) |
static ClientMessage |
MapPutCodec.encodeResponse(Data response) |
static ClientMessage |
AtomicLongApplyCodec.encodeResponse(Data response) |
static ClientMessage |
TransactionalMapGetCodec.encodeResponse(Data response) |
static ClientMessage |
MapPutIfAbsentCodec.encodeResponse(Data response) |
static ClientMessage |
DurableExecutorRetrieveAndDisposeResultCodec.encodeResponse(Data response) |
static ClientMessage |
TopicAddMessageListenerCodec.encodeTopicEvent(Data item,
long publishTime,
UUID uuid) |
abstract void |
CacheAddInvalidationListenerCodec.AbstractEventHandler.handleCacheInvalidationEvent(String name,
Data key,
UUID sourceUuid,
UUID partitionUuid,
long sequence) |
abstract void |
CacheAddNearCacheInvalidationListenerCodec.AbstractEventHandler.handleCacheInvalidationEvent(String name,
Data key,
UUID sourceUuid,
UUID partitionUuid,
long sequence) |
abstract void |
ReplicatedMapAddEntryListenerToKeyWithPredicateCodec.AbstractEventHandler.handleEntryEvent(Data key,
Data value,
Data oldValue,
Data mergingValue,
int eventType,
UUID uuid,
int numberOfAffectedEntries) |
abstract void |
ReplicatedMapAddEntryListenerWithPredicateCodec.AbstractEventHandler.handleEntryEvent(Data key,
Data value,
Data oldValue,
Data mergingValue,
int eventType,
UUID uuid,
int numberOfAffectedEntries) |
abstract void |
MapAddEntryListenerToKeyCodec.AbstractEventHandler.handleEntryEvent(Data key,
Data value,
Data oldValue,
Data mergingValue,
int eventType,
UUID uuid,
int numberOfAffectedEntries) |
abstract void |
MultiMapAddEntryListenerCodec.AbstractEventHandler.handleEntryEvent(Data key,
Data value,
Data oldValue,
Data mergingValue,
int eventType,
UUID uuid,
int numberOfAffectedEntries) |
abstract void |
ReplicatedMapAddNearCacheEntryListenerCodec.AbstractEventHandler.handleEntryEvent(Data key,
Data value,
Data oldValue,
Data mergingValue,
int eventType,
UUID uuid,
int numberOfAffectedEntries) |
abstract void |
MapAddEntryListenerCodec.AbstractEventHandler.handleEntryEvent(Data key,
Data value,
Data oldValue,
Data mergingValue,
int eventType,
UUID uuid,
int numberOfAffectedEntries) |
abstract void |
MapAddEntryListenerWithPredicateCodec.AbstractEventHandler.handleEntryEvent(Data key,
Data value,
Data oldValue,
Data mergingValue,
int eventType,
UUID uuid,
int numberOfAffectedEntries) |
abstract void |
MapAddEntryListenerToKeyWithPredicateCodec.AbstractEventHandler.handleEntryEvent(Data key,
Data value,
Data oldValue,
Data mergingValue,
int eventType,
UUID uuid,
int numberOfAffectedEntries) |
abstract void |
ReplicatedMapAddEntryListenerToKeyCodec.AbstractEventHandler.handleEntryEvent(Data key,
Data value,
Data oldValue,
Data mergingValue,
int eventType,
UUID uuid,
int numberOfAffectedEntries) |
abstract void |
MultiMapAddEntryListenerToKeyCodec.AbstractEventHandler.handleEntryEvent(Data key,
Data value,
Data oldValue,
Data mergingValue,
int eventType,
UUID uuid,
int numberOfAffectedEntries) |
abstract void |
ReplicatedMapAddEntryListenerCodec.AbstractEventHandler.handleEntryEvent(Data key,
Data value,
Data oldValue,
Data mergingValue,
int eventType,
UUID uuid,
int numberOfAffectedEntries) |
abstract void |
MapAddNearCacheEntryListenerCodec.AbstractEventHandler.handleIMapInvalidationEvent(Data key,
UUID sourceUuid,
UUID partitionUuid,
long sequence) |
abstract void |
MapAddNearCacheInvalidationListenerCodec.AbstractEventHandler.handleIMapInvalidationEvent(Data key,
UUID sourceUuid,
UUID partitionUuid,
long sequence) |
abstract void |
ListAddListenerCodec.AbstractEventHandler.handleItemEvent(Data item,
UUID uuid,
int eventType) |
abstract void |
QueueAddListenerCodec.AbstractEventHandler.handleItemEvent(Data item,
UUID uuid,
int eventType) |
abstract void |
SetAddListenerCodec.AbstractEventHandler.handleItemEvent(Data item,
UUID uuid,
int eventType) |
abstract void |
TopicAddMessageListenerCodec.AbstractEventHandler.handleTopicEvent(Data item,
long publishTime,
UUID uuid) |
Modifier and Type | Method and Description |
---|---|
static ClientMessage |
CacheAddInvalidationListenerCodec.encodeCacheBatchInvalidationEvent(String name,
Collection<Data> keys,
Collection<UUID> sourceUuids,
Collection<UUID> partitionUuids,
Collection<Long> sequences) |
static ClientMessage |
CacheAddNearCacheInvalidationListenerCodec.encodeCacheBatchInvalidationEvent(String name,
Collection<Data> keys,
Collection<UUID> sourceUuids,
Collection<UUID> partitionUuids,
Collection<Long> sequences) |
static ClientMessage |
MapAddNearCacheEntryListenerCodec.encodeIMapBatchInvalidationEvent(Collection<Data> keys,
Collection<UUID> sourceUuids,
Collection<UUID> partitionUuids,
Collection<Long> sequences) |
static ClientMessage |
MapAddNearCacheInvalidationListenerCodec.encodeIMapBatchInvalidationEvent(Collection<Data> keys,
Collection<UUID> sourceUuids,
Collection<UUID> partitionUuids,
Collection<Long> sequences) |
static ClientMessage |
QueueCompareAndRetainAllCodec.encodeRequest(String name,
Collection<Data> dataList) |
static ClientMessage |
QueueCompareAndRemoveAllCodec.encodeRequest(String name,
Collection<Data> dataList) |
static ClientMessage |
ListAddAllCodec.encodeRequest(String name,
Collection<Data> valueList) |
static ClientMessage |
QueueContainsAllCodec.encodeRequest(String name,
Collection<Data> dataList) |
static ClientMessage |
SetContainsAllCodec.encodeRequest(String name,
Collection<Data> items) |
static ClientMessage |
ListContainsAllCodec.encodeRequest(String name,
Collection<Data> values) |
static ClientMessage |
SetCompareAndRemoveAllCodec.encodeRequest(String name,
Collection<Data> values) |
static ClientMessage |
SetCompareAndRetainAllCodec.encodeRequest(String name,
Collection<Data> values) |
static ClientMessage |
MapGetAllCodec.encodeRequest(String name,
Collection<Data> keys) |
static ClientMessage |
ListCompareAndRemoveAllCodec.encodeRequest(String name,
Collection<Data> values) |
static ClientMessage |
SetAddAllCodec.encodeRequest(String name,
Collection<Data> valueList) |
static ClientMessage |
QueueAddAllCodec.encodeRequest(String name,
Collection<Data> dataList) |
static ClientMessage |
ListCompareAndRetainAllCodec.encodeRequest(String name,
Collection<Data> values) |
static ClientMessage |
MapLoadGivenKeysCodec.encodeRequest(String name,
Collection<Data> keys,
boolean replaceExistingValues) |
static ClientMessage |
CacheLoadAllCodec.encodeRequest(String name,
Collection<Data> keys,
boolean replaceExistingValues) |
static ClientMessage |
CacheGetAllCodec.encodeRequest(String name,
Collection<Data> keys,
Data expiryPolicy) |
static ClientMessage |
CacheSetExpiryPolicyCodec.encodeRequest(String name,
Collection<Data> keys,
Data expiryPolicy) |
static ClientMessage |
RingbufferAddAllCodec.encodeRequest(String name,
Collection<Data> valueList,
int overflowPolicy) |
static ClientMessage |
CacheRemoveAllKeysCodec.encodeRequest(String name,
Collection<Data> keys,
int completionId) |
static ClientMessage |
MapPutAllCodec.encodeRequest(String name,
Collection<Map.Entry<Data,Data>> entries) |
static ClientMessage |
MapPutAllCodec.encodeRequest(String name,
Collection<Map.Entry<Data,Data>> entries) |
static ClientMessage |
ReplicatedMapPutAllCodec.encodeRequest(String name,
Collection<Map.Entry<Data,Data>> entries) |
static ClientMessage |
ReplicatedMapPutAllCodec.encodeRequest(String name,
Collection<Map.Entry<Data,Data>> entries) |
static ClientMessage |
CachePutAllCodec.encodeRequest(String name,
Collection<Map.Entry<Data,Data>> entries,
Data expiryPolicy,
int completionId) |
static ClientMessage |
CachePutAllCodec.encodeRequest(String name,
Collection<Map.Entry<Data,Data>> entries,
Data expiryPolicy,
int completionId) |
static ClientMessage |
MapExecuteOnKeysCodec.encodeRequest(String name,
Data entryProcessor,
Collection<Data> keys) |
static ClientMessage |
CacheEntryProcessorCodec.encodeRequest(String name,
Data key,
Data entryProcessor,
Collection<Data> arguments,
int completionId) |
static ClientMessage |
ListAddAllWithIndexCodec.encodeRequest(String name,
int index,
Collection<Data> valueList) |
static ClientMessage |
TransactionalMultiMapGetCodec.encodeResponse(Collection<Data> response) |
static ClientMessage |
QueueDrainToMaxSizeCodec.encodeResponse(Collection<Data> response) |
static ClientMessage |
TransactionalMultiMapRemoveCodec.encodeResponse(Collection<Data> response) |
static ClientMessage |
MapProjectCodec.encodeResponse(Collection<Data> response) |
static ClientMessage |
MapValuesWithPredicateCodec.encodeResponse(Collection<Data> response) |
static ClientMessage |
TransactionalMapKeySetWithPredicateCodec.encodeResponse(Collection<Data> response) |
static ClientMessage |
SetGetAllCodec.encodeResponse(Collection<Data> response) |
static ClientMessage |
MultiMapValuesCodec.encodeResponse(Collection<Data> response) |
static ClientMessage |
ListListIteratorCodec.encodeResponse(Collection<Data> response) |
static ClientMessage |
ListSubCodec.encodeResponse(Collection<Data> response) |
static ClientMessage |
QueueIteratorCodec.encodeResponse(Collection<Data> response) |
static ClientMessage |
TransactionalMapKeySetCodec.encodeResponse(Collection<Data> response) |
static ClientMessage |
MapKeySetWithPredicateCodec.encodeResponse(Collection<Data> response) |
static ClientMessage |
MapKeySetCodec.encodeResponse(Collection<Data> response) |
static ClientMessage |
MapValuesCodec.encodeResponse(Collection<Data> response) |
static ClientMessage |
QueueDrainToCodec.encodeResponse(Collection<Data> response) |
static ClientMessage |
MultiMapRemoveCodec.encodeResponse(Collection<Data> response) |
static ClientMessage |
MapProjectWithPredicateCodec.encodeResponse(Collection<Data> response) |
static ClientMessage |
ListIteratorCodec.encodeResponse(Collection<Data> response) |
static ClientMessage |
TransactionalMapValuesWithPredicateCodec.encodeResponse(Collection<Data> response) |
static ClientMessage |
MultiMapGetCodec.encodeResponse(Collection<Data> response) |
static ClientMessage |
MapKeySetWithPagingPredicateCodec.encodeResponse(Collection<Data> response) |
static ClientMessage |
ContinuousQueryPublisherCreateCodec.encodeResponse(Collection<Data> response) |
static ClientMessage |
TransactionalMapValuesCodec.encodeResponse(Collection<Data> response) |
static ClientMessage |
ReplicatedMapKeySetCodec.encodeResponse(Collection<Data> response) |
static ClientMessage |
ListGetAllCodec.encodeResponse(Collection<Data> response) |
static ClientMessage |
ReplicatedMapValuesCodec.encodeResponse(Collection<Data> response) |
static ClientMessage |
MultiMapKeySetCodec.encodeResponse(Collection<Data> response) |
static ClientMessage |
MapFetchWithQueryCodec.encodeResponse(Collection<Data> results,
int nextTableIndexToReadFrom) |
static ClientMessage |
MapEntriesWithPagingPredicateCodec.encodeResponse(Collection<Map.Entry<Data,Data>> response) |
static ClientMessage |
MapEntriesWithPagingPredicateCodec.encodeResponse(Collection<Map.Entry<Data,Data>> response) |
static ClientMessage |
MapExecuteWithPredicateCodec.encodeResponse(Collection<Map.Entry<Data,Data>> response) |
static ClientMessage |
MapExecuteWithPredicateCodec.encodeResponse(Collection<Map.Entry<Data,Data>> response) |
static ClientMessage |
CacheGetAllCodec.encodeResponse(Collection<Map.Entry<Data,Data>> response) |
static ClientMessage |
CacheGetAllCodec.encodeResponse(Collection<Map.Entry<Data,Data>> response) |
static ClientMessage |
MapValuesWithPagingPredicateCodec.encodeResponse(Collection<Map.Entry<Data,Data>> response) |
static ClientMessage |
MapValuesWithPagingPredicateCodec.encodeResponse(Collection<Map.Entry<Data,Data>> response) |
static ClientMessage |
MultiMapEntrySetCodec.encodeResponse(Collection<Map.Entry<Data,Data>> response) |
static ClientMessage |
MultiMapEntrySetCodec.encodeResponse(Collection<Map.Entry<Data,Data>> response) |
static ClientMessage |
MapEntriesWithPredicateCodec.encodeResponse(Collection<Map.Entry<Data,Data>> response) |
static ClientMessage |
MapEntriesWithPredicateCodec.encodeResponse(Collection<Map.Entry<Data,Data>> response) |
static ClientMessage |
MapEntrySetCodec.encodeResponse(Collection<Map.Entry<Data,Data>> response) |
static ClientMessage |
MapEntrySetCodec.encodeResponse(Collection<Map.Entry<Data,Data>> response) |
static ClientMessage |
MapExecuteOnKeysCodec.encodeResponse(Collection<Map.Entry<Data,Data>> response) |
static ClientMessage |
MapExecuteOnKeysCodec.encodeResponse(Collection<Map.Entry<Data,Data>> response) |
static ClientMessage |
MapExecuteOnAllKeysCodec.encodeResponse(Collection<Map.Entry<Data,Data>> response) |
static ClientMessage |
MapExecuteOnAllKeysCodec.encodeResponse(Collection<Map.Entry<Data,Data>> response) |
static ClientMessage |
MapGetAllCodec.encodeResponse(Collection<Map.Entry<Data,Data>> response) |
static ClientMessage |
MapGetAllCodec.encodeResponse(Collection<Map.Entry<Data,Data>> response) |
static ClientMessage |
ContinuousQueryPublisherCreateWithValueCodec.encodeResponse(Collection<Map.Entry<Data,Data>> response) |
static ClientMessage |
ContinuousQueryPublisherCreateWithValueCodec.encodeResponse(Collection<Map.Entry<Data,Data>> response) |
static ClientMessage |
ReplicatedMapEntrySetCodec.encodeResponse(Collection<Map.Entry<Data,Data>> response) |
static ClientMessage |
ReplicatedMapEntrySetCodec.encodeResponse(Collection<Map.Entry<Data,Data>> response) |
static ClientMessage |
CacheIterateCodec.encodeResponse(int tableIndex,
Collection<Data> keys) |
static ClientMessage |
MapFetchKeysCodec.encodeResponse(int tableIndex,
Collection<Data> keys) |
static ClientMessage |
CacheEventJournalReadCodec.encodeResponse(int readCount,
Collection<Data> items,
long[] itemSeqs,
long nextSeq) |
static ClientMessage |
RingbufferReadManyCodec.encodeResponse(int readCount,
Collection<Data> items,
long[] itemSeqs,
long nextSeq) |
static ClientMessage |
MapEventJournalReadCodec.encodeResponse(int readCount,
Collection<Data> items,
long[] itemSeqs,
long nextSeq) |
static ClientMessage |
CacheIterateEntriesCodec.encodeResponse(int tableIndex,
Collection<Map.Entry<Data,Data>> entries) |
static ClientMessage |
CacheIterateEntriesCodec.encodeResponse(int tableIndex,
Collection<Map.Entry<Data,Data>> entries) |
static ClientMessage |
MapFetchEntriesCodec.encodeResponse(int tableIndex,
Collection<Map.Entry<Data,Data>> entries) |
static ClientMessage |
MapFetchEntriesCodec.encodeResponse(int tableIndex,
Collection<Map.Entry<Data,Data>> entries) |
static ClientMessage |
MapGetEntryViewCodec.encodeResponse(SimpleEntryView<Data,Data> response,
long maxIdle) |
static ClientMessage |
MapGetEntryViewCodec.encodeResponse(SimpleEntryView<Data,Data> response,
long maxIdle) |
abstract void |
CacheAddInvalidationListenerCodec.AbstractEventHandler.handleCacheBatchInvalidationEvent(String name,
Collection<Data> keys,
Collection<UUID> sourceUuids,
Collection<UUID> partitionUuids,
Collection<Long> sequences) |
abstract void |
CacheAddNearCacheInvalidationListenerCodec.AbstractEventHandler.handleCacheBatchInvalidationEvent(String name,
Collection<Data> keys,
Collection<UUID> sourceUuids,
Collection<UUID> partitionUuids,
Collection<Long> sequences) |
abstract void |
MapAddNearCacheEntryListenerCodec.AbstractEventHandler.handleIMapBatchInvalidationEvent(Collection<Data> keys,
Collection<UUID> sourceUuids,
Collection<UUID> partitionUuids,
Collection<Long> sequences) |
abstract void |
MapAddNearCacheInvalidationListenerCodec.AbstractEventHandler.handleIMapBatchInvalidationEvent(Collection<Data> keys,
Collection<UUID> sourceUuids,
Collection<UUID> partitionUuids,
Collection<Long> sequences) |
Modifier and Type | Method and Description |
---|---|
static Data |
DataCodec.decode(ClientMessage.ForwardFrameIterator iterator) |
static Data |
DataCodec.decode(ClientMessage.Frame frame) |
Modifier and Type | Method and Description |
---|---|
static SimpleEntryView<Data,Data> |
CustomTypeFactory.createSimpleEntryView(Data key,
Data value,
long cost,
long creationTime,
long expirationTime,
long hits,
long lastAccessTime,
long lastStoredTime,
long lastUpdateTime,
long version,
long ttl,
long maxIdle) |
static SimpleEntryView<Data,Data> |
CustomTypeFactory.createSimpleEntryView(Data key,
Data value,
long cost,
long creationTime,
long expirationTime,
long hits,
long lastAccessTime,
long lastStoredTime,
long lastUpdateTime,
long version,
long ttl,
long maxIdle) |
Modifier and Type | Method and Description |
---|---|
static CacheEventDataImpl |
CustomTypeFactory.createCacheEventData(String name,
int cacheEventType,
Data dataKey,
Data dataValue,
Data dataOldValue,
boolean oldValueAvailable) |
static DefaultQueryCacheEventData |
CustomTypeFactory.createQueryCacheEventData(Data dataKey,
Data dataNewValue,
long sequence,
int eventType,
int partitionId) |
static SimpleEntryView<Data,Data> |
CustomTypeFactory.createSimpleEntryView(Data key,
Data value,
long cost,
long creationTime,
long expirationTime,
long hits,
long lastAccessTime,
long lastStoredTime,
long lastUpdateTime,
long version,
long ttl,
long maxIdle) |
static void |
DataCodec.encode(ClientMessage clientMessage,
Data data) |
Modifier and Type | Method and Description |
---|---|
static SimpleEntryView<Data,Data> |
SimpleEntryViewCodec.decode(ClientMessage.ForwardFrameIterator iterator) |
static SimpleEntryView<Data,Data> |
SimpleEntryViewCodec.decode(ClientMessage.ForwardFrameIterator iterator) |
Modifier and Type | Method and Description |
---|---|
static void |
SimpleEntryViewCodec.encode(ClientMessage clientMessage,
SimpleEntryView<Data,Data> simpleEntryView) |
static void |
SimpleEntryViewCodec.encode(ClientMessage clientMessage,
SimpleEntryView<Data,Data> simpleEntryView) |
Modifier and Type | Method and Description |
---|---|
Data |
CacheConfigHolder.getCacheLoaderFactory() |
Data |
CacheConfigHolder.getCacheWriterFactory() |
Data |
CacheConfigHolder.getExpiryPolicyFactory() |
Modifier and Type | Method and Description |
---|---|
List<Data> |
CacheConfigHolder.getListenerConfigurations() |
Constructor and Description |
---|
CacheConfigHolder(String name,
String managerPrefix,
String uriString,
int backupCount,
int asyncBackupCount,
String inMemoryFormat,
EvictionConfigHolder evictionConfigHolder,
WanReplicationRef wanReplicationRef,
String keyClassName,
String valueClassName,
Data cacheLoaderFactory,
Data cacheWriterFactory,
Data expiryPolicyFactory,
boolean isReadThrough,
boolean isWriteThrough,
boolean isStoreByValue,
boolean isManagementEnabled,
boolean isStatisticsEnabled,
HotRestartConfig hotRestartConfig,
EventJournalConfig eventJournalConfig,
String splitBrainProtectionName,
List<Data> listenerConfigurations,
MergePolicyConfig mergePolicyConfig,
boolean disablePerEntryInvalidationEvents,
List<ListenerConfigHolder> cachePartitionLostListenerConfigs) |
Constructor and Description |
---|
CacheConfigHolder(String name,
String managerPrefix,
String uriString,
int backupCount,
int asyncBackupCount,
String inMemoryFormat,
EvictionConfigHolder evictionConfigHolder,
WanReplicationRef wanReplicationRef,
String keyClassName,
String valueClassName,
Data cacheLoaderFactory,
Data cacheWriterFactory,
Data expiryPolicyFactory,
boolean isReadThrough,
boolean isWriteThrough,
boolean isStoreByValue,
boolean isManagementEnabled,
boolean isStatisticsEnabled,
HotRestartConfig hotRestartConfig,
EventJournalConfig eventJournalConfig,
String splitBrainProtectionName,
List<Data> listenerConfigurations,
MergePolicyConfig mergePolicyConfig,
boolean disablePerEntryInvalidationEvents,
List<ListenerConfigHolder> cachePartitionLostListenerConfigs) |
Modifier and Type | Method and Description |
---|---|
Data |
EvictionConfigHolder.getComparator() |
Data |
MapStoreConfigHolder.getFactoryImplementation() |
Data |
QueueStoreConfigHolder.getFactoryImplementation() |
Data |
RingbufferStoreConfigHolder.getFactoryImplementation() |
Data |
PredicateConfigHolder.getImplementation() |
Data |
MapStoreConfigHolder.getImplementation() |
Data |
QueueStoreConfigHolder.getImplementation() |
Data |
RingbufferStoreConfigHolder.getImplementation() |
Data |
ListenerConfigHolder.getListenerImplementation() |
Modifier and Type | Method and Description |
---|---|
void |
MapStoreConfigHolder.setFactoryImplementation(Data factoryImplementation) |
void |
MapStoreConfigHolder.setImplementation(Data implementation) |
Constructor and Description |
---|
EvictionConfigHolder(int size,
String maxSizePolicy,
String evictionPolicy,
String comparatorClassName,
Data comparator) |
ListenerConfigHolder(int listenerType,
Data listenerImplementation) |
ListenerConfigHolder(int listenerType,
Data listenerImplementation,
String className,
boolean includeValue,
boolean local) |
MapStoreConfigHolder(boolean enabled,
boolean writeCoalescing,
int writeDelaySeconds,
int writeBatchSize,
String className,
Data implementation,
String factoryClassName,
Data factoryImplementation,
Map<String,String> properties,
String initialLoadMode) |
PredicateConfigHolder(String className,
String sql,
Data implementation) |
QueueStoreConfigHolder(String className,
String factoryClassName,
Data implementation,
Data factoryImplementation,
Map<String,String> properties,
boolean enabled) |
RingbufferStoreConfigHolder(String className,
String factoryClassName,
Data implementation,
Data factoryImplementation,
Map<String,String> properties,
boolean enabled) |
Modifier and Type | Method and Description |
---|---|
protected List<Data> |
DefaultMapProjectMessageTask.reduce(Collection<QueryResult> results) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
MapAddEntryListenerToKeyWithPredicateMessageTask.encodeEvent(Data keyData,
Data newValueData,
Data oldValueData,
Data meringValueData,
int type,
UUID uuid,
int numberOfAffectedEntries) |
protected abstract ClientMessage |
AbstractMapAddEntryListenerMessageTask.encodeEvent(Data keyData,
Data newValueData,
Data oldValueData,
Data meringValueData,
int type,
UUID uuid,
int numberOfEntriesAffected) |
protected ClientMessage |
MapAddNearCacheInvalidationListenerMessageTask.encodeEvent(Data keyData,
Data newValueData,
Data oldValueData,
Data meringValueData,
int type,
UUID uuid,
int numberOfAffectedEntries) |
protected ClientMessage |
Pre38MapAddNearCacheEntryListenerMessageTask.encodeEvent(Data keyData,
Data newValueData,
Data oldValueData,
Data meringValueData,
int type,
UUID uuid,
int numberOfAffectedEntries) |
protected ClientMessage |
MapAddEntryListenerToKeyMessageTask.encodeEvent(Data keyData,
Data newValueData,
Data oldValueData,
Data meringValueData,
int type,
UUID uuid,
int numberOfAffectedEntries) |
protected ClientMessage |
MapAddEntryListenerMessageTask.encodeEvent(Data keyData,
Data newValueData,
Data oldValueData,
Data meringValueData,
int type,
UUID uuid,
int numberOfAffectedEntries) |
protected ClientMessage |
MapAddEntryListenerWithPredicateMessageTask.encodeEvent(Data keyData,
Data newValueData,
Data oldValueData,
Data meringValueData,
int type,
UUID uuid,
int numberOfAffectedEntries) |
Modifier and Type | Method and Description |
---|---|
Data |
MultiMapAddEntryListenerToKeyMessageTask.getKey() |
Data |
AbstractMultiMapAddEntryListenerMessageTask.getKey() |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
MultiMapAddEntryListenerToKeyMessageTask.encodeEvent(Data key,
Data value,
Data oldValue,
int type,
UUID uuid,
int numberOfEntriesAffected) |
protected ClientMessage |
MultiMapAddEntryListenerMessageTask.encodeEvent(Data key,
Data value,
Data oldValue,
int type,
UUID uuid,
int numberOfEntriesAffected) |
protected abstract ClientMessage |
AbstractMultiMapAddEntryListenerMessageTask.encodeEvent(Data key,
Data value,
Data oldValue,
int type,
UUID uuid,
int numberOfEntriesAffected) |
Modifier and Type | Method and Description |
---|---|
Data |
ReplicatedMapAddNearCacheListenerMessageTask.getKey() |
Data |
ReplicatedMapAddEntryListenerMessageTask.getKey() |
Data |
ReplicatedMapAddEntryListenerToKeyMessageTask.getKey() |
abstract Data |
AbstractReplicatedMapAddEntryListenerMessageTask.getKey() |
Data |
ReplicatedMapAddEntryListenerToKeyWithPredicateMessageTask.getKey() |
Data |
ReplicatedMapAddEntryListenerWithPredicateMessageTask.getKey() |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
ReplicatedMapAddNearCacheListenerMessageTask.encodeEvent(Data key,
Data newValue,
Data oldValue,
Data mergingValue,
int type,
UUID uuid,
int numberOfAffectedEntries) |
protected ClientMessage |
ReplicatedMapAddEntryListenerMessageTask.encodeEvent(Data key,
Data newValue,
Data oldValue,
Data mergingValue,
int type,
UUID uuid,
int numberOfAffectedEntries) |
protected ClientMessage |
ReplicatedMapAddEntryListenerToKeyMessageTask.encodeEvent(Data key,
Data newValue,
Data oldValue,
Data mergingValue,
int type,
UUID uuid,
int numberOfAffectedEntries) |
protected abstract ClientMessage |
AbstractReplicatedMapAddEntryListenerMessageTask.encodeEvent(Data key,
Data newValue,
Data oldValue,
Data mergingValue,
int type,
UUID uuid,
int numberOfAffectedEntries) |
protected ClientMessage |
ReplicatedMapAddEntryListenerToKeyWithPredicateMessageTask.encodeEvent(Data key,
Data newValue,
Data oldValue,
Data mergingValue,
int type,
UUID uuid,
int numberOfAffectedEntries) |
protected ClientMessage |
ReplicatedMapAddEntryListenerWithPredicateMessageTask.encodeEvent(Data key,
Data newValue,
Data oldValue,
Data mergingValue,
int type,
UUID uuid,
int numberOfAffectedEntries) |
Modifier and Type | Method and Description |
---|---|
protected void |
ClientMapProxy.fillPartitionToKeyData(Set<K> keys,
Map<Integer,List<Data>> partitionToKeyData,
Map<Object,Data> keyMap,
Map<Data,Object> reverseKeyMap) |
protected void |
ClientMapProxy.fillPartitionToKeyData(Set<K> keys,
Map<Integer,List<Data>> partitionToKeyData,
Map<Object,Data> keyMap,
Map<Data,Object> reverseKeyMap) |
protected void |
ClientMapProxy.fillPartitionToKeyData(Set<K> keys,
Map<Integer,List<Data>> partitionToKeyData,
Map<Object,Data> keyMap,
Map<Data,Object> reverseKeyMap) |
protected void |
NearCachedClientMapProxy.finalizePutAll(Map<? extends K,? extends V> map,
Map<Integer,List<Map.Entry<Data,Data>>> entryMap) |
protected void |
NearCachedClientMapProxy.finalizePutAll(Map<? extends K,? extends V> map,
Map<Integer,List<Map.Entry<Data,Data>>> entryMap) |
protected void |
ClientMapProxy.finalizePutAll(Map<? extends K,? extends V> map,
Map<Integer,List<Map.Entry<Data,Data>>> entryMap) |
protected void |
ClientMapProxy.finalizePutAll(Map<? extends K,? extends V> map,
Map<Integer,List<Map.Entry<Data,Data>>> entryMap) |
protected void |
NearCachedClientMapProxy.getAllInternal(Set<K> keys,
Map<Integer,List<Data>> partitionToKeyData,
List<Object> resultingKeyValuePairs) |
protected void |
ClientMapProxy.getAllInternal(Set<K> keys,
Map<Integer,List<Data>> partitionToKeyData,
List<Object> resultingKeyValuePairs) |
protected <R> Map<K,R> |
NearCachedClientMapProxy.prepareResult(Collection<Map.Entry<Data,Data>> entrySet) |
protected <R> Map<K,R> |
NearCachedClientMapProxy.prepareResult(Collection<Map.Entry<Data,Data>> entrySet) |
protected <R> Map<K,R> |
ClientMapProxy.prepareResult(Collection<Map.Entry<Data,Data>> entries) |
protected <R> Map<K,R> |
ClientMapProxy.prepareResult(Collection<Map.Entry<Data,Data>> entries) |
Modifier and Type | Method and Description |
---|---|
protected <T> Data |
ClientProxy.toData(T o) |
Modifier and Type | Method and Description |
---|---|
int |
ClientPartitionService.getPartitionId(Data key) |
Modifier and Type | Method and Description |
---|---|
int |
ClientPartitionServiceImpl.getPartitionId(Data key) |
Modifier and Type | Method and Description |
---|---|
protected List<Data> |
ClientMapQueryPartitionIterator.fetch() |
Modifier and Type | Field and Description |
---|---|
protected Data |
CollectionItem.value |
Modifier and Type | Method and Description |
---|---|
Data |
CollectionEvent.getData() |
Data |
CollectionItem.getValue() |
Modifier and Type | Method and Description |
---|---|
Map<Long,Data> |
CollectionContainer.addAll(List<Data> valueList) |
Map<Long,Data> |
CollectionContainer.clear(boolean returnValues) |
Map<Long,Data> |
CollectionContainer.compareAndRemove(boolean retain,
Set<Data> valueSet) |
List<Data> |
CollectionContainer.getAll() |
Modifier and Type | Method and Description |
---|---|
long |
CollectionContainer.add(Data value) |
void |
CollectionContainer.addBackup(long itemId,
Data value) |
void |
CollectionContainer.commitAdd(long itemId,
Data value) |
void |
CollectionContainer.commitAddBackup(long itemId,
Data value) |
CollectionItem |
CollectionContainer.remove(Data value) |
Long |
CollectionContainer.reserveAdd(UUID transactionId,
Data value) |
CollectionItem |
CollectionContainer.reserveRemove(long reservedItemId,
Data value,
UUID transactionId) |
void |
CollectionItem.setValue(Data value) |
Modifier and Type | Method and Description |
---|---|
Map<Long,Data> |
CollectionContainer.addAll(List<Data> valueList) |
void |
CollectionContainer.addAllBackup(Map<Long,Data> valueMap) |
Map<Long,Data> |
CollectionContainer.compareAndRemove(boolean retain,
Set<Data> valueSet) |
boolean |
CollectionContainer.contains(Set<Data> valueSet) |
void |
CollectionService.dispatchEvent(CollectionEvent event,
ItemListener<Data> listener) |
Constructor and Description |
---|
CollectionEvent(String name,
Data data,
ItemEventType eventType,
Address caller) |
CollectionItem(long itemId,
Data value) |
TxCollectionItem(long itemId,
Data value,
UUID transactionId,
boolean removeOperation) |
Modifier and Type | Field and Description |
---|---|
protected Data |
CollectionAddOperation.value |
Modifier and Type | Field and Description |
---|---|
protected List<Data> |
CollectionAddAllOperation.valueList |
protected Map<Long,Data> |
CollectionAddAllOperation.valueMap |
protected Map<Long,Data> |
CollectionAddAllBackupOperation.valueMap |
Modifier and Type | Method and Description |
---|---|
protected void |
CollectionOperation.publishEvent(ItemEventType eventType,
Data data) |
Constructor and Description |
---|
CollectionAddBackupOperation(String name,
long itemId,
Data value) |
CollectionAddOperation(String name,
Data value) |
CollectionRemoveOperation(String name,
Data value) |
Constructor and Description |
---|
CollectionAddAllBackupOperation(String name,
Map<Long,Data> valueMap) |
CollectionAddAllOperation(String name,
List<Data> valueList) |
CollectionCompareAndRemoveOperation(String name,
boolean retain,
Set<Data> valueSet) |
CollectionContainsOperation(String name,
Set<Data> valueSet) |
Modifier and Type | Method and Description |
---|---|
Data |
DataAwareItemEvent.getItemData() |
Constructor and Description |
---|
DataAwareItemEvent(String name,
ItemEventType itemEventType,
Data dataItem,
Member member,
SerializationService serializationService) |
Modifier and Type | Method and Description |
---|---|
Map<Long,Data> |
ListContainer.addAll(int index,
List<Data> valueList) |
List<Data> |
ListContainer.sub(int from,
int to) |
Modifier and Type | Method and Description |
---|---|
CollectionItem |
ListContainer.add(int index,
Data value) |
int |
ListContainer.indexOf(boolean last,
Data value) |
CollectionItem |
ListContainer.set(int index,
long itemId,
Data value) |
void |
ListContainer.setBackup(long oldItemId,
long itemId,
Data value) |
Modifier and Type | Method and Description |
---|---|
Map<Long,Data> |
ListContainer.addAll(int index,
List<Data> valueList) |
Constructor and Description |
---|
ListAddOperation(String name,
int index,
Data value) |
ListIndexOfOperation(String name,
boolean last,
Data value) |
ListSetBackupOperation(String name,
long oldItemId,
long itemId,
Data value) |
ListSetOperation(String name,
int index,
Data value) |
Constructor and Description |
---|
ListAddAllOperation(String name,
int index,
List<Data> valueList) |
Modifier and Type | Field and Description |
---|---|
protected Data |
QueueItem.data |
Modifier and Type | Method and Description |
---|---|
Data |
QueueItem.getData() |
Data |
QueueContainer.getDataFromMap(long itemId) |
Data |
QueueStoreWrapper.load(Long key) |
Data |
QueueContainer.txnCommitPoll(long itemId) |
Data |
QueueContainer.txnCommitPollBackup(long itemId)
Commits the effects of the
QueueContainer.txnPollReserve(long, UUID) }. |
Modifier and Type | Method and Description |
---|---|
Map<Long,Data> |
QueueContainer.addAll(Collection<Data> dataList)
Adds all items from the
dataList to the queue. |
Map<Long,Data> |
QueueContainer.clear() |
Map<Long,Data> |
QueueContainer.compareAndRemove(Collection<Data> dataList,
boolean retain)
Compares if the queue contains the items in the dataList and removes them according to the retain parameter.
|
Map<Long,Data> |
QueueContainer.drain(int maxSize)
Removes items from the queue and the queue store (if configured), up to
maxSize or the size of the queue,
whichever is smaller. |
List<Data> |
QueueContainer.getAsDataList()
Returns data in the queue.
|
Map<Long,Data> |
QueueStoreWrapper.loadAll(Collection<Long> keys) |
Modifier and Type | Method and Description |
---|---|
long |
QueueContainer.offer(Data data) |
void |
QueueContainer.offerBackup(Data data,
long itemId)
Offers the item to the backup map.
|
long |
QueueContainer.remove(Data data)
Iterates all items, checks equality with data
This method does not trigger store load.
|
void |
QueueItem.setData(Data data) |
void |
QueueStoreWrapper.store(Long key,
Data value) |
boolean |
QueueContainer.txnCommitOffer(long itemId,
Data data,
boolean backup)
Sets the data of a reserved item and commits the change so it can be
visible outside a transaction.
|
Modifier and Type | Method and Description |
---|---|
Map<Long,Data> |
QueueContainer.addAll(Collection<Data> dataList)
Adds all items from the
dataList to the queue. |
void |
QueueContainer.addAllBackup(Map<Long,Data> dataMap)
Offers the items to the backup map in bulk.
|
Map<Long,Data> |
QueueContainer.compareAndRemove(Collection<Data> dataList,
boolean retain)
Compares if the queue contains the items in the dataList and removes them according to the retain parameter.
|
boolean |
QueueContainer.contains(Collection<Data> dataSet)
Checks if the queue contains all items in the dataSet.
|
void |
QueueContainer.mapDrainIterator(int maxSize,
Map<Long,Data> map) |
void |
QueueContainer.mapIterateAndRemove(Map<Long,Data> map)
Deletes items from the queue which have IDs contained in the key set of the given map.
|
void |
QueueStoreWrapper.storeAll(Map<Long,Data> map) |
Constructor and Description |
---|
QueueEvent(String name,
Data data,
ItemEventType eventType,
Address caller) |
QueueItem(QueueContainer container,
long itemId,
Data data) |
Constructor and Description |
---|
QueueIterator(Iterator<Data> iterator,
SerializationService serializationService,
boolean binary) |
Modifier and Type | Method and Description |
---|---|
void |
QueueOperation.publishEvent(ItemEventType eventType,
Data data) |
Constructor and Description |
---|
OfferBackupOperation(String name,
Data data,
long itemId) |
OfferOperation(String name,
long timeout,
Data data) |
RemoveOperation(String name,
Data data) |
Constructor and Description |
---|
AddAllBackupOperation(String name,
Map<Long,Data> dataMap) |
AddAllOperation(String name,
Collection<Data> dataList) |
CompareAndRemoveOperation(String name,
Collection<Data> dataList,
boolean retain) |
ContainsOperation(String name,
Collection<Data> dataList) |
Modifier and Type | Method and Description |
---|---|
Map<Long,Data> |
SetContainer.addAll(List<Data> valueList) |
Modifier and Type | Method and Description |
---|---|
Map<Long,Data> |
SetContainer.addAll(List<Data> valueList) |
Constructor and Description |
---|
CollectionReserveAddOperation(String name,
UUID transactionId,
Data value) |
CollectionReserveRemoveOperation(String name,
long reservedItemId,
Data value,
UUID transactionId) |
CollectionTxnAddBackupOperation(String name,
long itemId,
Data value) |
CollectionTxnAddOperation(String name,
long itemId,
Data value) |
Constructor and Description |
---|
TxQueueItem(QueueContainer container,
long itemId,
Data data) |
Constructor and Description |
---|
TxnOfferBackupOperation(String name,
long itemId,
Data data) |
TxnOfferOperation(String name,
long itemId,
Data data) |
Modifier and Type | Method and Description |
---|---|
Data |
AtomicRef.get() |
protected Data |
AtomicRefSnapshot.readValue(ObjectDataInput in) |
Modifier and Type | Method and Description |
---|---|
boolean |
AtomicRef.contains(Data expected) |
protected AtomicRef |
AtomicRefService.newAtomicValue(CPGroupId groupId,
String name,
Data val) |
void |
AtomicRef.set(Data value) |
protected void |
AtomicRefSnapshot.writeValue(ObjectDataOutput out,
Data value) |
Modifier and Type | Method and Description |
---|---|
protected AtomicRefSnapshot |
AtomicRefService.newSnapshot(Map<String,Data> values,
Set<String> destroyed) |
Constructor and Description |
---|
AtomicRefSnapshot(Map<String,Data> refs,
Set<String> destroyed) |
Constructor and Description |
---|
ApplyOp(String name,
Data function,
ApplyOp.ReturnValueType returnValueType,
boolean alter) |
CompareAndSetOp(String name,
Data expectedValue,
Data newValue) |
ContainsOp(String name,
Data value) |
SetOp(String name,
Data newValue,
boolean returnOldValue) |
Constructor and Description |
---|
TaskBackupOperation(String name,
int sequence,
Data callableData) |
TaskOperation(String name,
Data callableData) |
Constructor and Description |
---|
CallableTaskOperation(String name,
UUID uuid,
Data callableData) |
MemberCallableTaskOperation(String name,
UUID uuid,
Data callableData) |
Modifier and Type | Method and Description |
---|---|
Data |
ExpiredKey.getKey() |
Constructor and Description |
---|
ExpiredKey(Data key,
long creationTime) |
Constructor and Description |
---|
DeserializingEntry(Data dataKey,
Data dataValue) |
Modifier and Type | Method and Description |
---|---|
Data |
LockResource.getKey() |
Modifier and Type | Method and Description |
---|---|
Set<Data> |
LockStoreProxy.getLockedKeys() |
Set<Data> |
LockStore.getLockedKeys()
Return all locked keys for this store.
|
Set<Data> |
LockStoreImpl.getLockedKeys() |
Modifier and Type | Method and Description |
---|---|
boolean |
LockStoreProxy.canAcquireLock(Data key,
UUID caller,
long threadId) |
boolean |
LockStore.canAcquireLock(Data key,
UUID caller,
long threadId)
Return if the key can be locked by the caller and thread ID.
|
boolean |
LockStoreImpl.canAcquireLock(Data key,
UUID caller,
long threadId) |
boolean |
LockStoreProxy.extendLeaseTime(Data key,
UUID caller,
long threadId,
long leaseTime) |
boolean |
LockStore.extendLeaseTime(Data key,
UUID caller,
long threadId,
long leaseTime)
Extend the lease time for an already locked key.
|
boolean |
LockStoreImpl.extendLeaseTime(Data key,
UUID caller,
long threadId,
long leaseTime) |
boolean |
LockStoreProxy.forceUnlock(Data key) |
boolean |
LockStore.forceUnlock(Data dataKey)
Unlock the key regardless of the owner.
|
boolean |
LockStoreImpl.forceUnlock(Data key) |
void |
LockProxySupport.forceUnlock(NodeEngine nodeEngine,
Data key) |
com.hazelcast.internal.locksupport.LockResourceImpl |
LockStoreImpl.getLock(Data key) |
int |
LockStoreProxy.getLockCount(Data key) |
int |
LockStore.getLockCount(Data key)
Return the number of times a key was locked by the same owner (re-entered).
|
int |
LockStoreImpl.getLockCount(Data key) |
WaitNotifyKey |
LockStoreImpl.getNotifiedKey(Data key) |
String |
LockStoreProxy.getOwnerInfo(Data dataKey) |
String |
LockStore.getOwnerInfo(Data dataKey)
Return a string representation of the owner of the lock for a specific key.
|
String |
LockStoreImpl.getOwnerInfo(Data key) |
long |
LockStoreProxy.getRemainingLeaseTime(Data key) |
long |
LockStore.getRemainingLeaseTime(Data key)
Return the remaining lease time for a specific key.
|
long |
LockStoreImpl.getRemainingLeaseTime(Data key) |
int |
LockStoreImpl.getVersion(Data key) |
boolean |
LockStoreProxy.isLocked(Data key) |
boolean |
LockStore.isLocked(Data key)
Check if a key is locked by any caller and thread ID.
|
boolean |
LockStoreImpl.isLocked(Data key) |
boolean |
LockProxySupport.isLocked(NodeEngine nodeEngine,
Data key) |
boolean |
LockStoreProxy.isLockedBy(Data key,
UUID caller,
long threadId) |
boolean |
LockStore.isLockedBy(Data key,
UUID caller,
long threadId)
Check if a key is locked by a specific caller and thread ID.
|
boolean |
LockStoreImpl.isLockedBy(Data key,
UUID caller,
long threadId) |
boolean |
LockStoreProxy.localLock(Data key,
UUID caller,
long threadId,
long referenceId,
long leaseTime) |
boolean |
LockStore.localLock(Data key,
UUID caller,
long threadId,
long referenceId,
long leaseTime)
Lock a specific key on a local partition only.
|
boolean |
LockStoreImpl.localLock(Data key,
UUID caller,
long threadId,
long referenceId,
long leaseTime) |
boolean |
LockStoreProxy.lock(Data key,
UUID caller,
long threadId,
long referenceId,
long leaseTime) |
boolean |
LockStore.lock(Data key,
UUID caller,
long threadId,
long referenceId,
long leaseTime)
Lock a specific key.
|
boolean |
LockStoreImpl.lock(Data key,
UUID caller,
long threadId,
long referenceId,
long leaseTime) |
void |
LockProxySupport.lock(NodeEngine nodeEngine,
Data key) |
void |
LockProxySupport.lock(NodeEngine nodeEngine,
Data key,
long leaseTime) |
boolean |
LockStoreProxy.shouldBlockReads(Data key) |
boolean |
LockStore.shouldBlockReads(Data key)
Return whether the reads for the specific key should be blocked
(see
LockStore.txnLock(Data, UUID, long, long, long, boolean) ). |
boolean |
LockStoreImpl.shouldBlockReads(Data key) |
boolean |
LockProxySupport.tryLock(NodeEngine nodeEngine,
Data key) |
boolean |
LockProxySupport.tryLock(NodeEngine nodeEngine,
Data key,
long timeout,
TimeUnit timeunit) |
boolean |
LockProxySupport.tryLock(NodeEngine nodeEngine,
Data key,
long timeout,
TimeUnit timeunit,
long leaseTime,
TimeUnit leaseTimeunit) |
boolean |
LockStoreProxy.txnLock(Data key,
UUID caller,
long threadId,
long referenceId,
long leaseTime,
boolean blockReads) |
boolean |
LockStore.txnLock(Data key,
UUID caller,
long threadId,
long referenceId,
long leaseTime,
boolean blockReads)
Lock a specific key for use inside a transaction.
|
boolean |
LockStoreImpl.txnLock(Data key,
UUID caller,
long threadId,
long referenceId,
long leaseTime,
boolean blockReads) |
boolean |
LockStoreProxy.unlock(Data key,
UUID caller,
long threadId,
long referenceId) |
boolean |
LockStore.unlock(Data key,
UUID caller,
long threadId,
long referenceId)
Unlock a specific key.
|
boolean |
LockStoreImpl.unlock(Data key,
UUID caller,
long threadId,
long referenceId) |
void |
LockProxySupport.unlock(NodeEngine nodeEngine,
Data key) |
Modifier and Type | Method and Description |
---|---|
void |
LockEvictionProcessor.process(EntryTaskScheduler<Data,Integer> scheduler,
Collection<ScheduledEntry<Data,Integer>> entries) |
void |
LockEvictionProcessor.process(EntryTaskScheduler<Data,Integer> scheduler,
Collection<ScheduledEntry<Data,Integer>> entries) |
Constructor and Description |
---|
LockWaitNotifyKey(ObjectNamespace namespace,
Data key) |
Constructor and Description |
---|
LockStoreImpl(LockSupportService lockService,
ObjectNamespace name,
EntryTaskScheduler<Data,Integer> entryTaskScheduler,
int backupCount,
int asyncBackupCount) |
Modifier and Type | Field and Description |
---|---|
protected Data |
AbstractLockOperation.key |
Modifier and Type | Method and Description |
---|---|
Data |
AbstractLockOperation.getKey() |
Constructor and Description |
---|
AbstractLockOperation(ObjectNamespace namespace,
Data key,
long threadId) |
AbstractLockOperation(ObjectNamespace namespace,
Data key,
long threadId,
long timeout) |
AbstractLockOperation(ObjectNamespace namespace,
Data key,
long threadId,
long leaseTime,
long timeout) |
IsLockedOperation(ObjectNamespace namespace,
Data key) |
IsLockedOperation(ObjectNamespace namespace,
Data key,
long threadId) |
LocalLockCleanupOperation(ObjectNamespace namespace,
Data key,
UUID uuid) |
LockBackupOperation(ObjectNamespace namespace,
Data key,
long threadId,
long leaseTime,
UUID originalCallerUuid,
boolean isClient) |
LockOperation(ObjectNamespace namespace,
Data key,
long threadId,
long leaseTime,
long timeout) |
LockOperation(ObjectNamespace namespace,
Data key,
long threadId,
long leaseTime,
long timeout,
long referenceId,
boolean isClient) |
UnlockBackupOperation(ObjectNamespace namespace,
Data key,
long threadId,
UUID originalCallerUuid,
boolean force) |
UnlockIfLeaseExpiredOperation(ObjectNamespace namespace,
Data key,
int version) |
UnlockOperation(ObjectNamespace namespace,
Data key,
long threadId) |
UnlockOperation(ObjectNamespace namespace,
Data key,
long threadId,
boolean force) |
UnlockOperation(ObjectNamespace namespace,
Data key,
long threadId,
boolean force,
long referenceId) |
Modifier and Type | Method and Description |
---|---|
void |
NearCacheRecordStore.put(K key,
Data keyData,
V value,
Data valueData)
Puts (associates) a value with the given
key . |
void |
NearCache.put(K key,
Data keyData,
V value,
Data valueData)
Puts (associates) a value with the given
key . |
long |
NearCacheRecordStore.tryReserveForUpdate(K key,
Data keyData)
Tries to reserve supplied key for update.
|
long |
NearCache.tryReserveForUpdate(K key,
Data keyData)
Tries to reserve supplied key for update.
|
Modifier and Type | Method and Description |
---|---|
void |
DefaultNearCache.put(K key,
Data keyData,
V value,
Data valueData) |
long |
DefaultNearCache.tryReserveForUpdate(K key,
Data keyData) |
Modifier and Type | Method and Description |
---|---|
Data |
Invalidation.getKey() |
Data |
SingleNearCacheInvalidation.getKey() |
Modifier and Type | Method and Description |
---|---|
protected abstract ClientMessage |
AbstractBaseNearCacheInvalidationListener.encodeSingleInvalidation(String name,
Data key,
UUID sourceUuid,
UUID partitionUuid,
long sequence) |
int |
MinimalPartitionService.getPartitionId(Data key)
Returns the partition ID for a Data key.
|
void |
RepairingHandler.handle(Data key,
UUID sourceUuid,
UUID partitionUuid,
long sequence)
Handles a single invalidation
|
void |
Invalidator.invalidateKey(Data key,
String dataStructureName,
UUID sourceUuid)
Invalidates supplied key from Near Caches of supplied data structure name.
|
protected Invalidation |
Invalidator.newInvalidation(Data key,
String dataStructureName,
UUID sourceUuid,
int partitionId) |
protected Invalidation |
BatchInvalidator.newInvalidation(Data key,
String dataStructureName,
UUID sourceUuid,
int partitionId) |
Modifier and Type | Method and Description |
---|---|
protected abstract ClientMessage |
AbstractBaseNearCacheInvalidationListener.encodeBatchInvalidation(String name,
List<Data> keys,
List<UUID> sourceUuids,
List<UUID> partitionUuids,
List<Long> sequences) |
void |
RepairingHandler.handle(Collection<Data> keys,
Collection<UUID> sourceUuids,
Collection<UUID> partitionUuids,
Collection<Long> sequences)
Handles batch invalidations
|
Constructor and Description |
---|
SingleNearCacheInvalidation(Data key,
String dataStructureName,
UUID sourceUuid,
UUID partitionUuid,
long sequence) |
Constructor and Description |
---|
NearCacheDataRecord(Data value,
long creationTime,
long expiryTime) |
Modifier and Type | Method and Description |
---|---|
protected Data |
AbstractNearCacheRecordStore.toData(Object obj) |
Modifier and Type | Method and Description |
---|---|
protected R |
BaseHeapNearCacheRecordStore.getOrCreateToReserve(K key,
Data keyData) |
protected abstract R |
AbstractNearCacheRecordStore.getOrCreateToReserve(K key,
Data keyData) |
protected void |
AbstractNearCacheRecordStore.onRecordCreate(K key,
Data keyData,
R record) |
void |
AbstractNearCacheRecordStore.put(K key,
Data keyData,
V value,
Data valueData) |
long |
AbstractNearCacheRecordStore.tryReserveForUpdate(K key,
Data keyData) |
Constructor and Description |
---|
ReserveForUpdateFunction(Data keyData) |
Modifier and Type | Class and Description |
---|---|
class |
Packet
A Packet is a piece of data sent over the wire.
|
Modifier and Type | Method and Description |
---|---|
int |
InternalPartitionServiceImpl.getPartitionId(Data key) |
Modifier and Type | Method and Description |
---|---|
<B extends Data> |
InternalSerializationService.convertData(Data data,
DataType type) |
<B extends Data> |
SerializationService.toData(Object obj)
Serializes an object to a
Data . |
<B extends Data> |
InternalSerializationService.toData(Object obj,
DataType type) |
<B extends Data> |
InternalSerializationService.toData(Object obj,
DataType type,
PartitioningStrategy strategy) |
<B extends Data> |
SerializationService.toData(Object obj,
PartitioningStrategy strategy)
Serializes an object to a
Data . |
Modifier and Type | Method and Description |
---|---|
<B extends Data> |
InternalSerializationService.convertData(Data data,
DataType type) |
BufferObjectDataInput |
InputOutputFactory.createInput(Data data,
InternalSerializationService service) |
BufferObjectDataInput |
InternalSerializationService.createObjectDataInput(Data data) |
PortableReader |
InternalSerializationService.createPortableReader(Data data) |
void |
InternalSerializationService.disposeData(Data data) |
ClassDefinition |
PortableContext.lookupClassDefinition(Data data) |
Modifier and Type | Class and Description |
---|---|
class |
HeapData
A
Data implementation where the content lives on the heap. |
Modifier and Type | Method and Description |
---|---|
<B extends Data> |
SerializationServiceV1.convertData(Data data,
DataType type) |
<B extends Data> |
AbstractSerializationService.toData(Object obj) |
<B extends Data> |
SerializationServiceV1.toData(Object obj,
DataType type) |
<B extends Data> |
SerializationServiceV1.toData(Object obj,
DataType type,
PartitioningStrategy strategy) |
<B extends Data> |
AbstractSerializationService.toData(Object obj,
PartitioningStrategy strategy) |
Modifier and Type | Method and Description |
---|---|
Data |
ObjectDataInputStream.readData() |
Modifier and Type | Method and Description |
---|---|
<B extends Data> |
SerializationServiceV1.convertData(Data data,
DataType type) |
BufferObjectDataInput |
AbstractSerializationService.createObjectDataInput(Data data) |
PortableReader |
SerializationServiceV1.createPortableReader(Data data) |
void |
AbstractSerializationService.disposeData(Data data) |
ObjectDataInput |
SerializationServiceV1.initDataSerializableInputAndSkipTheHeader(Data data)
Init the ObjectDataInput for the given Data skipping the serialization header-bytes and navigating to the position
from where the readData() starts reading the object fields.
|
void |
ObjectDataOutputStream.writeData(Data data) |
Modifier and Type | Method and Description |
---|---|
BufferObjectDataInput |
BufferPool.takeInputBuffer(Data data)
Takes an BufferObjectDataInput from the pool and initializes it with the given data.
|
BufferObjectDataInput |
BufferPoolImpl.takeInputBuffer(Data data) |
Modifier and Type | Method and Description |
---|---|
static Data |
ToHeapDataConverter.toHeapData(Data data)
Converts Data to HeapData.
|
Modifier and Type | Method and Description |
---|---|
static <C> Collection<Data> |
CollectionUtil.objectToDataCollection(Collection<C> collection,
SerializationService serializationService)
Converts a collection of any type to a collection of
Data . |
Modifier and Type | Method and Description |
---|---|
static Data |
ToHeapDataConverter.toHeapData(Data data)
Converts Data to HeapData.
|
Modifier and Type | Method and Description |
---|---|
static <C> void |
CollectionUtil.objectToDataCollection(Collection<C> objectCollection,
Collection<Data> dataCollection,
SerializationService serializationService,
String errorMessage)
Converts a collection of any type to a collection of
Data . |
Modifier and Type | Field and Description |
---|---|
protected Data |
EntryEventFilter.key |
Modifier and Type | Field and Description |
---|---|
protected Function<Object,Data> |
MapContainer.toDataFunction |
Modifier and Type | Method and Description |
---|---|
Data |
EntryEventFilter.getKey() |
Data |
MapEntries.getKey(int index) |
Data |
DataAwareEntryEvent.getKeyData() |
Data |
DataAwareEntryEvent.getMergingValueData() |
Data |
DataAwareEntryEvent.getNewValueData() |
Data |
DataAwareEntryEvent.getOldValueData() |
Data |
MapEntries.getValue(int index) |
Data |
MapServiceContext.toData(Object object) |
Data |
MapServiceContext.toData(Object object,
PartitioningStrategy partitionStrategy) |
Modifier and Type | Method and Description |
---|---|
List<Map.Entry<Data,Data>> |
MapEntries.entries() |
List<Map.Entry<Data,Data>> |
MapEntries.entries() |
Set<Data> |
MapKeySet.getKeySet() |
Set<EntryView<Data,Data>> |
MerkleTreeNodeEntries.getNodeEntries() |
Set<EntryView<Data,Data>> |
MerkleTreeNodeEntries.getNodeEntries() |
Collection<Data> |
MapValueCollection.getValues() |
Function<Object,Data> |
MapContainer.toData() |
Modifier and Type | Method and Description |
---|---|
void |
MapEntries.add(Data key,
Data value) |
Object |
JsonMetadataInitializer.createFromData(Data data) |
Object |
MetadataInitializer.createFromData(Data keyData)
Returns metadata for given binary data.
|
QueryableEntry |
MapContainer.newQueryEntry(Data key,
Object value) |
void |
MapService.onBeforeLock(String distributedObjectName,
Data key) |
Modifier and Type | Method and Description |
---|---|
void |
MapEntries.putAllToList(Collection<Map.Entry<Data,Data>> targetList) |
void |
MapEntries.putAllToList(Collection<Map.Entry<Data,Data>> targetList) |
void |
MerkleTreeNodeEntries.setNodeEntries(Set<EntryView<Data,Data>> nodeEntries) |
void |
MerkleTreeNodeEntries.setNodeEntries(Set<EntryView<Data,Data>> nodeEntries) |
Constructor and Description |
---|
DataAwareEntryEvent(Member from,
int eventType,
String source,
Data dataKey,
Data dataNewValue,
Data dataOldValue,
Data dataMergingValue,
SerializationService serializationService) |
EntryEventFilter(boolean includeValue,
Data key) |
LazyMapEntry(Data key,
Object value,
InternalSerializationService serializationService) |
LazyMapEntry(Data key,
Object value,
InternalSerializationService serializationService,
Extractors extractors) |
LockAwareLazyMapEntry(Data key,
Object value,
InternalSerializationService serializationService,
Extractors extractors,
Boolean locked) |
MapRecordKey(String mapName,
Data key) |
Constructor and Description |
---|
MapEntries(List<Map.Entry<Data,Data>> entries) |
MapEntries(List<Map.Entry<Data,Data>> entries) |
MapKeyLoader(String mapName,
OperationService opService,
IPartitionService ps,
ClusterService clusterService,
ExecutionService execService,
Function<Object,Data> serialize) |
MapKeySet(Set<Data> keySet) |
MapValueCollection(Collection<Data> values) |
MerkleTreeNodeEntries(int nodeOrder,
Set<EntryView<Data,Data>> nodeEntries) |
MerkleTreeNodeEntries(int nodeOrder,
Set<EntryView<Data,Data>> nodeEntries) |
Modifier and Type | Field and Description |
---|---|
protected Data |
EntryEventData.dataKey |
protected Data |
EntryEventData.dataMergingValue |
protected Data |
EntryEventData.dataNewValue |
protected Data |
EntryEventData.dataOldValue |
Modifier and Type | Method and Description |
---|---|
Data |
EntryEventData.getDataKey() |
Data |
EntryEventData.getDataMergingValue() |
Data |
EntryEventData.getDataNewValue() |
Data |
EntryEventData.getDataOldValue() |
Modifier and Type | Method and Description |
---|---|
int |
QueryCacheNaturalFilteringStrategy.doFilter(EventFilter filter,
Data dataKey,
Object oldValue,
Object dataValue,
EntryEventType eventType,
String mapNameOrNull) |
int |
DefaultEntryEventFilteringStrategy.doFilter(EventFilter filter,
Data dataKey,
Object oldValue,
Object dataValue,
EntryEventType eventType,
String mapNameOrNull)
Main entry point for filtering events according to given filter.
|
int |
FilteringStrategy.doFilter(EventFilter filter,
Data dataKey,
Object oldValue,
Object dataValue,
EntryEventType eventType,
String mapNameOrNull)
Main entry point for filtering events according to given filter.
|
protected boolean |
AbstractFilteringStrategy.evaluateQueryEventFilter(EventFilter filter,
Data dataKey,
Object testValue,
String mapNameOrNull)
Evalues the
filter using a CachedQueryEntry together with the
value Extractors configured for this map. |
EntryEventData |
EntryEventDataCache.getOrCreateEventData(String mapName,
Address caller,
Data dataKey,
Object newValue,
Object oldValue,
Object mergingValue,
int eventType,
boolean includingValues)
If an
EntryEventData for the given parameters is already cached then return the cached value, otherwise create,
cache and return the EntryEventData . |
protected boolean |
AbstractFilteringStrategy.processEntryEventFilter(EventFilter filter,
Data dataKey)
Evaluates filters of
EntryEventFilter type. |
void |
MapEventPublisherImpl.publishEvent(Address caller,
String mapName,
EntryEventType eventType,
Data dataKey,
Object oldValue,
Object dataValue) |
void |
MapEventPublisher.publishEvent(Address caller,
String mapName,
EntryEventType eventType,
Data dataKey,
Object oldValue,
Object dataValue)
Publish an event to the event subsystem.
|
void |
MapEventPublisherImpl.publishEvent(Address caller,
String mapName,
EntryEventType eventType,
Data dataKey,
Object oldValue,
Object value,
Object mergingValue) |
void |
MapEventPublisher.publishEvent(Address caller,
String mapName,
EntryEventType eventType,
Data dataKey,
Object oldValue,
Object dataValue,
Object dataMergingValue)
Publish an event to the event subsystem.
|
void |
MapEventPublisherImpl.publishWanRemove(String mapName,
Data key) |
void |
MapEventPublisher.publishWanRemove(String mapName,
Data key)
Notifies the WAN subsystem of a map entry removal on a replica owner.
|
Modifier and Type | Method and Description |
---|---|
void |
MapEventPublisherImpl.publishWanUpdate(String mapName,
EntryView<Data,Data> entryView,
boolean hasLoadProvenance) |
void |
MapEventPublisherImpl.publishWanUpdate(String mapName,
EntryView<Data,Data> entryView,
boolean hasLoadProvenance) |
void |
MapEventPublisher.publishWanUpdate(String mapName,
EntryView<Data,Data> entryView,
boolean hasLoadProvenance)
Notifies the WAN subsystem of a map update on a replica owner.
|
void |
MapEventPublisher.publishWanUpdate(String mapName,
EntryView<Data,Data> entryView,
boolean hasLoadProvenance)
Notifies the WAN subsystem of a map update on a replica owner.
|
Constructor and Description |
---|
EntryEventData(String source,
String mapName,
Address caller,
Data dataKey,
Data dataNewValue,
Data dataOldValue,
Data dataMergingValue,
int eventType) |
EntryEventData(String source,
String mapName,
Address caller,
Data dataKey,
Data dataNewValue,
Data dataOldValue,
int eventType) |
Modifier and Type | Method and Description |
---|---|
void |
EvictorImpl.evict(RecordStore recordStore,
Data excludedKey) |
void |
Evictor.evict(RecordStore recordStore,
Data excludedKey)
Evict supplied record-store.
|
Modifier and Type | Field and Description |
---|---|
protected List<Data> |
AbstractMapQueryPartitionIterator.segment |
Modifier and Type | Method and Description |
---|---|
protected List<Data> |
MapQueryPartitionIterator.fetch() |
protected abstract List<Data> |
AbstractMapQueryPartitionIterator.fetch() |
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractMapQueryPartitionIterator.setLastTableIndex(List<Data> segment,
int lastTableIndex) |
Constructor and Description |
---|
MapEntriesWithCursor(List<Map.Entry<Data,Data>> entries,
int nextTableIndexToReadFrom) |
MapEntriesWithCursor(List<Map.Entry<Data,Data>> entries,
int nextTableIndexToReadFrom) |
MapKeysWithCursor(List<Data> keys,
int nextTableIndexToReadFrom) |
Modifier and Type | Field and Description |
---|---|
protected Data |
InternalEventJournalMapEvent.dataKey |
protected Data |
InternalEventJournalMapEvent.dataNewValue |
protected Data |
InternalEventJournalMapEvent.dataOldValue |
Modifier and Type | Method and Description |
---|---|
Data |
InternalEventJournalMapEvent.getDataKey() |
Data |
InternalEventJournalMapEvent.getDataNewValue() |
Data |
InternalEventJournalMapEvent.getDataOldValue() |
Modifier and Type | Method and Description |
---|---|
void |
RingbufferMapEventJournalImpl.writeAddEvent(EventJournalConfig journalConfig,
ObjectNamespace namespace,
int partitionId,
Data key,
Object value) |
void |
MapEventJournal.writeAddEvent(EventJournalConfig journalConfig,
ObjectNamespace namespace,
int partitionId,
Data key,
Object value)
Writes an
EntryEventType.ADDED to the event journal. |
void |
RingbufferMapEventJournalImpl.writeEvictEvent(EventJournalConfig journalConfig,
ObjectNamespace namespace,
int partitionId,
Data key,
Object value) |
void |
MapEventJournal.writeEvictEvent(EventJournalConfig journalConfig,
ObjectNamespace namespace,
int partitionId,
Data key,
Object value)
Writes an
EntryEventType.EVICTED to the event journal. |
void |
RingbufferMapEventJournalImpl.writeLoadEvent(EventJournalConfig journalConfig,
ObjectNamespace namespace,
int partitionId,
Data key,
Object value) |
void |
MapEventJournal.writeLoadEvent(EventJournalConfig journalConfig,
ObjectNamespace namespace,
int partitionId,
Data key,
Object value)
Writes an
EntryEventType.LOADED to the event journal. |
void |
RingbufferMapEventJournalImpl.writeRemoveEvent(EventJournalConfig journalConfig,
ObjectNamespace namespace,
int partitionId,
Data key,
Object value) |
void |
MapEventJournal.writeRemoveEvent(EventJournalConfig journalConfig,
ObjectNamespace namespace,
int partitionId,
Data key,
Object value)
Writes an
EntryEventType.REMOVED to the event journal. |
void |
RingbufferMapEventJournalImpl.writeUpdateEvent(EventJournalConfig journalConfig,
ObjectNamespace namespace,
int partitionId,
Data key,
Object oldValue,
Object newValue) |
void |
MapEventJournal.writeUpdateEvent(EventJournalConfig journalConfig,
ObjectNamespace namespace,
int partitionId,
Data key,
Object oldValue,
Object newValue)
Writes an
EntryEventType.UPDATED to the event journal. |
Constructor and Description |
---|
InternalEventJournalMapEvent(Data dataKey,
Data dataNewValue,
Data dataOldValue,
int eventType) |
Modifier and Type | Method and Description |
---|---|
protected Data |
AbstractMapDataStore.toHeapData(Object obj) |
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 |
---|---|
Object |
WriteBehindStore.add(Data key,
Object value,
long expirationTime,
long now,
UUID transactionId) |
Object |
WriteBehindStore.addBackup(Data key,
Object value,
long expirationTime,
long time,
UUID transactionId)
Throw no exception while putting backup entry.
|
void |
WriteBehindStore.addTransient(Data key,
long now) |
Object |
WriteBehindStore.flush(Data key,
Object value,
boolean backup) |
Object |
WriteBehindStore.load(Data key) |
boolean |
WriteBehindStore.loadable(Data key) |
void |
WriteBehindStore.remove(Data key,
long now,
UUID transactionId) |
void |
WriteBehindStore.removeBackup(Data key,
long time,
UUID transactionId) |
Modifier and Type | Method and Description |
---|---|
void |
WriteBehindStore.add(DelayedEntry<Data,Object> delayedEntry) |
void |
WriteBehindStore.addForcibly(DelayedEntry<Data,Object> delayedEntry) |
Modifier and Type | Method and Description |
---|---|
Object |
WriteThroughStore.add(Data key,
Object value,
long expirationTime,
long time,
UUID transactionId) |
Object |
WriteThroughStore.addBackup(Data key,
Object value,
long expirationTime,
long time,
UUID transactionId) |
void |
WriteThroughStore.addTransient(Data key,
long now) |
Object |
WriteThroughStore.flush(Data key,
Object value,
boolean backup) |
Object |
WriteThroughStore.load(Data key) |
boolean |
WriteThroughStore.loadable(Data key) |
void |
WriteThroughStore.remove(Data key,
long time,
UUID transactionId) |
void |
WriteThroughStore.removeBackup(Data key,
long time,
UUID transactionId) |
Modifier and Type | Method and Description |
---|---|
int |
MemberMinimalPartitionService.getPartitionId(Data key) |
Modifier and Type | Field and Description |
---|---|
protected Data |
KeyBasedMapOperation.dataKey |
protected Data |
PutBackupOperation.dataKey |
protected Data |
ReadonlyKeyBasedMapOperation.dataKey |
protected Data |
BaseRemoveOperation.dataOldValue |
protected Data |
KeyBasedMapOperation.dataValue |
protected Data |
PutBackupOperation.dataValue |
protected Data |
EntryOffloadableSetUnlockOperation.newValue |
protected Data |
EntryOffloadableSetUnlockOperation.oldValue |
Modifier and Type | Field and Description |
---|---|
protected Set<Data> |
MultipleEntryOperation.keys |
protected Set<Data> |
PartitionWideEntryOperation.keysFromIndex |
protected SplitBrainMergePolicy<Data,SplitBrainMergeTypes.MapMergeTypes> |
MergeOperationFactory.mergePolicy |
Modifier and Type | Method and Description |
---|---|
Data |
KeyBasedMapOperation.getKey() |
Data |
WanEventHolder.getKey() |
Data |
GetOperation.getResponse() |
Data |
EntryOperator.getResult() |
Data |
KeyBasedMapOperation.getValue() |
Data |
WanEventHolder.getValue() |
Modifier and Type | Method and Description |
---|---|
MapOperation |
MapOperationProvider.createContainsKeyOperation(String name,
Data dataKey) |
MapOperation |
DefaultMapOperationProvider.createContainsKeyOperation(String name,
Data dataKey) |
OperationFactory |
MapOperationProvider.createContainsValueOperationFactory(String name,
Data testValue) |
OperationFactory |
DefaultMapOperationProvider.createContainsValueOperationFactory(String name,
Data testValue) |
MapOperation |
MapOperationProvider.createDeleteOperation(String name,
Data key,
boolean disableWanReplicationEvent)
Creates a delete operation for an entry with key equal to
key from the map named name . |
MapOperation |
DefaultMapOperationProvider.createDeleteOperation(String name,
Data key,
boolean disableWanReplicationEvent) |
MapOperation |
MapOperationProvider.createEntryOperation(String name,
Data dataKey,
EntryProcessor entryProcessor) |
MapOperation |
DefaultMapOperationProvider.createEntryOperation(String name,
Data dataKey,
EntryProcessor entryProcessor) |
MapOperation |
MapOperationProvider.createEvictOperation(String name,
Data dataKey,
boolean asyncBackup) |
MapOperation |
DefaultMapOperationProvider.createEvictOperation(String name,
Data dataKey,
boolean asyncBackup) |
MapOperation |
MapOperationProvider.createGetEntryViewOperation(String name,
Data dataKey) |
MapOperation |
DefaultMapOperationProvider.createGetEntryViewOperation(String name,
Data dataKey) |
MapOperation |
MapOperationProvider.createGetOperation(String name,
Data dataKey) |
MapOperation |
DefaultMapOperationProvider.createGetOperation(String name,
Data dataKey) |
MapOperation |
MapOperationProvider.createPutIfAbsentOperation(String name,
Data key,
Data value,
long ttl,
long maxIdle) |
MapOperation |
DefaultMapOperationProvider.createPutIfAbsentOperation(String name,
Data key,
Data value,
long ttl,
long maxIdle) |
MapOperation |
MapOperationProvider.createPutOperation(String name,
Data key,
Data value,
long ttl,
long maxIdle) |
MapOperation |
DefaultMapOperationProvider.createPutOperation(String name,
Data key,
Data value,
long ttl,
long maxIdle) |
MapOperation |
MapOperationProvider.createPutTransientOperation(String name,
Data key,
Data value,
long ttl,
long maxIdle) |
MapOperation |
DefaultMapOperationProvider.createPutTransientOperation(String name,
Data keyData,
Data valueData,
long ttl,
long maxIdle) |
MapOperation |
MapOperationProvider.createRemoveIfSameOperation(String name,
Data dataKey,
Data value) |
MapOperation |
DefaultMapOperationProvider.createRemoveIfSameOperation(String name,
Data dataKey,
Data value) |
MapOperation |
MapOperationProvider.createRemoveOperation(String name,
Data key) |
MapOperation |
DefaultMapOperationProvider.createRemoveOperation(String name,
Data key) |
MapOperation |
MapOperationProvider.createReplaceIfSameOperation(String name,
Data dataKey,
Data expect,
Data update) |
MapOperation |
DefaultMapOperationProvider.createReplaceIfSameOperation(String name,
Data dataKey,
Data expect,
Data update) |
MapOperation |
MapOperationProvider.createReplaceOperation(String name,
Data dataKey,
Data value) |
MapOperation |
DefaultMapOperationProvider.createReplaceOperation(String name,
Data dataKey,
Data value) |
MapOperation |
MapOperationProvider.createSetOperation(String name,
Data dataKey,
Data value,
long ttl,
long maxIdle) |
MapOperation |
DefaultMapOperationProvider.createSetOperation(String name,
Data dataKey,
Data value,
long ttl,
long maxIdle) |
MapOperation |
MapOperationProvider.createSetTtlOperation(String name,
Data key,
long ttl) |
MapOperation |
DefaultMapOperationProvider.createSetTtlOperation(String name,
Data key,
long ttl) |
MapOperation |
MapOperationProvider.createTryPutOperation(String name,
Data dataKey,
Data value,
long timeout) |
MapOperation |
DefaultMapOperationProvider.createTryPutOperation(String name,
Data dataKey,
Data value,
long timeout) |
MapOperation |
MapOperationProvider.createTryRemoveOperation(String name,
Data dataKey,
long timeout) |
MapOperation |
DefaultMapOperationProvider.createTryRemoveOperation(String name,
Data dataKey,
long timeout) |
MapOperation |
MapOperationProvider.createTxnDeleteOperation(String name,
Data dataKey,
long version) |
MapOperation |
DefaultMapOperationProvider.createTxnDeleteOperation(String name,
Data dataKey,
long version) |
MapOperation |
MapOperationProvider.createTxnLockAndGetOperation(String name,
Data dataKey,
long timeout,
long ttl,
UUID ownerUuid,
boolean shouldLoad,
boolean blockReads) |
MapOperation |
DefaultMapOperationProvider.createTxnLockAndGetOperation(String name,
Data dataKey,
long timeout,
long ttl,
UUID ownerUuid,
boolean shouldLoad,
boolean blockReads) |
MapOperation |
MapOperationProvider.createTxnSetOperation(String name,
Data dataKey,
Data value,
long version,
long ttl) |
MapOperation |
DefaultMapOperationProvider.createTxnSetOperation(String name,
Data dataKey,
Data value,
long version,
long ttl) |
protected void |
MapOperation.evict(Data justAddedKey) |
EntryOperator |
EntryOperator.init(Data dataKey,
Object oldValue,
Object newValue,
Data result,
EntryEventType eventType) |
void |
MapOperation.invalidateNearCache(Data key) |
EntryOperator |
EntryOperator.operateOnKey(Data dataKey) |
EntryOperator |
EntryOperator.operateOnKeyValue(Data dataKey,
Object oldValue) |
protected void |
MapOperation.publishLoadAsWanUpdate(Data dataKey,
Object value) |
protected void |
MapOperation.publishWanRemove(Data dataKey) |
protected void |
MapOperation.publishWanUpdate(Data dataKey,
Object value) |
Modifier and Type | Method and Description |
---|---|
OperationFactory |
MapOperationProvider.createGetAllOperationFactory(String name,
List<Data> keys) |
OperationFactory |
DefaultMapOperationProvider.createGetAllOperationFactory(String name,
List<Data> keys) |
MapOperation |
MapOperationProvider.createLoadAllOperation(String name,
List<Data> keys,
boolean replaceExistingValues)
Creates an operation to load entry values for the provided
keys on
the partition owner. |
MapOperation |
DefaultMapOperationProvider.createLoadAllOperation(String name,
List<Data> keys,
boolean replaceExistingValues) |
OperationFactory |
MapOperationProvider.createLoadAllOperationFactory(String name,
List<Data> keys,
boolean replaceExistingValues) |
OperationFactory |
DefaultMapOperationProvider.createLoadAllOperationFactory(String name,
List<Data> keys,
boolean replaceExistingValues) |
MapOperation |
MapOperationProvider.createMergeOperation(String name,
SplitBrainMergeTypes.MapMergeTypes mergingValue,
SplitBrainMergePolicy<Data,SplitBrainMergeTypes.MapMergeTypes> mergePolicy,
boolean disableWanReplicationEvent) |
MapOperation |
DefaultMapOperationProvider.createMergeOperation(String name,
SplitBrainMergeTypes.MapMergeTypes mergingValue,
SplitBrainMergePolicy<Data,SplitBrainMergeTypes.MapMergeTypes> mergePolicy,
boolean disableWanReplicationEvent) |
OperationFactory |
MapOperationProvider.createMergeOperationFactory(String name,
int[] partitions,
List<SplitBrainMergeTypes.MapMergeTypes>[] mergingEntries,
SplitBrainMergePolicy<Data,SplitBrainMergeTypes.MapMergeTypes> mergePolicy) |
OperationFactory |
DefaultMapOperationProvider.createMergeOperationFactory(String name,
int[] partitions,
List<SplitBrainMergeTypes.MapMergeTypes>[] mergingEntries,
SplitBrainMergePolicy<Data,SplitBrainMergeTypes.MapMergeTypes> mergePolicy) |
OperationFactory |
MapOperationProvider.createMultipleEntryOperationFactory(String name,
Set<Data> keys,
EntryProcessor entryProcessor) |
OperationFactory |
DefaultMapOperationProvider.createMultipleEntryOperationFactory(String name,
Set<Data> keys,
EntryProcessor entryProcessor) |
MapOperation |
MapOperationProvider.createPutFromLoadAllOperation(String name,
List<Data> keyValueSequence,
boolean expirationTime) |
MapOperation |
DefaultMapOperationProvider.createPutFromLoadAllOperation(String name,
List<Data> keyValueSequence,
boolean includesExpirationTime) |
protected void |
MapOperation.invalidateNearCache(List<Data> keys) |
Modifier and Type | Method and Description |
---|---|
Data |
NearCachedMapProxyImpl.executeOnKeyInternal(Object key,
EntryProcessor entryProcessor) |
protected Data |
NearCachedMapProxyImpl.putIfAbsentInternal(Object key,
Data value,
long ttl,
TimeUnit ttlUnit,
long maxIdle,
TimeUnit maxIdleUnit) |
protected Data |
NearCachedMapProxyImpl.putInternal(Object key,
Data valueData,
long ttl,
TimeUnit ttlUnit,
long maxIdle,
TimeUnit maxIdleUnit) |
protected Data |
NearCachedMapProxyImpl.removeInternal(Object key) |
protected Data |
NearCachedMapProxyImpl.replaceInternal(Object key,
Data value) |
Modifier and Type | Method and Description |
---|---|
protected InternalCompletableFuture<Data> |
NearCachedMapProxyImpl.getAsyncInternal(Object key) |
protected InternalCompletableFuture<Data> |
NearCachedMapProxyImpl.putAsyncInternal(Object key,
Data valueData,
long ttl,
TimeUnit ttlUnit,
long maxIdle,
TimeUnit maxIdleUnit) |
protected InternalCompletableFuture<Data> |
NearCachedMapProxyImpl.removeAsyncInternal(Object key) |
protected InternalCompletableFuture<Data> |
NearCachedMapProxyImpl.setAsyncInternal(Object key,
Data valueData,
long ttl,
TimeUnit ttlUnit,
long maxIdle,
TimeUnit maxIdleUnit) |
Modifier and Type | Method and Description |
---|---|
protected InternalCompletableFuture<Data> |
NearCachedMapProxyImpl.putAsyncInternal(Object key,
Data valueData,
long ttl,
TimeUnit ttlUnit,
long maxIdle,
TimeUnit maxIdleUnit) |
protected Data |
NearCachedMapProxyImpl.putIfAbsentInternal(Object key,
Data value,
long ttl,
TimeUnit ttlUnit,
long maxIdle,
TimeUnit maxIdleUnit) |
protected Data |
NearCachedMapProxyImpl.putInternal(Object key,
Data valueData,
long ttl,
TimeUnit ttlUnit,
long maxIdle,
TimeUnit maxIdleUnit) |
protected void |
NearCachedMapProxyImpl.putTransientInternal(Object key,
Data value,
long ttl,
TimeUnit ttlUnit,
long maxIdle,
TimeUnit maxIdleUnit) |
protected boolean |
NearCachedMapProxyImpl.removeInternal(Object key,
Data value) |
protected Data |
NearCachedMapProxyImpl.replaceInternal(Object key,
Data value) |
protected boolean |
NearCachedMapProxyImpl.replaceInternal(Object key,
Data expect,
Data update) |
protected InternalCompletableFuture<Data> |
NearCachedMapProxyImpl.setAsyncInternal(Object key,
Data valueData,
long ttl,
TimeUnit ttlUnit,
long maxIdle,
TimeUnit maxIdleUnit) |
protected void |
NearCachedMapProxyImpl.setInternal(Object key,
Data valueData,
long ttl,
TimeUnit ttlUnit,
long maxIdle,
TimeUnit maxIdleUnit) |
protected boolean |
NearCachedMapProxyImpl.tryPutInternal(Object key,
Data value,
long timeout,
TimeUnit timeunit) |
Modifier and Type | Method and Description |
---|---|
void |
NearCachedMapProxyImpl.executeOnEntriesInternal(EntryProcessor entryProcessor,
Predicate predicate,
List<Data> resultingKeyValuePairs) |
protected void |
NearCachedMapProxyImpl.getAllInternal(Set<K> keys,
List<Data> dataKeys,
List<Object> resultingKeyValuePairs) |
protected void |
NearCachedMapProxyImpl.loadInternal(Set<K> keys,
Iterable<Data> dataKeys,
boolean replaceExistingValues) |
<R> InternalCompletableFuture<Map<K,R>> |
NearCachedMapProxyImpl.submitToKeysInternal(Set<K> keys,
Set<Data> dataKeys,
EntryProcessor<K,V,R> entryProcessor) |
Modifier and Type | Method and Description |
---|---|
Data |
QueryResultRow.getKey() |
Data |
QueryResultRow.getValue() |
Data |
QueryResultRow.setValue(Data value) |
Modifier and Type | Method and Description |
---|---|
QueryableEntry |
QueryEntryFactory.newEntry(Data key,
Object value) |
Data |
QueryResultRow.setValue(Data value) |
Constructor and Description |
---|
QueryEventFilter(boolean includeValue,
Data key,
Predicate predicate) |
QueryResultRow(Data key,
Data valueData) |
Modifier and Type | Method and Description |
---|---|
Data |
DefaultQueryCacheEventData.getDataKey() |
Data |
QueryCacheEventData.getDataKey() |
Data |
DefaultQueryCacheEventData.getDataNewValue() |
Data |
QueryCacheEventData.getDataNewValue() |
Data |
DefaultQueryCacheEventData.getDataOldValue() |
Data |
QueryCacheEventData.getDataOldValue() |
Data |
LocalEntryEventData.getKeyData() |
Data |
LocalEntryEventData.getOldValueData() |
Data |
LocalEntryEventData.getValueData() |
Modifier and Type | Method and Description |
---|---|
void |
DefaultQueryCacheEventData.setDataKey(Data dataKey) |
void |
DefaultQueryCacheEventData.setDataNewValue(Data dataNewValue) |
void |
DefaultQueryCacheEventData.setDataOldValue(Data dataOldValue) |
QueryCacheEventDataBuilder |
QueryCacheEventDataBuilder.withDataKey(Data dataKey) |
QueryCacheEventDataBuilder |
QueryCacheEventDataBuilder.withDataNewValue(Data dataNewValue) |
QueryCacheEventDataBuilder |
QueryCacheEventDataBuilder.withDataOldValue(Data dataOldValue) |
Modifier and Type | Method and Description |
---|---|
<C extends EvictionCandidate<Data,QueryCacheRecord>> |
QueryCacheRecordHashMap.tryEvict(C evictionCandidate,
EvictionListener<Data,QueryCacheRecord> evictionListener) |
Modifier and Type | Method and Description |
---|---|
Set<Map.Entry<Data,QueryCacheRecord>> |
QueryCacheRecordStore.entrySet() |
Set<Data> |
QueryCacheRecordStore.keySet() |
Modifier and Type | Method and Description |
---|---|
QueryCacheRecord |
QueryCacheRecordStore.add(Data keyData,
Data valueData) |
QueryCacheRecord |
QueryCacheRecordStore.addWithoutEvictionCheck(Data keyData,
Data valueData) |
boolean |
QueryCacheRecordStore.containsKey(Data keyData) |
protected com.hazelcast.map.impl.querycache.subscriber.QueryCacheRecordHashMap.QueryCacheEvictableSamplingEntry |
QueryCacheRecordHashMap.createSamplingEntry(Data key,
QueryCacheRecord value) |
QueryCacheRecord |
QueryCacheRecordStore.get(Data keyData) |
QueryCacheRecord |
QueryCacheRecordStore.remove(Data keyData) |
Modifier and Type | Method and Description |
---|---|
<C extends EvictionCandidate<Data,QueryCacheRecord>> |
QueryCacheRecordHashMap.tryEvict(C evictionCandidate,
EvictionListener<Data,QueryCacheRecord> evictionListener) |
Modifier and Type | Method and Description |
---|---|
QueryCacheRecord |
DataQueryCacheRecordFactory.createRecord(Data valueData) |
QueryCacheRecord |
ObjectQueryCacheRecordFactory.createRecord(Data valueData) |
QueryCacheRecord |
QueryCacheRecordFactory.createRecord(Data value)
Creates new
QueryCacheRecord . |
Modifier and Type | Field and Description |
---|---|
protected Data |
AbstractRecord.key |
Modifier and Type | Method and Description |
---|---|
Data |
Record.getKey() |
Data |
AbstractRecord.getKey() |
Data |
RecordReplicationInfo.getKey() |
Data |
RecordReplicationInfo.getValue() |
Modifier and Type | Method and Description |
---|---|
Record<Data> |
DataRecordFactory.newRecord(Data key,
Object value) |
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) |
void |
Record.setKey(Data key) |
void |
AbstractRecord.setKey(Data key) |
Modifier and Type | Method and Description |
---|---|
void |
DataRecordFactory.setValue(Record<Data> record,
Object value) |
Constructor and Description |
---|
RecordReplicationInfo(Data key,
Data value,
RecordInfo recordInfo) |
Modifier and Type | Method and Description |
---|---|
Data |
RecordStore.readBackupData(Data key)
|
Data |
DefaultRecordStore.readBackupData(Data key)
This method is called directly by user threads, in other words
it is called outside of the partition threads.
|
Modifier and Type | Method and Description |
---|---|
protected List<Data> |
DefaultRecordStore.getKeysFromRecords(Collection<Record> clearableRecords) |
MapDataStore<Data,Object> |
RecordStore.getMapDataStore() |
MapDataStore<Data,Object> |
DefaultRecordStore.getMapDataStore() |
protected Map<Data,Object> |
DefaultRecordStore.loadEntries(Set<Data> keys,
Address callerAddress) |
Modifier and Type | Method and Description |
---|---|
boolean |
RecordStore.canAcquireLock(Data key,
UUID caller,
long threadId) |
boolean |
DefaultRecordStore.canAcquireLock(Data key,
UUID caller,
long threadId) |
boolean |
StorageImpl.containsKey(Data key) |
boolean |
RecordStore.containsKey(Data dataKey,
Address callerAddress) |
boolean |
DefaultRecordStore.containsKey(Data key,
Address callerAddress) |
Record |
RecordStore.createRecord(Data key,
Object value,
long ttlMillis,
long maxIdle,
long now) |
protected <E extends SampleableConcurrentHashMap.SamplingEntry> |
StorageSCHM.createSamplingEntry(Data key,
R record) |
boolean |
RecordStore.delete(Data dataKey,
CallerProvenance provenance) |
boolean |
DefaultRecordStore.delete(Data key,
CallerProvenance provenance) |
Object |
RecordStore.evict(Data key,
boolean backup) |
Object |
DefaultRecordStore.evict(Data key,
boolean backup) |
void |
RecordStore.evictEntries(Data excludedKey)
Evicts entries from this record-store.
|
void |
AbstractEvictableRecordStore.evictEntries(Data excludedKey) |
boolean |
RecordStore.existInMemory(Data key)
Checks if the key exist in memory without trying to load data from map-loader
|
boolean |
DefaultRecordStore.existInMemory(Data key) |
boolean |
RecordStore.extendLock(Data key,
UUID caller,
long threadId,
long ttl) |
boolean |
DefaultRecordStore.extendLock(Data key,
UUID caller,
long threadId,
long ttl) |
boolean |
RecordStore.forceUnlock(Data dataKey) |
boolean |
DefaultRecordStore.forceUnlock(Data dataKey) |
R |
StorageImpl.get(Data key) |
Object |
RecordStore.get(Data dataKey,
boolean backup,
Address callerAddress)
Gets record from
RecordStore . |
Object |
DefaultRecordStore.get(Data key,
boolean backup,
Address callerAddress) |
R |
StorageImpl.getIfSameKey(Data key) |
String |
RecordStore.getLockOwnerInfo(Data key) |
String |
DefaultRecordStore.getLockOwnerInfo(Data key) |
R |
RecordStore.getRecord(Data key) |
Record |
DefaultRecordStore.getRecord(Data key) |
R |
RecordStore.getRecordOrNull(Data key)
Returns live record or null if record is already expired.
|
Record |
DefaultRecordStore.getRecordOrNull(Data key) |
protected Record |
DefaultRecordStore.getRecordOrNull(Data key,
long now,
boolean backup) |
protected boolean |
DefaultRecordStore.isKeyAndValueLoadable(Data key,
Object value) |
boolean |
RecordStore.isLocked(Data key) |
boolean |
DefaultRecordStore.isLocked(Data dataKey) |
boolean |
RecordStore.isLockedBy(Data key,
UUID caller,
long threadId) |
boolean |
DefaultRecordStore.isLockedBy(Data key,
UUID caller,
long threadId) |
boolean |
RecordStore.isTransactionallyLocked(Data key) |
boolean |
DefaultRecordStore.isTransactionallyLocked(Data key) |
Record |
RecordStore.loadRecordOrNull(Data key,
boolean backup,
Address callerAddress) |
Record |
DefaultRecordStore.loadRecordOrNull(Data key,
boolean backup,
Address callerAddress) |
boolean |
RecordStore.localLock(Data key,
UUID caller,
long threadId,
long referenceId,
long ttl) |
boolean |
DefaultRecordStore.localLock(Data key,
UUID caller,
long threadId,
long referenceId,
long ttl) |
boolean |
RecordStore.lock(Data key,
UUID caller,
long threadId,
long referenceId,
long ttl) |
boolean |
DefaultRecordStore.lock(Data key,
UUID caller,
long threadId,
long referenceId,
long ttl) |
void |
RecordStoreMutationObserver.onEvictRecord(Data key,
R record)
Called when a record is evicted from the observed
RecordStore |
void |
EventJournalWriterRecordStoreMutationObserver.onEvictRecord(Data key,
Record record) |
void |
JsonMetadataRecordStoreMutationObserver.onEvictRecord(Data key,
Record record) |
void |
RecordStoreMutationObserver.onLoadRecord(Data key,
R record)
Called when a record is loaded into the observed
RecordStore |
void |
EventJournalWriterRecordStoreMutationObserver.onLoadRecord(Data key,
Record record) |
void |
JsonMetadataRecordStoreMutationObserver.onLoadRecord(Data key,
Record record) |
void |
RecordStoreMutationObserver.onPutRecord(Data key,
R record)
Called when a new record is added to the
RecordStore |
void |
EventJournalWriterRecordStoreMutationObserver.onPutRecord(Data key,
Record record) |
void |
JsonMetadataRecordStoreMutationObserver.onPutRecord(Data key,
Record record) |
void |
RecordStoreMutationObserver.onRemoveRecord(Data key,
R record)
Called when a record is removed from the observed
RecordStore |
void |
EventJournalWriterRecordStoreMutationObserver.onRemoveRecord(Data key,
Record record) |
void |
JsonMetadataRecordStoreMutationObserver.onRemoveRecord(Data key,
Record record) |
void |
RecordStoreMutationObserver.onReplicationPutRecord(Data key,
R record)
Called when a new record is added to the
RecordStore due
to replication |
void |
EventJournalWriterRecordStoreMutationObserver.onReplicationPutRecord(Data key,
Record record) |
void |
JsonMetadataRecordStoreMutationObserver.onReplicationPutRecord(Data key,
Record record) |
void |
EventJournalWriterRecordStoreMutationObserver.onUpdateRecord(Data key,
Record record,
Object newValue) |
void |
JsonMetadataRecordStoreMutationObserver.onUpdateRecord(Data key,
Record record,
Object newValue) |
void |
RecordStoreMutationObserver.onUpdateRecord(Data key,
R record,
Object newValue)
Called when a new record is updated in the observed
RecordStore |
Object |
RecordStore.put(Data dataKey,
Object dataValue,
long ttl,
long maxIdle) |
Object |
DefaultRecordStore.put(Data key,
Object value,
long ttl,
long maxIdle) |
void |
StorageImpl.put(Data key,
R record) |
R |
RecordStore.putBackup(Data key,
Object value,
CallerProvenance provenance) |
Record |
DefaultRecordStore.putBackup(Data key,
Object value,
CallerProvenance provenance) |
R |
RecordStore.putBackup(Data key,
Object value,
long ttl,
long maxIdle,
boolean putTransient,
CallerProvenance provenance) |
Record |
DefaultRecordStore.putBackup(Data key,
Object value,
long ttl,
long maxIdle,
boolean putTransient,
CallerProvenance provenance) |
R |
RecordStore.putBackupTxn(Data dataKey,
Data dataValue,
long ttl,
long maxIdle,
boolean putTransient,
CallerProvenance callerProvenance,
UUID transactionId) |
Record |
DefaultRecordStore.putBackupTxn(Data key,
Data value,
long ttl,
long maxIdle,
boolean putTransient,
CallerProvenance provenance,
UUID transactionId) |
Object |
RecordStore.putFromLoad(Data key,
Object value,
Address callerAddress)
Puts key-value pair to map which is the result of a load from map store operation.
|
Object |
DefaultRecordStore.putFromLoad(Data key,
Object value,
Address callerAddress) |
Object |
RecordStore.putFromLoad(Data key,
Object value,
long expirationTime,
Address callerAddress) |
Object |
DefaultRecordStore.putFromLoad(Data key,
Object value,
long expirationTime,
Address callerAddress) |
Object |
RecordStore.putFromLoadBackup(Data key,
Object value)
Puts key-value pair to map which is the result of a load from map store operation on backup.
|
Object |
DefaultRecordStore.putFromLoadBackup(Data key,
Object value) |
Object |
RecordStore.putFromLoadBackup(Data key,
Object value,
long expirationTime) |
Object |
DefaultRecordStore.putFromLoadBackup(Data key,
Object value,
long expirationTime) |
Object |
RecordStore.putIfAbsent(Data dataKey,
Object value,
long ttl,
long maxIdle,
Address callerAddress) |
Object |
DefaultRecordStore.putIfAbsent(Data key,
Object value,
long ttl,
long maxIdle,
Address callerAddress) |
protected Object |
DefaultRecordStore.putInternal(Data key,
Object value,
long ttl,
long maxIdle,
UUID transactionId,
boolean loadFromStore,
boolean countAsAccess) |
void |
RecordStore.putRecord(Data key,
R record)
Puts a data key and a record value to record-store.
|
void |
DefaultRecordStore.putRecord(Data key,
Record record) |
Object |
RecordStore.putTransient(Data dataKey,
Object value,
long ttl,
long maxIdle) |
Object |
DefaultRecordStore.putTransient(Data key,
Object value,
long ttl,
long maxIdle) |
Data |
RecordStore.readBackupData(Data key)
|
Data |
DefaultRecordStore.readBackupData(Data key)
This method is called directly by user threads, in other words
it is called outside of the partition threads.
|
Object |
RecordStore.remove(Data key,
CallerProvenance provenance) |
Object |
DefaultRecordStore.remove(Data key,
CallerProvenance callerProvenance) |
boolean |
RecordStore.remove(Data dataKey,
Object testValue) |
boolean |
DefaultRecordStore.remove(Data key,
Object testValue) |
void |
RecordStore.removeBackup(Data dataKey,
CallerProvenance provenance)
Similar to
RecordStore.remove(Data, CallerProvenance)
except removeBackup doesn't touch mapstore since it does not return previous value. |
void |
DefaultRecordStore.removeBackup(Data key,
CallerProvenance provenance) |
void |
RecordStore.removeBackupTxn(Data dataKey,
CallerProvenance callerProvenance,
UUID transactionId) |
void |
DefaultRecordStore.removeBackupTxn(Data key,
CallerProvenance provenance,
UUID transactionId) |
protected Object |
DefaultRecordStore.removeRecord(Data key,
Record record,
long now,
CallerProvenance provenance,
UUID transactionId) |
Object |
RecordStore.removeTxn(Data dataKey,
CallerProvenance callerProvenance,
UUID transactionId) |
Object |
DefaultRecordStore.removeTxn(Data dataKey,
CallerProvenance callerProvenance,
UUID transactionId) |
Object |
RecordStore.replace(Data dataKey,
Object update) |
Object |
DefaultRecordStore.replace(Data key,
Object update) |
boolean |
RecordStore.replace(Data dataKey,
Object expect,
Object update)
Sets the value to the given updated value
if
ValueComparator.isEqual(java.lang.Object, java.lang.Object, com.hazelcast.internal.serialization.SerializationService) comparison
of current value and expected value is true . |
boolean |
DefaultRecordStore.replace(Data key,
Object expect,
Object update) |
Object |
RecordStore.set(Data dataKey,
Object value,
long ttl,
long maxIdle) |
Object |
DefaultRecordStore.set(Data dataKey,
Object value,
long ttl,
long maxIdle) |
boolean |
RecordStore.setTtl(Data key,
long ttl) |
boolean |
DefaultRecordStore.setTtl(Data key,
long ttl) |
Object |
RecordStore.setTxn(Data dataKey,
Object value,
long ttl,
long maxIdle,
UUID transactionId) |
Object |
DefaultRecordStore.setTxn(Data dataKey,
Object value,
long ttl,
long maxIdle,
UUID transactionId) |
boolean |
RecordStore.setWithUncountedAccess(Data dataKey,
Object value,
long ttl,
long maxIdle)
Does exactly the same thing as
RecordStore.set(Data, Object, long, long) except the invocation is not counted as
a read access while updating the access statics. |
boolean |
DefaultRecordStore.setWithUncountedAccess(Data dataKey,
Object value,
long ttl,
long maxIdle) |
boolean |
RecordStore.txnLock(Data key,
UUID caller,
long threadId,
long referenceId,
long ttl,
boolean blockReads) |
boolean |
DefaultRecordStore.txnLock(Data key,
UUID caller,
long threadId,
long referenceId,
long ttl,
boolean blockReads) |
boolean |
RecordStore.unlock(Data key,
UUID caller,
long threadId,
long referenceId) |
boolean |
DefaultRecordStore.unlock(Data key,
UUID caller,
long threadId,
long referenceId) |
void |
StorageImpl.updateRecordValue(Data key,
R record,
Object value) |
Modifier and Type | Method and Description |
---|---|
MapEntries |
RecordStore.getAll(Set<Data> keySet,
Address callerAddress) |
MapEntries |
DefaultRecordStore.getAll(Set<Data> keys,
Address callerAddress) |
void |
RecordStore.loadAllFromStore(List<Data> keys,
boolean replaceExistingValues)
Triggers loading values for the given
keys from the
defined MapLoader . |
void |
DefaultRecordStore.loadAllFromStore(List<Data> keys,
boolean replaceExistingValues) |
protected Map<Data,Object> |
DefaultRecordStore.loadEntries(Set<Data> keys,
Address callerAddress) |
boolean |
RecordStore.merge(SplitBrainMergeTypes.MapMergeTypes mergingEntry,
SplitBrainMergePolicy<Data,SplitBrainMergeTypes.MapMergeTypes> mergePolicy) |
boolean |
DefaultRecordStore.merge(SplitBrainMergeTypes.MapMergeTypes mergingEntry,
SplitBrainMergePolicy<Data,SplitBrainMergeTypes.MapMergeTypes> mergePolicy) |
boolean |
RecordStore.merge(SplitBrainMergeTypes.MapMergeTypes mergingEntry,
SplitBrainMergePolicy<Data,SplitBrainMergeTypes.MapMergeTypes> mergePolicy,
CallerProvenance provenance)
Merges the given
SplitBrainMergeTypes.MapMergeTypes via the given SplitBrainMergePolicy . |
boolean |
DefaultRecordStore.merge(SplitBrainMergeTypes.MapMergeTypes mergingEntry,
SplitBrainMergePolicy<Data,SplitBrainMergeTypes.MapMergeTypes> mergePolicy,
CallerProvenance provenance) |
Modifier and Type | Field and Description |
---|---|
protected Map<Data,VersionedValue> |
TransactionalMapProxySupport.valueMap |
Constructor and Description |
---|
MapTransactionLogRecord(String name,
Data key,
int partitionId,
Operation op,
UUID ownerUuid,
UUID transactionId) |
TxnDeleteBackupOperation(String name,
Data dataKey,
UUID transactionId) |
TxnDeleteOperation(String name,
Data dataKey,
long version) |
TxnLockAndGetOperation(String name,
Data dataKey,
long timeout,
long ttl,
UUID ownerUuid,
boolean shouldLoad,
boolean blockReads) |
TxnPrepareBackupOperation(String name,
Data dataKey,
UUID lockOwnerUuid,
long lockThreadId,
UUID transactionId) |
TxnPrepareOperation(int partitionId,
String name,
Data dataKey,
UUID ownerUuid,
UUID transactionId) |
TxnRollbackBackupOperation(String name,
Data dataKey,
UUID lockOwner,
long lockThreadId,
UUID transactionId) |
TxnRollbackOperation(int partitionId,
String name,
Data dataKey,
UUID ownerUuid,
UUID transactionId) |
TxnSetBackupOperation(String name,
Data dataKey,
Data dataValue,
RecordInfo recordInfo,
UUID transactionId) |
TxnSetOperation(String name,
Data dataKey,
Data value,
long version,
long ttl) |
TxnUnlockBackupOperation(String name,
Data dataKey,
UUID ownerUuid,
long lockThreadId) |
TxnUnlockOperation(String name,
Data dataKey,
long version) |
VersionedValue(Data value,
long version) |
Modifier and Type | Method and Description |
---|---|
Data |
MapReplicationUpdate.getKey() |
Data |
MapReplicationRemove.getKey() |
Modifier and Type | Method and Description |
---|---|
WanMapEntryView<Data,Data> |
MapReplicationUpdate.getEntryView() |
WanMapEntryView<Data,Data> |
MapReplicationUpdate.getEntryView() |
Modifier and Type | Method and Description |
---|---|
void |
MapReplicationRemove.setKey(Data key) |
Modifier and Type | Method and Description |
---|---|
void |
MapReplicationUpdate.setEntryView(WanMapEntryView<Data,Data> entryView) |
void |
MapReplicationUpdate.setEntryView(WanMapEntryView<Data,Data> entryView) |
Constructor and Description |
---|
MapReplicationRemove(String mapName,
Data key) |
Constructor and Description |
---|
MapReplicationUpdate(String mapName,
SplitBrainMergePolicy mergePolicy,
EntryView<Data,Data> entryView) |
MapReplicationUpdate(String mapName,
SplitBrainMergePolicy mergePolicy,
EntryView<Data,Data> entryView) |
Modifier and Type | Method and Description |
---|---|
Data |
MultiMapMergeContainer.getKey() |
Data |
MultiMapEventFilter.getKey() |
Modifier and Type | Method and Description |
---|---|
Map<Data,Collection<MultiMapRecord>> |
MultiMapContainer.copyCollections() |
Set<Data> |
MultiMapContainer.keySet() |
protected Set<Data> |
MultiMapProxySupport.keySetInternal() |
Set<Data> |
MultiMapService.localKeySet(String name) |
protected Set<Data> |
MultiMapProxySupport.localKeySetInternal() |
Modifier and Type | Method and Description |
---|---|
UUID |
MultiMapService.addListener(String name,
EventListener listener,
Data key,
boolean includeValue,
boolean local) |
boolean |
MultiMapContainer.canAcquireLock(Data dataKey,
UUID caller,
long threadId) |
boolean |
MultiMapContainer.containsEntry(boolean binary,
Data key,
Data value) |
protected boolean |
MultiMapProxySupport.containsInternal(Data key,
Data value) |
boolean |
MultiMapContainer.containsKey(Data key) |
boolean |
MultiMapContainer.containsValue(boolean binary,
Data value) |
protected Integer |
MultiMapProxySupport.countInternal(Data dataKey) |
boolean |
MultiMapContainer.delete(Data dataKey) |
protected void |
MultiMapProxySupport.deleteInternal(Data dataKey) |
boolean |
MultiMapContainer.extendLock(Data key,
UUID caller,
long threadId,
long ttl) |
boolean |
MultiMapContainer.forceUnlock(Data key) |
protected MultiMapResponse |
MultiMapProxySupport.getAllInternal(Data dataKey) |
String |
MultiMapContainer.getLockOwnerInfo(Data dataKey) |
boolean |
MultiMapContainer.isLocked(Data dataKey) |
boolean |
MultiMapContainer.isTransactionallyLocked(Data key) |
void |
MultiMapService.onBeforeLock(String distributedObjectName,
Data key) |
void |
MultiMapEventsPublisher.publishEntryEvent(String multiMapName,
EntryEventType eventType,
Data key,
Object newValue,
Object oldValue) |
void |
MultiMapService.publishEntryEvent(String multiMapName,
EntryEventType eventType,
Data key,
Object newValue,
Object oldValue) |
protected Boolean |
MultiMapProxySupport.putInternal(Data dataKey,
Data dataValue,
int index) |
Collection<MultiMapRecord> |
MultiMapContainer.remove(Data dataKey,
boolean copyOf) |
protected MultiMapResponse |
MultiMapProxySupport.removeInternal(Data dataKey) |
protected Boolean |
MultiMapProxySupport.removeInternal(Data dataKey,
Data dataValue) |
boolean |
MultiMapContainer.txnLock(Data key,
UUID caller,
long threadId,
long referenceId,
long ttl,
boolean blockReads) |
boolean |
MultiMapContainer.unlock(Data key,
UUID caller,
long threadId,
long referenceId) |
Modifier and Type | Method and Description |
---|---|
void |
MultiMapService.insertMigratedData(int partitionId,
Map<String,Map<Data,MultiMapValue>> map) |
Constructor and Description |
---|
MultiMapEventFilter(boolean includeValue,
Data key) |
MultiMapMergeContainer(Data key,
Collection<MultiMapRecord> records,
long creationTime,
long lastAccessTime,
long lastUpdateTime,
long hits) |
Modifier and Type | Field and Description |
---|---|
protected Data |
AbstractKeyBasedMultiMapOperation.dataKey |
Modifier and Type | Method and Description |
---|---|
Data |
AbstractMultiMapOperation.toData(Object obj) |
Modifier and Type | Method and Description |
---|---|
Set<Map.Entry<Data,Data>> |
EntrySetResponse.getDataEntrySet() |
Set<Map.Entry<Data,Data>> |
EntrySetResponse.getDataEntrySet() |
Modifier and Type | Method and Description |
---|---|
void |
AbstractMultiMapOperation.publishEvent(EntryEventType eventType,
Data key,
Object newValue,
Object oldValue) |
Constructor and Description |
---|
EntrySetResponse(Map<Data,Collection<MultiMapRecord>> map,
NodeEngine nodeEngine) |
MultiMapReplicationOperation(Map<String,Map<Data,MultiMapValue>> map) |
Constructor and Description |
---|
MultiMapTransactionLogRecord(int partitionId,
Data key,
String name,
long ttl,
long threadId) |
TxnCommitBackupOperation(String name,
Data dataKey,
List<Operation> opList,
UUID caller,
long threadId) |
TxnCommitOperation(int partitionId,
String name,
Data dataKey,
long threadId,
List<Operation> opList) |
TxnGenerateRecordIdOperation(String name,
Data dataKey) |
TxnLockAndGetOperation(String name,
Data dataKey,
long timeout,
long ttl,
long threadId,
boolean blockReads) |
TxnPrepareBackupOperation(String name,
Data dataKey,
long threadId,
UUID caller) |
TxnPrepareOperation(int partitionId,
String name,
Data dataKey,
long threadId) |
TxnPutBackupOperation(String name,
Data dataKey,
long recordId,
Data value) |
TxnPutOperation(String name,
Data dataKey,
Data value,
long recordId) |
TxnRemoveAllBackupOperation(String name,
Data dataKey,
Collection<Long> recordIds) |
TxnRemoveAllOperation(String name,
Data dataKey,
Collection<MultiMapRecord> records) |
TxnRemoveBackupOperation(String name,
Data dataKey,
long recordId,
Data value) |
TxnRemoveOperation(String name,
Data dataKey,
long recordId,
Data value) |
TxnRollbackBackupOperation(String name,
Data dataKey,
UUID caller,
long threadId) |
TxnRollbackOperation(int partitionId,
String name,
Data dataKey,
long threadId) |
Modifier and Type | Method and Description |
---|---|
Data |
ObjectDataInput.readData() |
Modifier and Type | Method and Description |
---|---|
void |
ObjectDataOutput.writeData(Data data) |
Modifier and Type | Field and Description |
---|---|
protected Data |
CachedQueryEntry.keyData |
protected Data |
CachedQueryEntry.valueData |
Modifier and Type | Method and Description |
---|---|
Data |
QueryEntry.getKeyData() |
abstract Data |
QueryableEntry.getKeyData() |
Data |
CachedQueryEntry.getKeyData() |
Data |
QueryEntry.getValueData() |
abstract Data |
QueryableEntry.getValueData() |
Data |
CachedQueryEntry.getValueData() |
Modifier and Type | Method and Description |
---|---|
void |
QueryEntry.init(InternalSerializationService serializationService,
Data key,
Object value,
Extractors extractors)
It may be useful to use this
init method in some cases that same instance of this class can be used
instead of creating a new one for every iteration when scanning large data sets, for example: |
void |
CachedQueryEntry.init(InternalSerializationService serializationService,
Data key,
Object value,
Extractors extractors) |
void |
IndexStore.remove(Object value,
Data indexKey,
IndexOperationStats operationStats)
Removes the existing entry mapping in this index.
|
void |
BaseIndexStore.remove(Object value,
Data indexKey,
IndexOperationStats operationStats) |
void |
AbstractIndex.removeEntry(Data key,
Object value,
Index.OperationSource operationSource) |
void |
Index.removeEntry(Data key,
Object value,
Index.OperationSource operationSource)
Removes the entry having the given key and the value from this index.
|
void |
Indexes.removeEntry(Data key,
Object value,
Index.OperationSource operationSource)
Removes the entry from this indexes instance identified by the given key
and value.
|
Modifier and Type | Method and Description |
---|---|
void |
FastMultiResultSet.addResultSet(Map<Data,QueryableEntry> resultSet) |
void |
MultiResultSet.addResultSet(Map<Data,QueryableEntry> resultSet)
TODO
|
void |
DuplicateDetectingMultiResult.addResultSet(Map<Data,QueryableEntry> resultSet) |
Constructor and Description |
---|
CachedQueryEntry(InternalSerializationService serializationService,
Data key,
Object value,
Extractors extractors) |
QueryEntry(InternalSerializationService serializationService,
Data key,
Object value,
Extractors extractors) |
Constructor and Description |
---|
SingleResultSet(Map<Data,QueryableEntry> records) |
Modifier and Type | Method and Description |
---|---|
void |
ReplicatedMapEventPublishingService.fireEntryListenerEvent(Data key,
Data oldValue,
Data value,
EntryEventType eventType,
String name,
Address caller) |
void |
ReplicatedMapEventPublishingService.fireEntryListenerEvent(Data key,
Data oldValue,
Data value,
String name,
Address caller) |
Modifier and Type | Method and Description |
---|---|
Data |
ReplicatedMapPortableEntryEvent.getKey() |
Data |
ReplicatedMapEntries.getKey(int index) |
Data |
ReplicatedMapPortableEntryEvent.getOldValue() |
Data |
ReplicatedMapPortableEntryEvent.getValue() |
Data |
ReplicatedMapEntries.getValue(int index) |
Modifier and Type | Method and Description |
---|---|
List<Map.Entry<Data,Data>> |
ReplicatedMapEntries.entries() |
List<Map.Entry<Data,Data>> |
ReplicatedMapEntries.entries() |
List<Data> |
ReplicatedMapKeys.getKeys() |
Collection<Data> |
ReplicatedMapValueCollection.getValues() |
Modifier and Type | Method and Description |
---|---|
void |
ReplicatedMapEntries.add(Data key,
Data value) |
Constructor and Description |
---|
ReplicatedMapEntries(List<Map.Entry<Data,Data>> entries) |
ReplicatedMapEntries(List<Map.Entry<Data,Data>> entries) |
ReplicatedMapKeys(List<Data> keys) |
ReplicatedMapValueCollection(Collection<Data> values) |
Modifier and Type | Field and Description |
---|---|
protected Data |
AbstractReplicatedMapOperation.key |
protected Data |
AbstractReplicatedMapOperation.value |
Constructor and Description |
---|
ContainsKeyOperation(String name,
Data key) |
ContainsValueOperation(String name,
Data value) |
GetOperation(String name,
Data key) |
PutOperation(String name,
Data key,
Data value) |
PutOperation(String name,
Data key,
Data value,
long ttl) |
RemoveOperation(String name,
Data key) |
ReplicateUpdateOperation(String name,
Data dataKey,
Data dataValue,
long ttl,
VersionResponsePair response,
boolean isRemove,
Address origin) |
ReplicateUpdateToCallerOperation(String name,
long callId,
Data dataKey,
Data dataValue,
VersionResponsePair response,
long ttl,
boolean isRemove) |
Modifier and Type | Field and Description |
---|---|
protected Data |
ReplicatedEntryEventFilter.key |
Modifier and Type | Method and Description |
---|---|
Data |
RecordMigrationInfo.getKey() |
Data |
RecordMigrationInfo.getValue() |
Modifier and Type | Method and Description |
---|---|
void |
RecordMigrationInfo.setKey(Data key) |
void |
RecordMigrationInfo.setValue(Data value) |
Constructor and Description |
---|
RecordMigrationInfo(Data key,
Data value,
long ttl) |
ReplicatedEntryEventFilter(Data key) |
ReplicatedQueryEventFilter(Data key,
Predicate predicate) |
Modifier and Type | Method and Description |
---|---|
Data[] |
ReadResultSetImpl.getDataItems() |
Data |
RingbufferStoreWrapper.load(long sequence) |
Data |
RingbufferContainer.readAsData(long sequence)
Reads one item from the ring buffer and returns the serialized format.
|
Modifier and Type | Method and Description |
---|---|
void |
RingbufferStoreWrapper.store(long sequence,
Data value) |
void |
RingbufferStoreWrapper.storeAll(long firstItemSequence,
Data[] items) |
Modifier and Type | Method and Description |
---|---|
List<Data> |
PortableReadResultSet.getDataItems() |
Constructor and Description |
---|
PortableReadResultSet(int readCount,
List<Data> items,
long[] seqs,
long nextSeq) |
Modifier and Type | Method and Description |
---|---|
Data |
ReadOneOperation.getResponse() |
Constructor and Description |
---|
AddAllBackupOperation(String name,
long lastSequenceId,
Data[] items) |
AddAllOperation(String name,
Data[] items,
OverflowPolicy overflowPolicy) |
AddBackupOperation(String name,
long sequenceId,
Data item) |
AddOperation(String name,
Data item,
OverflowPolicy overflowPolicy) |
Modifier and Type | Method and Description |
---|---|
default Data |
TokenCredentials.asData()
Returns the token represented as
Data . |
Modifier and Type | Method and Description |
---|---|
Data |
PortableItemEvent.getItem() |
Data |
PortableEntryEvent.getKey() |
Data |
PortableEntryEvent.getMergingValue() |
protected Data |
AbstractDistributedObject.getNameAsPartitionAwareData() |
Data |
PortableEntryEvent.getOldValue() |
Data |
PortableEntryEvent.getValue() |
Data |
NodeEngine.toData(Object object)
Serializes an object to a
Data . |
Data |
NodeEngineImpl.toData(Object object) |
protected Data |
AbstractDistributedObject.toData(Object object) |
Modifier and Type | Method and Description |
---|---|
Collection<Data> |
PortableCollection.getCollection() |
List<Data> |
SerializableList.getCollection() |
Iterator<Data> |
SerializableList.iterator() |
Modifier and Type | Method and Description |
---|---|
protected int |
AbstractDistributedObject.getPartitionId(Data key) |
Modifier and Type | Method and Description |
---|---|
static <V> InternalCompletableFuture<V> |
InternalCompletableFuture.newDelegatingFuture(SerializationService serializationService,
InternalCompletableFuture<Data> future)
Creates a new
InternalCompletableFuture that delegates to the given future and
deserializes its completion value of type Data . |
Constructor and Description |
---|
PortableEntryEvent(Data key,
Data value,
Data oldValue,
Data mergingValue,
EntryEventType eventType,
UUID uuid) |
PortableItemEvent(Data item,
ItemEventType eventType,
UUID uuid) |
Constructor and Description |
---|
PortableCollection(Collection<Data> collection) |
SerializableList(List<Data> collection) |
Modifier and Type | Method and Description |
---|---|
Data |
CacheMergingEntryImpl.getKey() |
Data |
MultiMapMergingEntryImpl.getKey() |
Data |
MapMergingEntryImpl.getKey() |
Data |
CacheMergingEntryImpl.getValue() |
Data |
MapMergingEntryImpl.getValue() |
protected Data |
AbstractMergeRunnable.toData(Object object) |
protected Data |
AbstractMergeRunnable.toHeapData(Object object) |
Modifier and Type | Method and Description |
---|---|
static SplitBrainMergeTypes.CacheMergeTypes |
MergingValueFactory.createMergingEntry(SerializationService serializationService,
CacheEntryView<Data,Data> entryView) |
static SplitBrainMergeTypes.CacheMergeTypes |
MergingValueFactory.createMergingEntry(SerializationService serializationService,
CacheEntryView<Data,Data> entryView) |
static SplitBrainMergeTypes.MapMergeTypes |
MergingValueFactory.createMergingEntry(SerializationService serializationService,
EntryView<Data,Data> entryView) |
static SplitBrainMergeTypes.MapMergeTypes |
MergingValueFactory.createMergingEntry(SerializationService serializationService,
EntryView<Data,Data> entryView) |
Constructor and Description |
---|
BinaryOperationFactory(Data operationData) |
Constructor and Description |
---|
Backup(Data backupOpData,
Address originalCaller,
long[] replicaVersions,
boolean sync) |
Backup(Data backupOpData,
Address originalCaller,
long[] replicaVersions,
boolean sync,
long clientCorrelationId) |
Modifier and Type | Method and Description |
---|---|
int |
IPartitionService.getPartitionId(Data key)
Returns the partition ID for a
Data key. |
Modifier and Type | Method and Description |
---|---|
Data |
DataAwareMessage.getMessageData() |
Constructor and Description |
---|
DataAwareMessage(String topicName,
Data messageData,
long publishTime,
Member publishingMember,
SerializationService serializationService) |
PublishOperation(String name,
Data message) |
Modifier and Type | Method and Description |
---|---|
Data |
ReliableTopicMessage.getPayload() |
Constructor and Description |
---|
ReliableTopicMessage(Data payload,
Address publisherAddress) |
Constructor and Description |
---|
ClearRemoteTransactionBackupOperation(Data xidData) |
ClearRemoteTransactionOperation(Data xidData) |
FinalizeRemoteTransactionBackupOperation(Data xidData) |
FinalizeRemoteTransactionOperation(Data xidData,
boolean isCommit) |
Modifier and Type | Method and Description |
---|---|
Data |
InternalWanReplicationEvent.getKey()
Returns the key for the entry on which the event occurred.
|
Copyright © 2019 Hazelcast, Inc.. All rights reserved.