Package | Description |
---|---|
com.hazelcast.cache.impl |
Hazelcast JSR-107 aka JCache implementation
|
com.hazelcast.cache.impl.client |
Hazelcast JSR-107 aka JCache implementation
Client Requests
|
com.hazelcast.cache.impl.nearcache.impl.record |
Near cache record implementations.
|
com.hazelcast.cache.impl.nearcache.impl.store |
Near cache store implementations.
|
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.client |
This contains the Requests and other DTO's exchanged between client/server
|
com.hazelcast.client.impl.protocol.codec |
Client protocol custom codec implementations
|
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.protocol.template | |
com.hazelcast.client.impl.protocol.util |
Protocol utils
|
com.hazelcast.client.proxy |
This package contains client side proxy implementations of the different Hazelcast data structures
and operation types
|
com.hazelcast.client.spi |
Contains classes/interfaces related to Service Provider Interface
such as ClientProxy , ClientClusterService
|
com.hazelcast.client.spi.impl |
Provides util classes for com.hazelcast.client
|
com.hazelcast.client.util |
This package contains some utility classes and the base implementations of the
loadbalancer implementations
|
com.hazelcast.collection.common |
This package contains common classes related to all collections
|
com.hazelcast.collection.impl.collection | |
com.hazelcast.collection.impl.collection.client | |
com.hazelcast.collection.impl.collection.operations | |
com.hazelcast.collection.impl.list |
This package contains IList functionality for Hazelcast.
|
com.hazelcast.collection.impl.list.client | |
com.hazelcast.collection.impl.list.operations | |
com.hazelcast.collection.impl.queue | |
com.hazelcast.collection.impl.queue.client |
This package contains client requests for the IQueue.
|
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.client | |
com.hazelcast.collection.impl.txncollection.operations | |
com.hazelcast.collection.impl.txnlist.client | |
com.hazelcast.collection.impl.txnqueue | |
com.hazelcast.collection.impl.txnqueue.client | |
com.hazelcast.collection.impl.txnqueue.operations | |
com.hazelcast.collection.impl.txnset.client | |
com.hazelcast.concurrent.atomiclong.client |
This package contains client requests for the IAtomicLong.
This package contains all the client request object to operate on the IAtomicLong that are send by the client. |
com.hazelcast.concurrent.atomicreference |
This package contains IAtomicReferece functionality for Hazelcast.
The IAtomicReference is the distributed version of the AtomicReference . |
com.hazelcast.concurrent.atomicreference.client |
This package contains client requests for the IAtomicLong.
This package contains all the client request object to operate on the IAtomicLong that are send by the client. |
com.hazelcast.concurrent.atomicreference.operations |
This package contains the operations on the IAtomicReference.
|
com.hazelcast.concurrent.lock | |
com.hazelcast.concurrent.lock.client |
This package contains client requests for the ILock.
This package contains all the client requests object to operate on the ILock that are send by the client. |
com.hazelcast.concurrent.lock.operations |
This package contains the operations on the ILock.
|
com.hazelcast.executor.impl.operations |
This package contains operations for the IExecutorService.
|
com.hazelcast.internal.storage |
This package contains storage functionality for Hazelcast.
|
com.hazelcast.map.impl |
Contains implementation specific classes of
com.hazelcast.map package. |
com.hazelcast.map.impl.client |
Contains client requests for the
IMap |
com.hazelcast.map.impl.eviction |
This package contains eviction classes.
|
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.operation |
Package for map operations.
|
com.hazelcast.map.impl.record |
Contains record specific classes.
|
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.client |
Contains client requests 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.nio.serialization |
Contains interfaces/classes related to serialization;
such as serializer interfaces, input/output streams.
|
com.hazelcast.partition |
Contains the partition logic for Hazelcast.
|
com.hazelcast.partition.impl |
Contains the actual implementation of the
InternalPartitionService . |
com.hazelcast.query.impl |
Contains the implementation classes of the query functionality.
|
com.hazelcast.ringbuffer.impl |
Contains the
Ringbuffer implementation classes. |
com.hazelcast.ringbuffer.impl.operations | |
com.hazelcast.spi |
Provides interfaces/classes for Hazelcast SPI.
|
com.hazelcast.spi.impl |
Contains implementations for Hazelcast SPI.
|
com.hazelcast.spi.impl.operationservice.impl.operations |
Contains the Operations being used by the
OperationServiceImpl . |
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.client |
This package contains client requests for the ITopic.
|
com.hazelcast.topic.impl.reliable | |
com.hazelcast.transaction.client |
This package contains client transaction code
|
com.hazelcast.transaction.impl.xa |
Provides implementation for Hazelcast XA transaction support.
|
com.hazelcast.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.web |
Provides Hazelcast-based session replication.
|
com.hazelcast.web.entryprocessor |
Provides Entry Processors used in hazelcast-wm
|
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 EvictionStrategy<Data,R,CRM> |
AbstractCacheRecordStore.evictionStrategy |
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 |
CacheKeyIteratorResult.getKey(int index) |
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) |
protected 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 |
---|---|
protected EvictionPolicyEvaluator<Data,R> |
AbstractCacheRecordStore.createEvictionPolicyEvaluator(EvictionConfig cacheEvictionConfig) |
protected EvictionStrategy<Data,R,CRM> |
AbstractCacheRecordStore.createEvictionStrategy(EvictionConfig cacheEvictionConfig) |
List<Data> |
CacheKeyIteratorResult.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) |
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,
String origin,
int completionId) |
static CacheEventContext |
CacheEventContextUtil.createCacheCompleteEvent(Data dataKey,
int completionId) |
static CacheEventContext |
CacheEventContextUtil.createCacheCompleteEvent(Data dataKey,
long expirationTime,
String origin,
int completionId) |
static CacheEventContext |
CacheEventContextUtil.createCacheCreatedEvent(Data dataKey,
Data dataValue,
long expirationTime,
String 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,
String origin,
int completionId) |
static CacheEventContext |
CacheEventContextUtil.createCacheRemovedEvent(Data dataKey,
Data dataValue,
long expirationTime,
String origin,
int completionId) |
static CacheEventContext |
CacheEventContextUtil.createCacheUpdatedEvent(Data dataKey,
Data dataValue,
Data dataOldValue,
long expirationTime,
long accessHit,
String origin,
int completionId) |
Operation |
CacheOperationProvider.createContainsKeyOperation(Data key) |
Operation |
DefaultOperationProvider.createContainsKeyOperation(Data key) |
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) |
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) |
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 keyData,
Object value,
long expirationTime,
int completionId,
String origin) |
R |
AbstractCacheRecordStore.createRecordWithExpiry(Data key,
Object value,
javax.cache.expiry.ExpiryPolicy expiryPolicy,
long now,
boolean disableWriteThrough,
int completionId) |
R |
AbstractCacheRecordStore.createRecordWithExpiry(Data key,
Object value,
javax.cache.expiry.ExpiryPolicy expiryPolicy,
long now,
boolean disableWriteThrough,
int completionId,
String origin) |
R |
AbstractCacheRecordStore.createRecordWithExpiry(Data key,
Object value,
long expiryTime,
long now,
boolean disableWriteThrough,
int completionId) |
R |
AbstractCacheRecordStore.createRecordWithExpiry(Data key,
Object value,
long expiryTime,
long now,
boolean disableWriteThrough,
int completionId,
String 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) |
protected Object |
CacheRecordStore.dataToValue(Data data) |
protected abstract Object |
AbstractCacheRecordStore.dataToValue(Data data) |
protected void |
AbstractCacheRecordStore.deleteCacheEntry(Data key) |
protected boolean |
AbstractCacheRecordStore.deleteRecord(Data key,
int completionId) |
protected boolean |
AbstractCacheRecordStore.deleteRecord(Data key,
int completionId,
String source) |
protected boolean |
AbstractCacheRecordStore.deleteRecord(Data key,
int completionId,
String source,
String origin) |
protected R |
AbstractCacheRecordStore.doPutRecord(Data key,
R record) |
protected R |
AbstractCacheRecordStore.doPutRecord(Data key,
R record,
String source) |
protected R |
AbstractCacheRecordStore.doRemoveRecord(Data key) |
protected R |
AbstractCacheRecordStore.doRemoveRecord(Data key,
String source) |
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,
String 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,
String source,
int completionId) |
Object |
ICacheRecordStore.getAndRemove(Data key,
String caller,
int completionId)
Atomically removes the entry for a key only if it is currently mapped to some
value.
|
Object |
AbstractCacheRecordStore.getAndRemove(Data key,
String source,
int completionId) |
Object |
AbstractCacheRecordStore.getAndRemove(Data key,
String source,
int completionId,
String origin) |
Object |
ICacheRecordStore.getAndReplace(Data key,
Object value,
javax.cache.expiry.ExpiryPolicy expiryPolicy,
String 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,
String source,
int completionId) |
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,
String 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 |
AbstractCacheRecordStore.onDeleteRecord(Data key,
R record,
Data dataValue,
boolean deleted) |
protected void |
AbstractCacheRecordStore.onDeleteRecordError(Data key,
R record,
Data dataValue,
boolean deleted,
Throwable error) |
void |
AbstractCacheRecordStore.onEvict(Data key,
R record) |
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 |
AbstractCacheRecordStore.onPut(Data key,
Object value,
javax.cache.expiry.ExpiryPolicy expiryPolicy,
String 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,
String 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,
String source,
boolean disableWriteThrough,
R record,
boolean isExpired,
boolean isSaveSucceed) |
protected void |
AbstractCacheRecordStore.onPutIfAbsentError(Data key,
Object value,
javax.cache.expiry.ExpiryPolicy expiryPolicy,
String 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,
String source,
boolean getValue,
R record,
boolean removed) |
protected void |
AbstractCacheRecordStore.onRemoveError(Data key,
Object value,
String source,
boolean getValue,
R record,
boolean removed,
Throwable error) |
protected void |
AbstractCacheRecordStore.onReplace(Data key,
Object oldValue,
Object newValue,
javax.cache.expiry.ExpiryPolicy expiryPolicy,
String source,
boolean getValue,
R record,
boolean isExpired,
boolean replaced) |
protected void |
AbstractCacheRecordStore.onReplaceError(Data key,
Object oldValue,
Object newValue,
javax.cache.expiry.ExpiryPolicy expiryPolicy,
String source,
boolean getValue,
R record,
boolean isExpired,
boolean replaced,
Throwable error) |
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) |
boolean |
AbstractCacheRecordStore.processExpiredEntry(Data key,
R record,
long now) |
R |
AbstractCacheRecordStore.processExpiredEntry(Data key,
R record,
long expiryTime,
long now) |
R |
AbstractCacheRecordStore.processExpiredEntry(Data key,
R record,
long expiryTime,
long now,
String source) |
R |
AbstractCacheRecordStore.processExpiredEntry(Data key,
R record,
long expiryTime,
long now,
String source,
String origin) |
boolean |
AbstractCacheRecordStore.processExpiredEntry(Data key,
R record,
long now,
String source) |
boolean |
AbstractCacheRecordStore.processExpiredEntry(Data key,
R record,
long now,
String source,
String origin) |
protected Object |
AbstractCacheRecordStore.put(Data key,
Object value,
javax.cache.expiry.ExpiryPolicy expiryPolicy,
String source,
boolean getValue,
boolean disableWriteThrough,
int completionId) |
protected Object |
AbstractCacheRecordStore.put(Data key,
Object value,
javax.cache.expiry.ExpiryPolicy expiryPolicy,
String source,
boolean getValue,
int completionId) |
void |
ICacheRecordStore.put(Data key,
Object value,
javax.cache.expiry.ExpiryPolicy expiryPolicy,
String caller,
int completionId)
Associates the specified value with the specified key in this cache,
returning an existing value if one existed.
|
void |
AbstractCacheRecordStore.put(Data key,
Object value,
javax.cache.expiry.ExpiryPolicy expiryPolicy,
String source,
int completionId) |
protected boolean |
AbstractCacheRecordStore.putIfAbsent(Data key,
Object value,
javax.cache.expiry.ExpiryPolicy expiryPolicy,
String source,
boolean disableWriteThrough,
int completionId) |
boolean |
ICacheRecordStore.putIfAbsent(Data key,
Object value,
javax.cache.expiry.ExpiryPolicy expiryPolicy,
String 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,
String source,
int completionId) |
void |
ICacheRecordStore.putRecord(Data key,
CacheRecord record)
Associates the specified record with the specified key.
|
void |
AbstractCacheRecordStore.putRecord(Data key,
CacheRecord record) |
Object |
AbstractCacheRecordStore.readThroughCache(Data key) |
R |
AbstractCacheRecordStore.readThroughRecord(Data key,
long now) |
boolean |
ICacheRecordStore.remove(Data key,
Object value,
String caller,
int completionId)
Atomically removes the mapping for a key only if currently mapped to the
given value.
|
boolean |
AbstractCacheRecordStore.remove(Data key,
Object value,
String source,
int completionId) |
boolean |
AbstractCacheRecordStore.remove(Data key,
Object value,
String source,
int completionId,
String origin) |
boolean |
ICacheRecordStore.remove(Data key,
String caller,
int completionId)
Removes the mapping for a key from this cache if it is present.
|
boolean |
AbstractCacheRecordStore.remove(Data key,
String source,
int completionId) |
boolean |
AbstractCacheRecordStore.remove(Data key,
String source,
int completionId,
String origin) |
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,
String 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,
String source,
int completionId) |
boolean |
ICacheRecordStore.replace(Data key,
Object oldValue,
Object newValue,
javax.cache.expiry.ExpiryPolicy expiryPolicy,
String 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,
String source,
int completionId) |
protected void |
CacheService.sendBatchInvalidationEvent(String name,
Data key,
String sourceUuid) |
void |
CacheService.sendInvalidationEvent(String name,
Data key,
String sourceUuid)
Sends an invalidation event for given
cacheName with specified key
from mentioned source with sourceUuid . |
void |
ICacheService.sendInvalidationEvent(String name,
Data key,
String sourceUuid) |
protected void |
CacheService.sendSingleInvalidationEvent(String name,
Data key,
String sourceUuid) |
void |
CacheEventContext.setDataKey(Data dataKey) |
void |
CacheEventContext.setDataOldValue(Data dataOldValue) |
void |
CacheEventContext.setDataValue(Data dataValue) |
void |
ICacheRecordStore.setRecord(Data key,
CacheRecord record)
Associates the specified record with the specified key.
|
void |
AbstractCacheRecordStore.setRecord(Data key,
CacheRecord record) |
protected long |
AbstractCacheRecordStore.updateAccessDuration(Data key,
R record,
javax.cache.expiry.ExpiryPolicy expiryPolicy,
long now) |
protected R |
AbstractCacheRecordStore.updateRecord(Data key,
R record,
Object value,
int completionId) |
protected R |
AbstractCacheRecordStore.updateRecord(Data key,
R record,
Object value,
int completionId,
String source) |
protected R |
AbstractCacheRecordStore.updateRecord(Data key,
R record,
Object value,
int completionId,
String source,
String origin) |
boolean |
AbstractCacheRecordStore.updateRecordWithExpiry(Data key,
Object value,
R record,
javax.cache.expiry.ExpiryPolicy expiryPolicy,
long now,
boolean disableWriteThrough,
int completionId) |
boolean |
AbstractCacheRecordStore.updateRecordWithExpiry(Data key,
Object value,
R record,
javax.cache.expiry.ExpiryPolicy expiryPolicy,
long now,
boolean disableWriteThrough,
int completionId,
String source) |
boolean |
AbstractCacheRecordStore.updateRecordWithExpiry(Data key,
Object value,
R record,
javax.cache.expiry.ExpiryPolicy expiryPolicy,
long now,
boolean disableWriteThrough,
int completionId,
String source,
String origin) |
boolean |
AbstractCacheRecordStore.updateRecordWithExpiry(Data key,
Object value,
R record,
long expiryTime,
long now,
boolean disableWriteThrough,
int completionId) |
boolean |
AbstractCacheRecordStore.updateRecordWithExpiry(Data key,
Object value,
R record,
long expiryTime,
long now,
boolean disableWriteThrough,
int completionId,
String source) |
boolean |
AbstractCacheRecordStore.updateRecordWithExpiry(Data key,
Object value,
R record,
long expiryTime,
long now,
boolean disableWriteThrough,
int completionId,
String source,
String origin) |
void |
AbstractCacheRecordStore.writeThroughCache(Data key,
Object value) |
Modifier and Type | Method and Description |
---|---|
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) |
OperationFactory |
CacheOperationProvider.createRemoveAllOperationFactory(Set<Data> keySet,
Integer completionId) |
OperationFactory |
DefaultOperationProvider.createRemoveAllOperationFactory(Set<Data> keySet,
Integer completionId) |
protected void |
AbstractCacheRecordStore.deleteAllCacheEntry(Set<Data> keys) |
MapEntrySet |
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. |
MapEntrySet |
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) |
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) |
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 |
---|
CacheKeyIteratorResult(List<Data> keys,
int tableIndex) |
Modifier and Type | Method and Description |
---|---|
Data |
CacheSingleInvalidationMessage.getKey() |
Data |
CacheInvalidationMessage.getKey() |
Constructor and Description |
---|
CacheContainsKeyRequest(String name,
Data key,
InMemoryFormat inMemoryFormat) |
CacheEntryProcessorRequest(String name,
Data key,
javax.cache.processor.EntryProcessor entryProcessor,
InMemoryFormat inMemoryFormat,
Object... arguments) |
CacheGetAndRemoveRequest(String name,
Data key,
InMemoryFormat inMemoryFormat) |
CacheGetAndReplaceRequest(String name,
Data key,
Data value,
javax.cache.expiry.ExpiryPolicy expiryPolicy,
InMemoryFormat inMemoryFormat) |
CacheGetRequest(String name,
Data key,
javax.cache.expiry.ExpiryPolicy expiryPolicy,
InMemoryFormat inMemoryFormat) |
CachePutIfAbsentRequest(String name,
Data key,
Data value,
javax.cache.expiry.ExpiryPolicy expiryPolicy,
InMemoryFormat inMemoryFormat) |
CachePutRequest(String name,
Data key,
Data value,
javax.cache.expiry.ExpiryPolicy expiryPolicy,
boolean get,
InMemoryFormat inMemoryFormat) |
CachePutRequest(String name,
Data key,
Data value,
javax.cache.expiry.ExpiryPolicy expiryPolicy,
InMemoryFormat inMemoryFormat) |
CachePutRequest(String name,
Data key,
Data value,
InMemoryFormat inMemoryFormat) |
CacheRemoveRequest(String name,
Data key,
Data currentValue,
InMemoryFormat inMemoryFormat) |
CacheRemoveRequest(String name,
Data key,
InMemoryFormat inMemoryFormat) |
CacheReplaceRequest(String name,
Data key,
Data currentValue,
Data value,
javax.cache.expiry.ExpiryPolicy expiryPolicy,
InMemoryFormat inMemoryFormat) |
CacheReplaceRequest(String name,
Data key,
Data value,
javax.cache.expiry.ExpiryPolicy expiryPolicy,
InMemoryFormat inMemoryFormat) |
CacheSingleInvalidationMessage(String name,
Data key,
String sourceUuid) |
Constructor and Description |
---|
CacheClearRequest(String name,
Set<Data> keys,
boolean isRemoveAll,
int completionId) |
CacheGetAllRequest(String name,
Set<Data> keys,
javax.cache.expiry.ExpiryPolicy expiryPolicy) |
CacheLoadAllRequest(String name,
Set<Data> keys,
boolean replaceExistingValues) |
Constructor and Description |
---|
NearCacheDataRecord(Data value,
long creationTime,
long expiryTime) |
Modifier and Type | Method and Description |
---|---|
protected Data |
AbstractNearCacheRecordStore.toData(Object obj) |
protected Data |
AbstractNearCacheRecordStore.valueToData(V value) |
Modifier and Type | Method and Description |
---|---|
protected V |
AbstractNearCacheRecordStore.dataToValue(Data data) |
Modifier and Type | Field and Description |
---|---|
protected Map<String,Map<Data,CacheRecord>> |
CacheReplicationOperation.data |
Constructor and Description |
---|
AbstractMutatingCacheOperation(String name,
Data key,
int completionId) |
CacheBackupEntryProcessorOperation(String name,
Data key,
javax.cache.processor.EntryProcessor entryProcessor,
Object... arguments) |
CacheContainsKeyOperation(String name,
Data key) |
CacheEntryProcessorOperation(String name,
Data key,
int completionId,
javax.cache.processor.EntryProcessor entryProcessor,
Object... arguments) |
CacheGetAndRemoveOperation(String name,
Data key,
int completionId) |
CacheGetAndReplaceOperation(String name,
Data key,
Data value,
javax.cache.expiry.ExpiryPolicy expiryPolicy,
int completionId) |
CacheGetOperation(String name,
Data key,
javax.cache.expiry.ExpiryPolicy expiryPolicy) |
CachePutBackupOperation(String name,
Data key,
CacheRecord cacheRecord) |
CachePutIfAbsentOperation(String name,
Data key,
Data value,
javax.cache.expiry.ExpiryPolicy expiryPolicy,
int completionId) |
CachePutOperation(String name,
Data key,
Data value,
javax.cache.expiry.ExpiryPolicy expiryPolicy,
boolean get,
int completionId) |
CacheRemoveBackupOperation(String name,
Data key) |
CacheRemoveOperation(String name,
Data key,
Data oldValue,
int completionId) |
CacheReplaceOperation(String name,
Data key,
Data oldValue,
Data newValue,
javax.cache.expiry.ExpiryPolicy expiryPolicy,
int completionId) |
Constructor and Description |
---|
CacheGetAllOperation(String name,
Set<Data> keys,
javax.cache.expiry.ExpiryPolicy expiryPolicy) |
CacheGetAllOperationFactory(String name,
Set<Data> keys,
javax.cache.expiry.ExpiryPolicy expiryPolicy) |
CacheLoadAllOperation(String name,
Set<Data> keys,
boolean replaceExistingValues) |
CacheLoadAllOperationFactory(String name,
Set<Data> keys,
boolean replaceExistingValues) |
CachePutAllBackupOperation(String name,
Map<Data,CacheRecord> cacheRecords) |
CacheRemoveAllBackupOperation(String name,
Set<Data> keys) |
CacheRemoveAllOperation(String name,
Set<Data> keys,
int completionId) |
CacheRemoveAllOperationFactory(String name,
Set<Data> keys,
int completionId) |
Modifier and Type | Interface and Description |
---|---|
interface |
CacheRecordMap<K extends Data,V extends CacheRecord> |
interface |
SampleableCacheRecordMap<K extends Data,V extends CacheRecord> |
Modifier and Type | Method and Description |
---|---|
<C extends EvictionCandidate<Data,CacheRecord>> |
CacheRecordHashMap.evict(Iterable<C> evictionCandidates,
EvictionListener<Data,CacheRecord> evictionListener) |
Modifier and Type | Method and Description |
---|---|
Data |
CacheDataRecord.getValue() |
Modifier and Type | Method and Description |
---|---|
protected CacheRecord |
CacheRecordFactory.createCacheDataRecord(Data dataValue,
long creationTime,
long expiryTime) |
protected CacheRecordHashMap.EvictableSamplingEntry |
CacheRecordHashMap.createSamplingEntry(Data key,
CacheRecord value) |
void |
CacheDataRecord.setValue(Data value) |
Modifier and Type | Method and Description |
---|---|
<C extends EvictionCandidate<Data,CacheRecord>> |
CacheRecordHashMap.evict(Iterable<C> evictionCandidates,
EvictionListener<Data,CacheRecord> evictionListener) |
Constructor and Description |
---|
CacheDataRecord(Data value,
long creationTime,
long expiryTime) |
CacheRecordHashMap.EvictableSamplingEntry(Data key,
CacheRecord value) |
Modifier and Type | Method and Description |
---|---|
protected Data |
ClientClusterWideIterator.toData(Object obj) |
Modifier and Type | Method and Description |
---|---|
Data |
ClientResponse.getResponse() |
Constructor and Description |
---|
ClientResponse(Data response,
int callId,
boolean isError) |
Modifier and Type | Method and Description |
---|---|
static int |
EntryViewCodec.calculateDataSize(SimpleEntryView<Data,Data> entryView) |
static int |
EntryViewCodec.calculateDataSize(SimpleEntryView<Data,Data> entryView) |
static void |
EntryViewCodec.encode(SimpleEntryView<Data,Data> dataEntryView,
ClientMessage clientMessage) |
static void |
EntryViewCodec.encode(SimpleEntryView<Data,Data> dataEntryView,
ClientMessage clientMessage) |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
MapAddEntryListenerToKeyWithPredicateMessageTask.encodeEvent(Data keyData,
Data newValueData,
Data oldValueData,
Data meringValueData,
int type,
String uuid,
int numberOfAffectedEntries) |
protected abstract ClientMessage |
AbstractMapAddEntryListenerMessageTask.encodeEvent(Data keyData,
Data newValueData,
Data oldValueData,
Data meringValueData,
int type,
String uuid,
int numberOfEntriesAffected) |
protected ClientMessage |
MapAddNearCacheEntryListenerMessageTask.encodeEvent(Data keyData,
Data newValueData,
Data oldValueData,
Data meringValueData,
int type,
String uuid,
int numberOfAffectedEntries) |
protected ClientMessage |
MapAddEntryListenerToKeyMessageTask.encodeEvent(Data keyData,
Data newValueData,
Data oldValueData,
Data meringValueData,
int type,
String uuid,
int numberOfAffectedEntries) |
protected ClientMessage |
MapAddEntryListenerMessageTask.encodeEvent(Data keyData,
Data newValueData,
Data oldValueData,
Data meringValueData,
int type,
String uuid,
int numberOfAffectedEntries) |
protected ClientMessage |
MapAddEntryListenerWithPredicateMessageTask.encodeEvent(Data keyData,
Data newValueData,
Data oldValueData,
Data meringValueData,
int type,
String uuid,
int numberOfAffectedEntries) |
Modifier and Type | Method and Description |
---|---|
Data |
AbstractMultiMapAddEntryListenerMessageTask.getKey() |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
MultiMapAddEntryListenerToKeyMessageTask.encodeEvent(Data key,
Data value,
Data oldValue,
int type,
String uuid,
int numberOfEntriesAffected) |
protected ClientMessage |
MultiMapAddEntryListenerMessageTask.encodeEvent(Data key,
Data value,
Data oldValue,
int type,
String uuid,
int numberOfEntriesAffected) |
protected abstract ClientMessage |
AbstractMultiMapAddEntryListenerMessageTask.encodeEvent(Data key,
Data value,
Data oldValue,
int type,
String uuid,
int numberOfEntriesAffected) |
Modifier and Type | Method and Description |
---|---|
Data |
ReplicatedMapAddEntryListenerMessageTask.getKey() |
Data |
ReplicatedMapAddEntryListenerToKeyMessageTask.getKey() |
abstract Data |
AbstractReplicatedMapAddEntryListenerMessageTask.getKey() |
Data |
ReplicatedMapAddEntryListenerToKeyWithPredicateMessageTask.getKey() |
Data |
ReplicatedMapAddEntryListenerWithPredicateMessageTask.getKey() |
Modifier and Type | Method and Description |
---|---|
protected ClientMessage |
ReplicatedMapAddEntryListenerMessageTask.encodeEvent(Data key,
Data newValue,
Data oldValue,
Data mergingValue,
int type,
String uuid,
int numberOfAffectedEntries) |
protected ClientMessage |
ReplicatedMapAddEntryListenerToKeyMessageTask.encodeEvent(Data key,
Data newValue,
Data oldValue,
Data mergingValue,
int type,
String uuid,
int numberOfAffectedEntries) |
protected abstract ClientMessage |
AbstractReplicatedMapAddEntryListenerMessageTask.encodeEvent(Data key,
Data newValue,
Data oldValue,
Data mergingValue,
int type,
String uuid,
int numberOfAffectedEntries) |
protected ClientMessage |
ReplicatedMapAddEntryListenerToKeyWithPredicateMessageTask.encodeEvent(Data key,
Data newValue,
Data oldValue,
Data mergingValue,
int type,
String uuid,
int numberOfAffectedEntries) |
protected ClientMessage |
ReplicatedMapAddEntryListenerWithPredicateMessageTask.encodeEvent(Data key,
Data newValue,
Data oldValue,
Data mergingValue,
int type,
String uuid,
int numberOfAffectedEntries) |
Modifier and Type | Method and Description |
---|---|
void |
ListCodecTemplate.add(String name,
Data value) |
void |
SetCodecTemplate.add(String name,
Data value) |
void |
TransactionalSetCodecTemplate.add(String name,
String txnId,
long threadId,
Data item) |
void |
TransactionalListCodecTemplate.add(String name,
String txnId,
long threadId,
Data item) |
void |
ReplicatedMapCodecTemplate.addEntryListenerToKey(String name,
Data key) |
void |
MultiMapCodecTemplate.addEntryListenerToKey(String name,
Data key,
boolean includeValue) |
void |
MapCodecTemplate.addEntryListenerToKey(String name,
Data key,
boolean includeValue) |
void |
ReplicatedMapCodecTemplate.addEntryListenerToKeyWithPredicate(String name,
Data key,
Data predicate) |
void |
MapCodecTemplate.addEntryListenerToKeyWithPredicate(String name,
Data key,
Data predicate,
boolean includeValue) |
void |
ReplicatedMapCodecTemplate.addEntryListenerWithPredicate(String name,
Data predicate) |
void |
MapCodecTemplate.addEntryListenerWithPredicate(String name,
Data predicate,
boolean includeValue) |
void |
MapCodecTemplate.addInterceptor(String name,
Data interceptor) |
void |
ListCodecTemplate.addWithIndex(String name,
int index,
Data value) |
void |
AtomicReferenceCodecTemplate.alter(String name,
Data function) |
void |
AtomicLongCodecTemplate.alter(String name,
Data function) |
void |
AtomicReferenceCodecTemplate.alterAndGet(String name,
Data function) |
void |
AtomicLongCodecTemplate.alterAndGet(String name,
Data function) |
void |
AtomicReferenceCodecTemplate.apply(String name,
Data function) |
void |
AtomicLongCodecTemplate.apply(String name,
Data function) |
void |
ClientMessageTemplate.authenticationCustom(Data credentials,
String uuid,
String ownerUuid,
boolean isOwnerConnection) |
void |
EventResponseTemplate.CacheInvalidation(String name,
Data key,
String sourceUuid) |
void |
AtomicReferenceCodecTemplate.compareAndSet(String name,
Data expected,
Data updated) |
void |
AtomicReferenceCodecTemplate.contains(String name,
Data expected) |
void |
ListCodecTemplate.contains(String name,
Data value) |
void |
QueueCodecTemplate.contains(String name,
Data value) |
void |
SetCodecTemplate.contains(String name,
Data value) |
void |
MultiMapCodecTemplate.containsEntry(String name,
Data key,
Data value,
long threadId) |
void |
ReplicatedMapCodecTemplate.containsKey(String name,
Data key) |
void |
CacheCodecTemplate.containsKey(String name,
Data key) |
void |
MultiMapCodecTemplate.containsKey(String name,
Data key,
long threadId) |
void |
MapCodecTemplate.containsKey(String name,
Data key,
long threadId) |
void |
TransactionalMapCodecTemplate.containsKey(String name,
String txnId,
long threadId,
Data key) |
void |
ReplicatedMapCodecTemplate.containsValue(String name,
Data value) |
void |
MultiMapCodecTemplate.containsValue(String name,
Data value) |
void |
MapCodecTemplate.containsValue(String name,
Data value) |
void |
MultiMapCodecTemplate.count(String name,
Data key,
long threadId) |
void |
CacheCodecTemplate.createConfig(Data cacheConfig,
boolean createAlsoOnOthers) |
void |
ResponseTemplate.Data(Data response) |
void |
MapCodecTemplate.delete(String name,
Data key,
long threadId) |
void |
TransactionalMapCodecTemplate.delete(String name,
String txnId,
long threadId,
Data key) |
void |
MapCodecTemplate.entriesWithPagingPredicate(String name,
Data predicate) |
void |
MapCodecTemplate.entriesWithPredicate(String name,
Data predicate) |
void |
EventResponseTemplate.Entry(Data key,
Data value,
Data oldValue,
Data mergingValue,
int eventType,
String uuid,
int numberOfAffectedEntries) |
void |
CacheCodecTemplate.entryProcessor(String name,
Data key,
Data entryProcessor,
List<Data> arguments,
int completionId) |
void |
MapCodecTemplate.evict(String name,
Data key,
long threadId) |
void |
MapCodecTemplate.executeOnAllKeys(String name,
Data entryProcessor) |
void |
MapCodecTemplate.executeOnKey(String name,
Data entryProcessor,
Data key) |
void |
MapCodecTemplate.executeOnKeys(String name,
Data entryProcessor,
Set<Data> keys) |
void |
MapCodecTemplate.executeWithPredicate(String name,
Data entryProcessor,
Data predicate) |
void |
MultiMapCodecTemplate.forceUnlock(String name,
Data key) |
void |
MapCodecTemplate.forceUnlock(String name,
Data key) |
void |
MapReduceCodecTemplate.forCustom(String name,
String jobId,
Data predicate,
Data mapper,
Data combinerFactory,
Data reducerFactory,
Data keyValueSource,
int chunkSize,
List<Data> keys,
String topologyChangedStrategy) |
void |
MapReduceCodecTemplate.forList(String name,
String jobId,
Data predicate,
Data mapper,
Data combinerFactory,
Data reducerFactory,
String listName,
int chunkSize,
List<Data> keys,
String topologyChangedStrategy) |
void |
MapReduceCodecTemplate.forMap(String name,
String jobId,
Data predicate,
Data mapper,
Data combinerFactory,
Data reducerFactory,
String mapName,
int chunkSize,
List<Data> keys,
String topologyChangedStrategy) |
void |
MapReduceCodecTemplate.forMultiMap(String name,
String jobId,
Data predicate,
Data mapper,
Data combinerFactory,
Data reducerFactory,
String multiMapName,
int chunkSize,
List<Data> keys,
String topologyChangedStrategy) |
void |
MapReduceCodecTemplate.forSet(String name,
String jobId,
Data predicate,
Data mapper,
Data combinerFactory,
Data reducerFactory,
String setName,
int chunkSize,
List<Data> keys,
String topologyChangedStrategy) |
void |
ReplicatedMapCodecTemplate.get(String name,
Data key) |
void |
CacheCodecTemplate.get(String name,
Data key,
Data expiryPolicy) |
void |
MultiMapCodecTemplate.get(String name,
Data key,
long threadId) |
void |
MapCodecTemplate.get(String name,
Data key,
long threadId) |
void |
TransactionalMapCodecTemplate.get(String name,
String txnId,
long threadId,
Data key) |
void |
TransactionalMultiMapCodecTemplate.get(String name,
String txnId,
long threadId,
Data key) |
void |
CacheCodecTemplate.getAll(String name,
Set<Data> keys,
Data expiryPolicy) |
void |
AtomicReferenceCodecTemplate.getAndAlter(String name,
Data function) |
void |
AtomicLongCodecTemplate.getAndAlter(String name,
Data function) |
void |
CacheCodecTemplate.getAndRemove(String name,
Data key,
int completionId) |
void |
CacheCodecTemplate.getAndReplace(String name,
Data key,
Data value,
Data expiryPolicy,
int completionId) |
void |
AtomicReferenceCodecTemplate.getAndSet(String name,
Data newValue) |
void |
MapCodecTemplate.getAsync(String name,
Data key,
long threadId) |
void |
MapCodecTemplate.getEntryView(String name,
Data key,
long threadId) |
void |
TransactionalMapCodecTemplate.getForUpdate(String name,
String txnId,
long threadId,
Data key) |
void |
ListCodecTemplate.indexOf(String name,
Data value) |
void |
MultiMapCodecTemplate.isLocked(String name,
Data key) |
void |
MapCodecTemplate.isLocked(String name,
Data key) |
void |
EventResponseTemplate.Item(Data item,
String uuid,
int eventType) |
void |
MapCodecTemplate.keySetWithPagingPredicate(String name,
Data predicate) |
void |
MapCodecTemplate.keySetWithPredicate(String name,
Data predicate) |
void |
TransactionalMapCodecTemplate.keySetWithPredicate(String name,
String txnId,
long threadId,
Data predicate) |
void |
ListCodecTemplate.lastIndexOf(String name,
Data value) |
void |
CacheCodecTemplate.listenerRegistration(String name,
Data listenerConfig,
boolean register,
String hostname,
int port) |
void |
MultiMapCodecTemplate.lock(String name,
Data key,
long threadId,
long ttl) |
void |
MapCodecTemplate.lock(String name,
Data key,
long threadId,
long ttl) |
void |
QueueCodecTemplate.offer(String name,
Data value,
long timeoutMillis) |
void |
TransactionalQueueCodecTemplate.offer(String name,
String txnId,
long threadId,
Data item,
long timeout) |
void |
TopicCodecTemplate.publish(String name,
Data message) |
void |
QueueCodecTemplate.put(String name,
Data value) |
void |
CacheCodecTemplate.put(String name,
Data key,
Data value,
Data expiryPolicy,
boolean get,
int completionId) |
void |
ReplicatedMapCodecTemplate.put(String name,
Data key,
Data value,
long ttl) |
void |
MultiMapCodecTemplate.put(String name,
Data key,
Data value,
long threadId) |
void |
MapCodecTemplate.put(String name,
Data key,
Data value,
long threadId,
long ttl) |
void |
TransactionalMultiMapCodecTemplate.put(String name,
String txnId,
long threadId,
Data key,
Data value) |
void |
TransactionalMapCodecTemplate.put(String name,
String txnId,
long threadId,
Data key,
Data value,
long ttl) |
void |
MapCodecTemplate.putAsync(String name,
Data key,
Data value,
long threadId,
long ttl) |
void |
CacheCodecTemplate.putIfAbsent(String name,
Data key,
Data value,
Data expiryPolicy,
int completionId) |
void |
MapCodecTemplate.putIfAbsent(String name,
Data key,
Data value,
long threadId,
long ttl) |
void |
TransactionalMapCodecTemplate.putIfAbsent(String name,
String txnId,
long threadId,
Data key,
Data value) |
void |
MapCodecTemplate.putTransient(String name,
Data key,
Data value,
long threadId,
long ttl) |
void |
ReplicatedMapCodecTemplate.remove(String name,
Data key) |
void |
ListCodecTemplate.remove(String name,
Data value) |
void |
QueueCodecTemplate.remove(String name,
Data value) |
void |
SetCodecTemplate.remove(String name,
Data value) |
void |
CacheCodecTemplate.remove(String name,
Data key,
Data currentValue,
int completionId) |
void |
MultiMapCodecTemplate.remove(String name,
Data key,
long threadId) |
void |
MapCodecTemplate.remove(String name,
Data key,
long threadId) |
void |
TransactionalSetCodecTemplate.remove(String name,
String txnId,
long threadId,
Data item) |
void |
TransactionalMapCodecTemplate.remove(String name,
String txnId,
long threadId,
Data key) |
void |
TransactionalMultiMapCodecTemplate.remove(String name,
String txnId,
long threadId,
Data key) |
void |
TransactionalListCodecTemplate.remove(String name,
String txnId,
long threadId,
Data item) |
void |
MapCodecTemplate.removeAsync(String name,
Data key,
long threadId) |
void |
MultiMapCodecTemplate.removeEntry(String name,
Data key,
Data value,
long threadId) |
void |
TransactionalMultiMapCodecTemplate.removeEntry(String name,
String txnId,
long threadId,
Data key,
Data value) |
void |
MapCodecTemplate.removeIfSame(String name,
Data key,
Data value,
long threadId) |
void |
TransactionalMapCodecTemplate.removeIfSame(String name,
String txnId,
long threadId,
Data key,
Data value) |
void |
CacheCodecTemplate.replace(String name,
Data key,
Data oldValue,
Data newValue,
Data expiryPolicy,
int completionId) |
void |
MapCodecTemplate.replace(String name,
Data key,
Data value,
long threadId) |
void |
TransactionalMapCodecTemplate.replace(String name,
String txnId,
long threadId,
Data key,
Data value) |
void |
MapCodecTemplate.replaceIfSame(String name,
Data key,
Data testValue,
Data value,
long threadId) |
void |
TransactionalMapCodecTemplate.replaceIfSame(String name,
String txnId,
long threadId,
Data key,
Data oldValue,
Data newValue) |
void |
AtomicReferenceCodecTemplate.set(String name,
Data newValue) |
void |
MapCodecTemplate.set(String name,
Data key,
Data value,
long threadId,
long ttl) |
void |
ListCodecTemplate.set(String name,
int index,
Data value) |
void |
TransactionalMapCodecTemplate.set(String name,
String txnId,
long threadId,
Data key,
Data value) |
void |
AtomicReferenceCodecTemplate.setAndGet(String name,
Data newValue) |
void |
ExecutorServiceCodecTemplate.submitToAddress(String name,
String uuid,
Data callable,
String hostname,
int port) |
void |
MapCodecTemplate.submitToKey(String name,
Data entryProcessor,
Data key) |
void |
ExecutorServiceCodecTemplate.submitToPartition(String name,
String uuid,
Data callable,
int partitionId) |
void |
EventResponseTemplate.Topic(Data item,
long publishTime,
String uuid) |
void |
MultiMapCodecTemplate.tryLock(String name,
Data key,
long threadId,
long timeout) |
void |
MapCodecTemplate.tryLock(String name,
Data key,
long threadId,
long timeout) |
void |
MapCodecTemplate.tryPut(String name,
Data key,
Data value,
long threadId,
long timeout) |
void |
MapCodecTemplate.tryRemove(String name,
Data key,
long threadId,
long timeout) |
void |
MultiMapCodecTemplate.unlock(String name,
Data key,
long threadId) |
void |
MapCodecTemplate.unlock(String name,
Data key,
long threadId) |
void |
MultiMapCodecTemplate.valueCount(String name,
Data key,
long threadId) |
void |
TransactionalMultiMapCodecTemplate.valueCount(String name,
String txnId,
long threadId,
Data key) |
void |
MapCodecTemplate.valuesWithPagingPredicate(String name,
Data predicate) |
void |
MapCodecTemplate.valuesWithPredicate(String name,
Data predicate) |
void |
TransactionalMapCodecTemplate.valuesWithPredicate(String name,
String txnId,
long threadId,
Data predicate) |
Modifier and Type | Method and Description |
---|---|
void |
QueueCodecTemplate.addAll(String name,
Collection<Data> dataList) |
void |
ListCodecTemplate.addAll(String name,
List<Data> valueList) |
void |
SetCodecTemplate.addAll(String name,
List<Data> valueList) |
void |
ListCodecTemplate.addAllWithIndex(String name,
int index,
List<Data> valueList) |
void |
EventResponseTemplate.CacheBatchInvalidation(String name,
List<Data> keys,
List<String> sourceUuids) |
void |
QueueCodecTemplate.compareAndRemoveAll(String name,
Collection<Data> dataList) |
void |
ListCodecTemplate.compareAndRemoveAll(String name,
Set<Data> valueSet) |
void |
SetCodecTemplate.compareAndRemoveAll(String name,
Set<Data> valueSet) |
void |
QueueCodecTemplate.compareAndRetainAll(String name,
Collection<Data> dataList) |
void |
ListCodecTemplate.compareAndRetainAll(String name,
Set<Data> valueSet) |
void |
SetCodecTemplate.compareAndRetainAll(String name,
Set<Data> valueSet) |
void |
QueueCodecTemplate.containsAll(String name,
Collection<Data> dataList) |
void |
ListCodecTemplate.containsAll(String name,
Set<Data> valueSet) |
void |
SetCodecTemplate.containsAll(String name,
Set<Data> valueSet) |
void |
CacheCodecTemplate.entryProcessor(String name,
Data key,
Data entryProcessor,
List<Data> arguments,
int completionId) |
void |
ResponseTemplate.EntryView(SimpleEntryView<Data,Data> dataEntryView) |
void |
ResponseTemplate.EntryView(SimpleEntryView<Data,Data> dataEntryView) |
void |
MapCodecTemplate.executeOnKeys(String name,
Data entryProcessor,
Set<Data> keys) |
void |
MapReduceCodecTemplate.forCustom(String name,
String jobId,
Data predicate,
Data mapper,
Data combinerFactory,
Data reducerFactory,
Data keyValueSource,
int chunkSize,
List<Data> keys,
String topologyChangedStrategy) |
void |
MapReduceCodecTemplate.forList(String name,
String jobId,
Data predicate,
Data mapper,
Data combinerFactory,
Data reducerFactory,
String listName,
int chunkSize,
List<Data> keys,
String topologyChangedStrategy) |
void |
MapReduceCodecTemplate.forMap(String name,
String jobId,
Data predicate,
Data mapper,
Data combinerFactory,
Data reducerFactory,
String mapName,
int chunkSize,
List<Data> keys,
String topologyChangedStrategy) |
void |
MapReduceCodecTemplate.forMultiMap(String name,
String jobId,
Data predicate,
Data mapper,
Data combinerFactory,
Data reducerFactory,
String multiMapName,
int chunkSize,
List<Data> keys,
String topologyChangedStrategy) |
void |
MapReduceCodecTemplate.forSet(String name,
String jobId,
Data predicate,
Data mapper,
Data combinerFactory,
Data reducerFactory,
String setName,
int chunkSize,
List<Data> keys,
String topologyChangedStrategy) |
void |
MapCodecTemplate.getAll(String name,
Set<Data> keys) |
void |
CacheCodecTemplate.getAll(String name,
Set<Data> keys,
Data expiryPolicy) |
void |
ResponseTemplate.ListData(List<Data> list) |
void |
CacheCodecTemplate.loadAll(String name,
Set<Data> keys,
boolean replaceExistingValues) |
void |
MapCodecTemplate.loadGivenKeys(String name,
List<Data> keys,
boolean replaceExistingValues) |
void |
ResponseTemplate.MapDataData(Map<Data,Data> map) |
void |
ResponseTemplate.MapDataData(Map<Data,Data> map) |
void |
ResponseTemplate.MapIntData(Map<Integer,Data> map) |
void |
ReplicatedMapCodecTemplate.putAll(String name,
Map<Data,Data> map) |
void |
ReplicatedMapCodecTemplate.putAll(String name,
Map<Data,Data> map) |
void |
MapCodecTemplate.putAll(String name,
Map<Data,Data> entries) |
void |
MapCodecTemplate.putAll(String name,
Map<Data,Data> entries) |
void |
CacheCodecTemplate.removeAllKeys(String name,
Set<Data> keys,
int completionId) |
void |
ResponseTemplate.SetData(Set<Data> list) |
void |
ResponseTemplate.SetEntry(List<Data> keys,
List<Data> values) |
void |
ResponseTemplate.SetEntry(List<Data> keys,
List<Data> values) |
Modifier and Type | Method and Description |
---|---|
Data |
MessageFlyweight.getData() |
Modifier and Type | Method and Description |
---|---|
List<Data> |
MessageFlyweight.getDataList() |
Set<Data> |
MessageFlyweight.getDataSet() |
Modifier and Type | Method and Description |
---|---|
static int |
ParameterUtil.calculateDataSize(Data key) |
MessageFlyweight |
MessageFlyweight.set(Data data) |
Modifier and Type | Method and Description |
---|---|
MessageFlyweight |
MessageFlyweight.set(Collection<Data> value) |
Modifier and Type | Method and Description |
---|---|
Data |
ClientSemaphoreProxy.getKey() |
Modifier and Type | Method and Description |
---|---|
protected Data |
ClientProxy.toData(Object 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 |
---|---|
void |
ClientInvocationFuture.andThenInternal(ExecutionCallback<Data> callback) |
Modifier and Type | Method and Description |
---|---|
void |
ClientDelegatingFuture.andThenInternal(ExecutionCallback<Data> callback) |
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 | 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() |
Map<Long,Data> |
CollectionContainer.compareAndRemove(boolean retain,
Set<Data> valueSet) |
Collection<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(String transactionId,
Data value) |
CollectionItem |
CollectionContainer.reserveRemove(long reservedItemId,
Data value,
String 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) |
Constructor and Description |
---|
CollectionEvent(String name,
Data data,
ItemEventType eventType,
Address caller) |
CollectionItem(long itemId,
Data value) |
TxCollectionItem(long itemId,
Data value,
String transactionId,
boolean removeOperation) |
Modifier and Type | Field and Description |
---|---|
protected Data |
CollectionAddRequest.value |
Modifier and Type | Field and Description |
---|---|
protected List<Data> |
CollectionAddAllRequest.valueList |
Constructor and Description |
---|
CollectionAddRequest(String name,
Data value) |
CollectionContainsRequest(String name,
Data value) |
CollectionRemoveRequest(String name,
Data value) |
Constructor and Description |
---|
CollectionAddAllRequest(String name,
List<Data> valueList) |
CollectionCompareAndRemoveRequest(String name,
Set<Data> valueSet,
boolean retain) |
CollectionContainsRequest(String name,
Set<Data> valueSet) |
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 |
---|---|
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 |
---|
ListAddRequest(String name,
Data value,
int index) |
ListIndexOfRequest(String name,
Data value,
boolean last) |
ListSetRequest(String name,
int index,
Data value) |
Constructor and Description |
---|
ListAddAllRequest(String name,
List<Data> valueList,
int index) |
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) |
Modifier and Type | Method and Description |
---|---|
Map<Long,Data> |
QueueContainer.addAll(Collection<Data> dataList) |
Map<Long,Data> |
QueueContainer.clear() |
Map<Long,Data> |
QueueContainer.compareAndRemove(Collection<Data> dataList,
boolean retain)
This method triggers store load
|
Map<Long,Data> |
QueueContainer.drain(int maxSize) |
List<Data> |
QueueContainer.getAsDataList()
This method triggers store load.
|
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) |
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) |
Modifier and Type | Method and Description |
---|---|
Map<Long,Data> |
QueueContainer.addAll(Collection<Data> dataList) |
void |
QueueContainer.addAllBackup(Map<Long,Data> dataMap) |
Map<Long,Data> |
QueueContainer.compareAndRemove(Collection<Data> dataList,
boolean retain)
This method triggers store load
|
boolean |
QueueContainer.contains(Collection<Data> dataSet)
This method does not trigger store load.
|
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) |
Constructor and Description |
---|
OfferRequest(String name,
Data data) |
OfferRequest(String name,
long timeoutMillis,
Data data) |
RemoveRequest(String name,
Data data) |
Constructor and Description |
---|
AddAllRequest(String name,
Collection<Data> dataList) |
CompareAndRemoveRequest(String name,
Collection<Data> dataList,
boolean retain) |
ContainsRequest(String name,
Collection<Data> dataList) |
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) |
Modifier and Type | Field and Description |
---|---|
protected Data |
TxnCollectionRequest.value |
Constructor and Description |
---|
TxnCollectionRequest(String name,
Data value) |
Constructor and Description |
---|
CollectionReserveAddOperation(String name,
String transactionId,
Data value) |
CollectionReserveRemoveOperation(String name,
long reservedItemId,
Data value,
String transactionId) |
CollectionTxnAddBackupOperation(String name,
long itemId,
Data value) |
CollectionTxnAddOperation(String name,
long itemId,
Data value) |
Constructor and Description |
---|
TxnListAddRequest(String name,
Data value) |
TxnListRemoveRequest(String name,
Data value) |
Modifier and Type | Method and Description |
---|---|
Data |
TransactionalQueueProxySupport.peekInternal(long timeout) |
Data |
TransactionalQueueProxySupport.pollInternal(long timeout) |
Modifier and Type | Method and Description |
---|---|
boolean |
TransactionalQueueProxySupport.offerInternal(Data data,
long timeout) |
Constructor and Description |
---|
TxQueueItem(QueueContainer container,
long itemId,
Data data) |
Constructor and Description |
---|
TxnOfferRequest(String name,
long timeout,
Data data) |
Constructor and Description |
---|
TxnOfferBackupOperation(String name,
long itemId,
Data data) |
TxnOfferOperation(String name,
long itemId,
Data data) |
Constructor and Description |
---|
TxnSetAddRequest(String name,
Data value) |
TxnSetRemoveRequest(String name,
Data value) |
Modifier and Type | Field and Description |
---|---|
protected Data |
AbstractAlterRequest.function |
Constructor and Description |
---|
AbstractAlterRequest(String name,
Data function) |
AlterAndGetRequest(String name,
Data function) |
AlterRequest(String name,
Data function) |
ApplyRequest(String name,
Data function) |
GetAndAlterRequest(String name,
Data function) |
Modifier and Type | Method and Description |
---|---|
Data |
AtomicReferenceContainer.get() |
Data |
AtomicReferenceContainer.getAndSet(Data value) |
Modifier and Type | Method and Description |
---|---|
boolean |
AtomicReferenceContainer.compareAndSet(Data expect,
Data value) |
boolean |
AtomicReferenceContainer.contains(Data expected) |
Data |
AtomicReferenceContainer.getAndSet(Data value) |
void |
AtomicReferenceContainer.set(Data value) |
Modifier and Type | Field and Description |
---|---|
protected Data |
AbstractAlterRequest.function |
Constructor and Description |
---|
AbstractAlterRequest(String name,
Data function) |
AlterAndGetRequest(String name,
Data function) |
AlterRequest(String name,
Data function) |
ApplyRequest(String name,
Data function) |
CompareAndSetRequest(String name,
Data expected,
Data update) |
ContainsRequest(String name,
Data expected) |
GetAndAlterRequest(String name,
Data function) |
GetAndSetRequest(String name,
Data update) |
ModifyRequest(String name,
Data update) |
SetRequest(String name,
Data update) |
Modifier and Type | Field and Description |
---|---|
protected Data |
AbstractAlterOperation.backup |
protected Data |
AbstractAlterOperation.function |
protected Data |
ApplyOperation.function |
protected Data |
ApplyOperation.returnValue |
Constructor and Description |
---|
AbstractAlterOperation(String name,
Data function) |
AlterAndGetOperation(String name,
Data function) |
AlterOperation(String name,
Data function) |
ApplyOperation(String name,
Data function) |
CompareAndSetOperation(String name,
Data expect,
Data update) |
ContainsOperation(String name,
Data contains) |
GetAndAlterOperation(String name,
Data function) |
GetAndSetOperation(String name,
Data newValue) |
SetAndGetOperation(String name,
Data newValue) |
SetBackupOperation(String name,
Data newValue) |
SetOperation(String name,
Data newValue) |
Constructor and Description |
---|
AtomicReferenceReplicationOperation(Map<String,Data> migrationData) |
Modifier and Type | Method and Description |
---|---|
Data |
ConditionKey.getKey() |
Data |
LockResource.getKey() |
Data |
LockProxy.getKeyData() |
Modifier and Type | Method and Description |
---|---|
Set<Data> |
LockStoreProxy.getLockedKeys() |
Set<Data> |
LockStore.getLockedKeys() |
Set<Data> |
LockStoreImpl.getLockedKeys() |
Modifier and Type | Method and Description |
---|---|
boolean |
LockStoreImpl.addAwait(Data key,
String conditionId,
String caller,
long threadId) |
boolean |
LockStoreProxy.canAcquireLock(Data key,
String caller,
long threadId) |
boolean |
LockStore.canAcquireLock(Data key,
String caller,
long threadId) |
boolean |
LockStoreImpl.canAcquireLock(Data key,
String caller,
long threadId) |
void |
LockServiceImpl.cancelEviction(ObjectNamespace namespace,
Data key) |
boolean |
LockStoreProxy.extendLeaseTime(Data key,
String caller,
long threadId,
long ttl) |
boolean |
LockStore.extendLeaseTime(Data key,
String caller,
long threadId,
long ttl) |
boolean |
LockStoreImpl.extendLeaseTime(Data key,
String caller,
long threadId,
long leaseTime) |
boolean |
LockStoreProxy.forceUnlock(Data key) |
boolean |
LockStore.forceUnlock(Data dataKey) |
boolean |
LockStoreImpl.forceUnlock(Data key) |
void |
LockProxySupport.forceUnlock(NodeEngine nodeEngine,
Data key) |
int |
LockStoreImpl.getAwaitCount(Data key,
String conditionId) |
int |
LockStoreProxy.getLockCount(Data key) |
int |
LockStore.getLockCount(Data key) |
int |
LockStoreImpl.getLockCount(Data key) |
int |
LockProxySupport.getLockCount(NodeEngine nodeEngine,
Data key) |
String |
LockStoreProxy.getOwnerInfo(Data dataKey) |
String |
LockStore.getOwnerInfo(Data dataKey) |
String |
LockStoreImpl.getOwnerInfo(Data key) |
long |
LockStoreProxy.getRemainingLeaseTime(Data key) |
long |
LockStore.getRemainingLeaseTime(Data key) |
long |
LockStoreImpl.getRemainingLeaseTime(Data key) |
long |
LockProxySupport.getRemainingLeaseTime(NodeEngine nodeEngine,
Data key) |
ConditionKey |
LockStoreImpl.getSignalKey(Data key) |
int |
LockStoreImpl.getVersion(Data key) |
boolean |
LockStoreProxy.isLocked(Data key) |
boolean |
LockStore.isLocked(Data key) |
boolean |
LockStoreImpl.isLocked(Data key) |
boolean |
LockProxySupport.isLocked(NodeEngine nodeEngine,
Data key) |
boolean |
LockStoreProxy.isLockedBy(Data key,
String caller,
long threadId) |
boolean |
LockStore.isLockedBy(Data key,
String caller,
long threadId) |
boolean |
LockStoreImpl.isLockedBy(Data key,
String caller,
long threadId) |
boolean |
LockProxySupport.isLockedByCurrentThread(NodeEngine nodeEngine,
Data key) |
boolean |
LockStoreProxy.isTransactionallyLocked(Data key) |
boolean |
LockStore.isTransactionallyLocked(Data key) |
boolean |
LockStoreImpl.isTransactionallyLocked(Data key) |
boolean |
LockStoreImpl.lock(Data key,
String caller,
long threadId) |
boolean |
LockStoreProxy.lock(Data key,
String caller,
long threadId,
long ttl) |
boolean |
LockStore.lock(Data key,
String caller,
long threadId,
long ttl) |
boolean |
LockStoreImpl.lock(Data key,
String caller,
long threadId,
long leaseTime) |
void |
LockProxySupport.lock(NodeEngine nodeEngine,
Data key) |
void |
LockProxySupport.lock(NodeEngine nodeEngine,
Data key,
long ttl) |
void |
LockProxySupport.lockInterruptly(NodeEngine nodeEngine,
Data key) |
void |
LockProxySupport.lockInterruptly(NodeEngine nodeEngine,
Data key,
long ttl) |
AwaitOperation |
LockStoreImpl.pollExpiredAwaitOp(Data key) |
boolean |
LockStoreImpl.removeAwait(Data key,
String conditionId,
String caller,
long threadId) |
void |
LockServiceImpl.scheduleEviction(ObjectNamespace namespace,
Data key,
int version,
long delay) |
boolean |
LockStoreImpl.startAwaiting(Data key,
String conditionId,
String caller,
long threadId) |
boolean |
LockProxySupport.tryLock(NodeEngine nodeEngine,
Data key) |
boolean |
LockProxySupport.tryLock(NodeEngine nodeEngine,
Data key,
long timeout,
TimeUnit timeunit) |
boolean |
LockStoreProxy.txnLock(Data key,
String caller,
long threadId,
long ttl) |
boolean |
LockStore.txnLock(Data key,
String caller,
long threadId,
long ttl) |
boolean |
LockStoreImpl.txnLock(Data key,
String caller,
long threadId,
long leaseTime) |
boolean |
LockStoreProxy.unlock(Data key,
String caller,
long threadId) |
boolean |
LockStore.unlock(Data key,
String caller,
long threadId) |
boolean |
LockStoreImpl.unlock(Data key,
String caller,
long threadId) |
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 |
---|
ConditionKey(String name,
Data key,
String conditionId) |
LockWaitNotifyKey(ObjectNamespace namespace,
Data key) |
Modifier and Type | Field and Description |
---|---|
protected Data |
AbstractLockRequest.key |
protected Data |
AbstractUnlockRequest.key |
protected Data |
AbstractIsLockedRequest.key |
Constructor and Description |
---|
AbstractIsLockedRequest(Data key) |
AbstractIsLockedRequest(Data key,
long threadId) |
AbstractLockRequest(Data key,
long threadId) |
AbstractLockRequest(Data key,
long threadId,
long ttl,
long timeout) |
AbstractUnlockRequest(Data key,
long threadId) |
AbstractUnlockRequest(Data key,
long threadId,
boolean force) |
BeforeAwaitRequest(ObjectNamespace namespace,
long threadId,
String conditionId,
Data key) |
GetLockCountRequest(Data key) |
GetRemainingLeaseRequest(Data key) |
IsLockedRequest(Data key) |
IsLockedRequest(Data key,
long threadId) |
LockRequest(Data key,
long threadId,
long ttl,
long timeout) |
UnlockRequest(Data key,
long threadId) |
UnlockRequest(Data key,
long threadId,
boolean force) |
Constructor and Description |
---|
AwaitBackupOperation(ObjectNamespace namespace,
Data key,
long threadId,
String conditionId,
String originalCaller) |
AwaitOperation(ObjectNamespace namespace,
Data key,
long threadId,
long timeout,
String conditionId) |
BeforeAwaitBackupOperation(ObjectNamespace namespace,
Data key,
long threadId,
String conditionId,
String originalCaller) |
BeforeAwaitOperation(ObjectNamespace namespace,
Data key,
long threadId,
String conditionId) |
GetLockCountOperation(ObjectNamespace namespace,
Data key) |
GetRemainingLeaseTimeOperation(ObjectNamespace namespace,
Data key) |
IsLockedOperation(ObjectNamespace namespace,
Data key) |
IsLockedOperation(ObjectNamespace namespace,
Data key,
long threadId) |
LocalLockCleanupOperation(ObjectNamespace namespace,
Data key,
long threadId) |
LockBackupOperation(ObjectNamespace namespace,
Data key,
long threadId,
String originalCallerUuid) |
LockOperation(ObjectNamespace namespace,
Data key,
long threadId,
long timeout) |
LockOperation(ObjectNamespace namespace,
Data key,
long threadId,
long ttl,
long timeout) |
SignalBackupOperation(ObjectNamespace namespace,
Data key,
long threadId,
String conditionId,
boolean all) |
SignalOperation(ObjectNamespace namespace,
Data key,
long threadId,
String conditionId,
boolean all) |
UnlockBackupOperation(ObjectNamespace namespace,
Data key,
long threadId,
String 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) |
Constructor and Description |
---|
CallableTaskOperation(String name,
String uuid,
Data callableData) |
MemberCallableTaskOperation(String name,
String uuid,
Data callableData) |
Modifier and Type | Method and Description |
---|---|
Data |
Storage.get(int hash,
REF ref) |
Modifier and Type | Method and Description |
---|---|
REF |
Storage.put(int hash,
Data data) |
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() |
Data |
EntryEventFilter.getKey() |
Data |
DataAwareEntryEvent.getKeyData() |
Data |
DataAwareEntryEvent.getMergingValueData() |
Data |
DataAwareEntryEvent.getNewValueData() |
Data |
DataAwareEntryEvent.getOldValueData() |
Data |
RecordStore.readBackupData(Data key)
Called when
MapConfig.isReadBackupData() is true from
MapProxySupport.getInternal(com.hazelcast.nio.serialization.Data)
Returns corresponding value for key as Data . |
Data |
DefaultRecordStore.readBackupData(Data key) |
Data |
MapServiceContext.toData(Object object) |
Data |
MapServiceContext.toData(Object object,
PartitioningStrategy partitionStrategy) |
Modifier and Type | Method and Description |
---|---|
Set<Map.Entry<Data,Data>> |
RecordStore.entrySetData() |
Set<Map.Entry<Data,Data>> |
RecordStore.entrySetData() |
Set<Map.Entry<Data,Data>> |
DefaultRecordStore.entrySetData() |
Set<Map.Entry<Data,Data>> |
DefaultRecordStore.entrySetData() |
Set<Map.Entry<Data,Data>> |
MapEntrySet.getEntrySet() |
Set<Map.Entry<Data,Data>> |
MapEntrySet.getEntrySet() |
Set<Data> |
MapKeySet.getKeySet() |
MapDataStore<Data,Object> |
RecordStore.getMapDataStore() |
MapDataStore<Data,Object> |
DefaultRecordStore.getMapDataStore() |
Map.Entry<Data,Object> |
RecordStore.getMapEntry(Data dataKey,
long now) |
Map.Entry<Data,Object> |
DefaultRecordStore.getMapEntry(Data key,
long now) |
Map<Data,NearCacheRecord> |
NearCache.getReadonlyMap() |
Map<Data,Record> |
RecordStore.getRecordMap()
Returns records map.
|
Map<Data,Record> |
DefaultRecordStore.getRecordMap() |
Collection<Data> |
MapValueCollection.getValues() |
Set<Data> |
RecordStore.keySet() |
Set<Data> |
DefaultRecordStore.keySet() |
IFunction<Object,Data> |
MapContainer.toData() |
Collection<Data> |
RecordStore.valuesData() |
Collection<Data> |
DefaultRecordStore.valuesData() |
Modifier and Type | Method and Description |
---|---|
void |
MapEntrySet.add(Data key,
Data value) |
boolean |
RecordStore.canAcquireLock(Data key,
String caller,
long threadId) |
boolean |
DefaultRecordStore.canAcquireLock(Data key,
String caller,
long threadId) |
boolean |
RecordStore.containsKey(Data dataKey) |
boolean |
DefaultRecordStore.containsKey(Data key) |
Record |
MapContainer.createRecord(Data key,
Object value,
long ttlMillis,
long now) |
boolean |
RecordStore.delete(Data dataKey) |
boolean |
DefaultRecordStore.delete(Data key) |
Object |
RecordStore.evict(Data key,
boolean backup) |
Object |
DefaultRecordStore.evict(Data key,
boolean backup) |
boolean |
RecordStore.extendLock(Data key,
String caller,
long threadId,
long ttl) |
boolean |
DefaultRecordStore.extendLock(Data key,
String caller,
long threadId,
long ttl) |
boolean |
RecordStore.forceUnlock(Data dataKey) |
boolean |
DefaultRecordStore.forceUnlock(Data dataKey) |
Object |
NearCache.get(Data key) |
Object |
RecordStore.get(Data dataKey,
boolean backup)
Gets record from
RecordStore . |
Object |
DefaultRecordStore.get(Data key,
boolean backup) |
Object |
NearCacheProvider.getFromNearCache(String mapName,
Data key) |
String |
RecordStore.getLockOwnerInfo(Data key) |
String |
DefaultRecordStore.getLockOwnerInfo(Data key) |
Map.Entry<Data,Object> |
RecordStore.getMapEntry(Data dataKey,
long now) |
Map.Entry<Data,Object> |
DefaultRecordStore.getMapEntry(Data key,
long now) |
Record |
RecordStore.getRecord(Data key) |
Record |
DefaultRecordStore.getRecord(Data key) |
Record |
RecordStore.getRecordOrNull(Data key)
Returns live record or null if record is already expired.
|
Record |
DefaultRecordStore.getRecordOrNull(Data key) |
void |
NearCache.invalidate(Data key) |
void |
NearCacheProvider.invalidateAllNearCaches(String mapName,
Data key) |
void |
NearCacheProvider.invalidateNearCache(String mapName,
Data key) |
boolean |
RecordStore.isLocked(Data key) |
boolean |
DefaultRecordStore.isLocked(Data dataKey) |
boolean |
RecordStore.isTransactionallyLocked(Data key) |
boolean |
DefaultRecordStore.isTransactionallyLocked(Data key) |
boolean |
RecordStore.merge(Data dataKey,
EntryView mergingEntryView,
MapMergePolicy mergePolicy) |
boolean |
DefaultRecordStore.merge(Data key,
EntryView mergingEntry,
MapMergePolicy mergePolicy) |
void |
MapEventPublisher.publishEvent(Address caller,
String mapName,
EntryEventType eventType,
boolean synthetic,
Data dataKey,
Data dataOldValue,
Data dataValue) |
void |
MapEventPublisher.publishEvent(Address caller,
String mapName,
EntryEventType eventType,
boolean synthetic,
Data dataKey,
Data dataOldValue,
Data dataValue,
Data dataMergingValue) |
void |
MapEventPublisher.publishEvent(Address caller,
String mapName,
EntryEventType eventType,
Data dataKey,
Data dataOldValue,
Data dataValue) |
void |
MapEventPublisher.publishWanReplicationRemove(String mapName,
Data key,
long removeTime) |
Object |
NearCache.put(Data key,
Data data) |
Object |
RecordStore.put(Data dataKey,
Object dataValue,
long ttl) |
Object |
DefaultRecordStore.put(Data key,
Object value,
long ttl) |
Record |
RecordStore.putBackup(Data key,
Object value) |
Record |
DefaultRecordStore.putBackup(Data key,
Object value) |
Record |
RecordStore.putBackup(Data key,
Object value,
long ttl,
boolean putTransient) |
Record |
DefaultRecordStore.putBackup(Data key,
Object value,
long ttl,
boolean putTransient) |
Object |
RecordStore.putFromLoad(Data key,
Object value)
Puts key-value pair to map which is the result of a load from map store operation.
|
Object |
DefaultRecordStore.putFromLoad(Data key,
Object value) |
Object |
RecordStore.putFromLoad(Data key,
Object value,
long ttl)
Puts key-value pair to map which is the result of a load from map store operation.
|
Object |
DefaultRecordStore.putFromLoad(Data key,
Object value,
long ttl) |
Object |
RecordStore.putIfAbsent(Data dataKey,
Object value,
long ttl) |
Object |
DefaultRecordStore.putIfAbsent(Data key,
Object value,
long ttl) |
Object |
NearCacheProvider.putNearCache(String mapName,
Data key,
Data value) |
void |
RecordStore.putRecord(Data key,
Record record)
Puts a data key and a record value to record-store.
|
void |
DefaultRecordStore.putRecord(Data key,
Record record) |
void |
RecordStore.putTransient(Data dataKey,
Object value,
long ttl) |
void |
DefaultRecordStore.putTransient(Data key,
Object value,
long ttl) |
Data |
RecordStore.readBackupData(Data key)
Called when
MapConfig.isReadBackupData() is true from
MapProxySupport.getInternal(com.hazelcast.nio.serialization.Data)
Returns corresponding value for key as Data . |
Data |
DefaultRecordStore.readBackupData(Data key) |
Object |
RecordStore.remove(Data dataKey) |
Object |
DefaultRecordStore.remove(Data key) |
boolean |
RecordStore.remove(Data dataKey,
Object testValue) |
boolean |
DefaultRecordStore.remove(Data key,
Object testValue) |
void |
RecordStore.removeBackup(Data dataKey)
Similar to
RecordStore.remove(com.hazelcast.nio.serialization.Data)
except removeBackup doesn't touch mapstore since it does not return previous value. |
void |
DefaultRecordStore.removeBackup(Data key) |
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
RecordFactory.isEquals(java.lang.Object, java.lang.Object) comparison
of current value and expected value is true . |
boolean |
DefaultRecordStore.replace(Data key,
Object expect,
Object update) |
boolean |
RecordStore.set(Data dataKey,
Object value,
long ttl) |
boolean |
DefaultRecordStore.set(Data key,
Object value,
long ttl) |
boolean |
RecordStore.tryPut(Data dataKey,
Object value,
long ttl) |
boolean |
DefaultRecordStore.tryPut(Data key,
Object value,
long ttl) |
boolean |
RecordStore.txnLock(Data key,
String caller,
long threadId,
long ttl) |
boolean |
DefaultRecordStore.txnLock(Data key,
String caller,
long threadId,
long ttl) |
boolean |
RecordStore.unlock(Data key,
String caller,
long threadId) |
boolean |
DefaultRecordStore.unlock(Data key,
String caller,
long threadId) |
Modifier and Type | Method and Description |
---|---|
void |
MapEntrySet.add(Map.Entry<Data,Data> entry) |
void |
MapEntrySet.add(Map.Entry<Data,Data> entry) |
MapEntrySet |
RecordStore.getAll(Set<Data> keySet) |
MapEntrySet |
DefaultRecordStore.getAll(Set<Data> keys) |
void |
NearCache.invalidate(Collection<Data> keys) |
void |
NearCacheProvider.invalidateAllNearCaches(String mapName,
Set<Data> keys) |
void |
NearCacheProvider.invalidateNearCache(String mapName,
Collection<Data> keys) |
void |
RecordStore.loadAllFromStore(List<Data> keys,
boolean replaceExistingValues)
Loads all given keys from defined map store.
|
void |
DefaultRecordStore.loadAllFromStore(List<Data> keys,
boolean replaceExistingValues) |
void |
RecordStore.put(Map.Entry<Data,Object> entry) |
void |
DefaultRecordStore.put(Map.Entry<Data,Object> entry) |
Constructor and Description |
---|
DataAwareEntryEvent(Member from,
int eventType,
String source,
Data dataKey,
Data dataNewValue,
Data dataOldValue,
Data dataMergingValue,
SerializationService serializationService) |
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) |
EntryEventFilter(boolean includeValue,
Data key) |
MapRecordKey(String mapName,
Data key) |
QueryEventFilter(boolean includeValue,
Data key,
Predicate predicate) |
Constructor and Description |
---|
MapEntrySet(Set<Map.Entry<Data,Data>> entrySet) |
MapEntrySet(Set<Map.Entry<Data,Data>> entrySet) |
MapKeyLoader(String mapName,
OperationService opService,
InternalPartitionService ps,
ExecutionService execService,
IFunction<Object,Data> serialize) |
MapKeySet(Set<Data> keySet) |
MapValueCollection(Collection<Data> values) |
Modifier and Type | Field and Description |
---|---|
protected Data |
AbstractMapAddEntryListenerRequest.key |
protected Data |
MapPutRequest.key |
protected Data |
MapRemoveRequest.key |
protected Data |
MapRemoveIfSameRequest.key |
protected Data |
MapTryRemoveRequest.key |
protected Data |
MapDeleteRequest.key |
protected Data |
MapPutRequest.value |
protected Data |
MapRemoveIfSameRequest.value |
Constructor and Description |
---|
MapExecuteOnKeysRequest(String name,
EntryProcessor processor,
Set<Data> keys) |
MapGetAllRequest(String name,
Set<Data> keys) |
MapLoadGivenKeysRequest(String name,
List<Data> keys,
boolean replaceExistingValues) |
Modifier and Type | Method and Description |
---|---|
void |
EvictionOperator.fireEvent(Data key,
Object value,
String mapName,
MapServiceContext mapServiceContext) |
Modifier and Type | Method and Description |
---|---|
protected Data |
AbstractMapDataStore.toData(Object obj) |
Modifier and Type | Method and Description |
---|---|
Collection<Data> |
MapDataStore.flush()
Flushes all keys in this map-store.
|
Modifier and Type | Method and Description |
---|---|
Collection<Data> |
WriteBehindStore.flush() |
Modifier and Type | Method and Description |
---|---|
Object |
WriteBehindStore.add(Data key,
Object value,
long now) |
Object |
WriteBehindStore.addBackup(Data key,
Object value,
long time) |
void |
WriteBehindStore.addTransient(Data key,
long now) |
Object |
WriteBehindStore.flush(Data key,
Object value,
long now,
boolean backup) |
Object |
WriteBehindStore.load(Data key) |
boolean |
WriteBehindStore.loadable(Data key)
* Used in
IMap.loadAll(boolean) calls. |
void |
WriteBehindStore.remove(Data key,
long now) |
void |
WriteBehindStore.removeBackup(Data key,
long time) |
Modifier and Type | Method and Description |
---|---|
void |
WriteBehindStore.add(DelayedEntry<Data,Object> delayedEntry) |
Modifier and Type | Method and Description |
---|---|
Collection<Data> |
WriteThroughStore.flush() |
Modifier and Type | Method and Description |
---|---|
Object |
WriteThroughStore.add(Data key,
Object value,
long time) |
Object |
WriteThroughStore.addBackup(Data key,
Object value,
long time) |
void |
WriteThroughStore.addTransient(Data key,
long now) |
Object |
WriteThroughStore.flush(Data key,
Object value,
long now,
boolean backup) |
Object |
WriteThroughStore.load(Data key) |
boolean |
WriteThroughStore.loadable(Data key) |
void |
WriteThroughStore.remove(Data key,
long time) |
void |
WriteThroughStore.removeBackup(Data key,
long time) |
Modifier and Type | Field and Description |
---|---|
protected Data |
KeyBasedMapOperation.dataKey |
protected Data |
BasePutOperation.dataOldValue |
protected Data |
BaseRemoveOperation.dataOldValue |
protected Data |
KeyBasedMapOperation.dataValue |
Modifier and Type | Method and Description |
---|---|
Data |
KeyBasedMapOperation.getKey() |
Data |
KeyBasedMapOperation.getValue() |
Modifier and Type | Method and Description |
---|---|
protected void |
PutAllOperation.invalidateNearCaches(Set<Data> keys) |
Modifier and Type | Method and Description |
---|---|
Data |
Record.getKey() |
Data |
RecordReplicationInfo.getKey() |
Data |
RecordReplicationInfo.getValue() |
Modifier and Type | Method and Description |
---|---|
Record<Data> |
NativeRecordFactory.newRecord(Data key,
Object value) |
Record<Data> |
DataRecordFactory.newRecord(Data key,
Object value) |
Modifier and Type | Method and Description |
---|---|
Record<Data> |
NativeRecordFactory.newRecord(Data key,
Object value) |
Record<Object> |
ObjectRecordFactory.newRecord(Data key,
Object value) |
Record<Data> |
DataRecordFactory.newRecord(Data key,
Object value) |
Record<T> |
RecordFactory.newRecord(Data key,
Object value) |
Modifier and Type | Method and Description |
---|---|
void |
NativeRecordFactory.setValue(Record<Data> record,
Object value) |
void |
DataRecordFactory.setValue(Record<Data> record,
Object value) |
Constructor and Description |
---|
RecordReplicationInfo(Data key,
Data value,
RecordInfo recordInfo) |
Modifier and Type | Field and Description |
---|---|
protected Map<Data,VersionedValue> |
TransactionalMapProxySupport.valueMap |
Modifier and Type | Method and Description |
---|---|
Data |
TransactionalMapProxySupport.putIfAbsentInternal(Data key,
Data value) |
Data |
TransactionalMapProxySupport.putInternal(Data key,
Data value) |
Data |
TransactionalMapProxySupport.putInternal(Data key,
Data value,
long ttl,
TimeUnit timeUnit) |
Data |
TransactionalMapProxySupport.removeInternal(Data key) |
Data |
TransactionalMapProxySupport.replaceInternal(Data key,
Data value) |
Modifier and Type | Method and Description |
---|---|
protected List<Map.Entry<Data,Data>> |
TransactionalMapProxySupport.getEntries() |
protected List<Map.Entry<Data,Data>> |
TransactionalMapProxySupport.getEntries() |
protected Set<Data> |
TransactionalMapProxySupport.keySetInternal() |
Modifier and Type | Method and Description |
---|---|
boolean |
TransactionalMapProxySupport.containsKeyInternal(Data key) |
Object |
TransactionalMapProxySupport.getForUpdateInternal(Data key) |
Object |
TransactionalMapProxySupport.getInternal(Data key) |
Data |
TransactionalMapProxySupport.putIfAbsentInternal(Data key,
Data value) |
Data |
TransactionalMapProxySupport.putInternal(Data key,
Data value) |
Data |
TransactionalMapProxySupport.putInternal(Data key,
Data value,
long ttl,
TimeUnit timeUnit) |
boolean |
TransactionalMapProxySupport.removeIfSameInternal(Data key,
Object value) |
Data |
TransactionalMapProxySupport.removeInternal(Data key) |
boolean |
TransactionalMapProxySupport.replaceIfSameInternal(Data key,
Object oldValue,
Data newValue) |
Data |
TransactionalMapProxySupport.replaceInternal(Data key,
Data value) |
Constructor and Description |
---|
MapTransactionLog(String name,
Data key,
Operation op,
long version,
String ownerUuid) |
TxnDeleteOperation(String name,
Data dataKey,
long version) |
TxnLockAndGetOperation(String name,
Data dataKey,
long timeout,
long ttl,
String ownerUuid) |
TxnPrepareBackupOperation(String name,
Data dataKey,
String lockOwner,
long lockThreadId) |
TxnPrepareOperation(String name,
Data dataKey,
String ownerUuid) |
TxnRollbackBackupOperation(String name,
Data dataKey,
String lockOwner,
long lockThreadId) |
TxnRollbackOperation(String name,
Data dataKey,
String ownerUuid) |
TxnSetOperation(String name,
Data dataKey,
Data value,
long version) |
TxnSetOperation(String name,
Data dataKey,
Data value,
long version,
long ttl) |
TxnUnlockBackupOperation(String name,
Data dataKey) |
TxnUnlockOperation(String name,
Data dataKey,
long version) |
VersionedValue(Data value,
long version) |
Modifier and Type | Method and Description |
---|---|
Data |
MapReplicationRemove.getKey() |
Modifier and Type | Method and Description |
---|---|
void |
MapReplicationRemove.setKey(Data key) |
Constructor and Description |
---|
MapReplicationRemove(String mapName,
Data key,
long removeTime) |
Modifier and Type | Method and Description |
---|---|
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 |
---|---|
String |
MultiMapService.addListener(String name,
EventListener listener,
Data key,
boolean includeValue,
boolean local) |
boolean |
MultiMapContainer.canAcquireLock(Data dataKey,
String 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) |
void |
MultiMapContainer.delete(Data dataKey) |
boolean |
MultiMapContainer.extendLock(Data key,
String 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 |
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,
String caller,
long threadId,
long ttl) |
boolean |
MultiMapContainer.unlock(Data key,
String caller,
long threadId) |
Constructor and Description |
---|
MultiMapEventFilter(boolean includeValue,
Data key) |
Modifier and Type | Method and Description |
---|---|
Data |
TxnMultiMapRequest.toData(Object obj) |
Modifier and Type | Field and Description |
---|---|
protected Data |
MultiMapKeyBasedOperation.dataKey |
Modifier and Type | Method and Description |
---|---|
Data |
MultiMapOperation.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 |
MultiMapOperation.publishEvent(EntryEventType eventType,
Data key,
Object newValue,
Object oldValue) |
Constructor and Description |
---|
EntrySetResponse(Map<Data,Collection<MultiMapRecord>> map,
NodeEngine nodeEngine) |
Modifier and Type | Method and Description |
---|---|
protected Collection<MultiMapRecord> |
TransactionalMultiMapProxySupport.getInternal(Data key) |
protected boolean |
TransactionalMultiMapProxySupport.putInternal(Data key,
Data value) |
protected Collection<MultiMapRecord> |
TransactionalMultiMapProxySupport.removeAllInternal(Data key) |
protected boolean |
TransactionalMultiMapProxySupport.removeInternal(Data key,
Data value) |
protected int |
TransactionalMultiMapProxySupport.valueCountInternal(Data key) |
Constructor and Description |
---|
MultiMapTransactionLog(Data key,
String name,
long ttl,
long threadId) |
TxnCommitBackupOperation(String name,
Data dataKey,
List<Operation> opList,
String caller,
long threadId) |
TxnCommitOperation(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) |
TxnPrepareBackupOperation(String name,
Data dataKey,
String caller,
long threadId) |
TxnPrepareOperation(String name,
Data dataKey,
long ttl,
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,
String caller,
long threadId) |
TxnRollbackOperation(String name,
Data dataKey,
long threadId) |
Modifier and Type | Method and Description |
---|---|
Data |
Packet.getData() |
Data |
ObjectDataInput.readData() |
Data |
NodeIOService.toData(Object obj) |
Data |
IOService.toData(Object obj) |
Modifier and Type | Method and Description |
---|---|
static long |
IOUtil.extractOperationCallId(Data data,
SerializationService serializationService)
This method has a direct dependency on how objects are serialized in
DataSerializer ! If the stream
format is ever changed this extraction method needs to be changed too! |
void |
Packet.setData(Data data) |
Object |
NodeIOService.toObject(Data data) |
Object |
IOService.toObject(Data data) |
void |
ObjectDataOutput.writeData(Data data) |
Constructor and Description |
---|
Packet(Data data) |
Packet(Data data,
int partitionId) |
Modifier and Type | Class and Description |
---|---|
class |
DefaultData |
Modifier and Type | Method and Description |
---|---|
<B extends Data> |
SerializationService.readData(ObjectDataInput in) |
<B extends Data> |
SerializationService.toData(Object obj) |
<B extends Data> |
SerializationService.toData(Object obj,
PartitioningStrategy strategy) |
Modifier and Type | Method and Description |
---|---|
Data |
ObjectDataInputStream.readData() |
Data |
SerializationServiceImpl.readData(ObjectDataInput input) |
Data |
SerializationServiceImpl.toData(Object obj) |
Data |
SerializationServiceImpl.toData(Object obj,
PartitioningStrategy strategy) |
Modifier and Type | Method and Description |
---|---|
BufferObjectDataInput |
InputOutputFactory.createInput(Data data,
SerializationService service) |
BufferObjectDataInput |
SerializationServiceImpl.createObjectDataInput(Data data) |
BufferObjectDataInput |
SerializationService.createObjectDataInput(Data data) |
PortableReader |
SerializationServiceImpl.createPortableReader(Data data) |
PortableReader |
SerializationService.createPortableReader(Data data) |
void |
SerializationServiceImpl.disposeData(Data data) |
void |
SerializationService.disposeData(Data data) |
ClassDefinition |
PortableContext.lookupClassDefinition(Data data) |
void |
ObjectDataOutputStream.writeData(Data data) |
void |
SerializationServiceImpl.writeData(ObjectDataOutput out,
Data data) |
void |
SerializationService.writeData(ObjectDataOutput out,
Data data) |
protected void |
SerializationServiceImpl.writeDataInternal(ObjectDataOutput out,
Data data) |
Modifier and Type | Method and Description |
---|---|
int |
InternalPartitionService.getPartitionId(Data key)
Returns the partition id for a Data key.
|
Modifier and Type | Method and Description |
---|---|
int |
InternalPartitionServiceImpl.getPartitionId(Data key) |
Modifier and Type | Method and Description |
---|---|
Data |
QueryEntry.getIndexKey() |
Data |
QueryResultEntry.getIndexKey() |
Data |
QueryResultEntryImpl.getIndexKey() |
Data |
QueryEntry.getKeyData() |
Data |
QueryResultEntry.getKeyData() |
Data |
QueryResultEntryImpl.getKeyData() |
Data |
QueryEntry.getValueData() |
Data |
QueryResultEntry.getValueData() |
Data |
QueryResultEntryImpl.getValueData() |
Modifier and Type | Method and Description |
---|---|
ConcurrentMap<Data,QueryableEntry> |
UnsortedIndexStore.getRecordMap(Comparable value) |
ConcurrentMap<Data,QueryableEntry> |
IndexStore.getRecordMap(Comparable indexValue) |
ConcurrentMap<Data,QueryableEntry> |
SortedIndexStore.getRecordMap(Comparable value) |
ConcurrentMap<Data,Comparable> |
IndexImpl.getRecordValues() |
Modifier and Type | Method and Description |
---|---|
void |
QueryEntry.init(SerializationService serializationService,
Data indexKey,
Object key,
Object value)
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 |
IndexService.removeEntryIndex(Data indexKey) |
void |
Index.removeEntryIndex(Data indexKey) |
void |
IndexImpl.removeEntryIndex(Data indexKey) |
void |
UnsortedIndexStore.removeIndex(Comparable oldValue,
Data indexKey) |
void |
IndexStore.removeIndex(Comparable oldValue,
Data indexKey) |
void |
SortedIndexStore.removeIndex(Comparable oldValue,
Data indexKey) |
Modifier and Type | Method and Description |
---|---|
void |
MultiResultSet.addResultSet(ConcurrentMap<Data,QueryableEntry> resultSet) |
Constructor and Description |
---|
QueryEntry(SerializationService serializationService,
Data indexKey,
Object key,
Object value) |
QueryResultEntryImpl(Data keyData,
Data indexKey,
Data valueData) |
Constructor and Description |
---|
SingleResultSet(ConcurrentMap<Data,QueryableEntry> records) |
Modifier and Type | Method and Description |
---|---|
Data |
RingbufferContainer.read(long sequence) |
Modifier and Type | Method and Description |
---|---|
long |
RingbufferContainer.add(Data item) |
long |
RingbufferContainer.addAll(Data[] items) |
Modifier and Type | Method and Description |
---|---|
Data |
ReadOneOperation.getResponse() |
Constructor and Description |
---|
AddAllBackupOperation(String name,
Data[] items) |
AddAllOperation(String name,
Data[] items,
OverflowPolicy overflowPolicy) |
AddBackupOperation(String name,
Data item) |
AddOperation(String name,
Data item,
OverflowPolicy overflowPolicy) |
Modifier and Type | Method and Description |
---|---|
protected Data |
AbstractDistributedObject.getNameAsPartitionAwareData() |
Data |
NodeEngine.toData(Object object)
Serializes an object to a
Data . |
Modifier and Type | Method and Description |
---|---|
Data |
PortableItemEvent.getItem() |
Data |
PortableEntryEvent.getKey() |
Data |
PortableEntryEvent.getMergingValue() |
Data |
PortableEntryEvent.getOldValue() |
Data |
PortableEntryEvent.getValue() |
Data |
NodeEngineImpl.toData(Object object) |
Modifier and Type | Method and Description |
---|---|
Collection<Data> |
SerializableCollection.getCollection() |
Collection<Data> |
PortableCollection.getCollection() |
Iterator<Data> |
SerializableCollection.iterator() |
Constructor and Description |
---|
BinaryOperationFactory(Data operationData) |
PortableEntryEvent(Data key,
Data value,
Data oldValue,
Data mergingValue,
EntryEventType eventType,
String uuid) |
PortableItemEvent(Data item,
ItemEventType eventType,
String uuid) |
SerializableCollection(Data... dataArray) |
Constructor and Description |
---|
PortableCollection(Collection<Data> collection) |
SerializableCollection(Collection<Data> collection) |
Constructor and Description |
---|
Backup(Data backupOp,
Address originalCaller,
long[] replicaVersions,
boolean sync) |
Modifier and Type | Field and Description |
---|---|
Data |
TopicEvent.data |
Modifier and Type | Method and Description |
---|---|
Data |
DataAwareMessage.getMessageData() |
Modifier and Type | Method and Description |
---|---|
void |
TopicProxySupport.publishInternal(Data message) |
Constructor and Description |
---|
DataAwareMessage(String topicName,
Data messageData,
long publishTime,
Member publishingMember,
SerializationService serializationService) |
PublishOperation(String name,
Data message) |
TopicEvent(String name,
Data data,
Address publisherAddress) |
Modifier and Type | Method and Description |
---|---|
Data |
PortableMessage.getMessage() |
Constructor and Description |
---|
PortableMessage(Data message,
long publishTime,
String uuid) |
PublishRequest(String name,
Data message) |
Modifier and Type | Method and Description |
---|---|
Data |
ReliableTopicMessage.getPayload() |
Constructor and Description |
---|
ReliableTopicMessage(Data payload,
Address publisherAddress) |
Constructor and Description |
---|
ClearRemoteTransactionRequest(Data xidData) |
FinalizeXATransactionRequest(Data xidData,
boolean isCommit) |
Constructor and Description |
---|
ClearRemoteTransactionBackupOperation(Data xidData) |
ClearRemoteTransactionOperation(Data xidData) |
FinalizeRemoteTransactionBackupOperation(Data xidData) |
FinalizeRemoteTransactionOperation(Data xidData,
boolean isCommit) |
Modifier and Type | Method and Description |
---|---|
int |
SampleableConcurrentHashMap.fetch(int tableIndex,
int size,
List<Data> keys)
Fetches keys from given
tableIndex as size
and puts them into keys list. |
Modifier and Type | Method and Description |
---|---|
Map<String,Data> |
SessionState.getAttributes() |
Modifier and Type | Method and Description |
---|---|
void |
SessionState.setAttribute(String key,
Data value) |
Modifier and Type | Method and Description |
---|---|
void |
SessionState.set(Map<String,Data> attributes) |
Modifier and Type | Method and Description |
---|---|
Data |
GetAttributeEntryProcessor.process(Map.Entry<String,SessionState> entry) |
Modifier and Type | Method and Description |
---|---|
Map<String,Data> |
SessionUpdateEntryProcessor.getAttributes() |
Constructor and Description |
---|
SessionUpdateEntryProcessor(String key,
Data value) |
Copyright © 2015 Hazelcast, Inc.. All Rights Reserved.