Package | Description |
---|---|
com.hazelcast.map.impl.journal | |
com.hazelcast.map.impl.operation |
Package for map operations.
|
com.hazelcast.map.impl.query | |
com.hazelcast.map.impl.querycache.subscriber.operation |
This package contains Enterprise specific operations for
QueryCache . |
com.hazelcast.map.impl.tx |
Contains implementation classes for
TransactionalMap |
Modifier and Type | Class and Description |
---|---|
class |
MapEventJournalSubscribeOperation
Performs the initial subscription to the map event journal.
|
Modifier and Type | Class and Description |
---|---|
class |
AddIndexOperation |
class |
AwaitMapFlushOperation
IMap.flush() call waits the end of flush by using this operation. |
class |
BasePutOperation |
class |
BaseRemoveOperation |
class |
ClearBackupOperation |
class |
ClearNearCacheOperation
Deprecated.
|
class |
ClearOperation |
class |
ContainsKeyOperation |
class |
ContainsValueOperation |
class |
DeleteOperation |
class |
EntryBackupOperation |
class |
EntryOffloadableSetUnlockOperation
Set & Unlock processing for the EntryOperation
See the javadoc on
EntryOperation |
class |
EntryOperation
Contains implementation of the off-loadable contract for EntryProcessor execution on a single key.
|
class |
EvictAllBackupOperation
Operation which evicts all keys except locked ones.
|
class |
EvictAllOperation
Operation which evicts all keys except locked ones.
|
class |
EvictBackupOperation |
class |
EvictBatchBackupOperation
Used to transfer expired keys from owner replica to backup replicas.
|
class |
EvictOperation |
class |
GetAllOperation |
class |
GetEntryViewOperation |
class |
GetOperation |
class |
IsKeyLoadFinishedOperation |
class |
IsPartitionLoadedOperation |
class |
KeyLoadStatusOperation
Notifies RecordStores about completion of loading
|
class |
LoadAllOperation
Triggers map store load of all given keys.
|
class |
LoadMapOperation
Triggers map loading from a map store
|
class |
LockAwareOperation |
class |
MapFetchEntriesOperation
Operation for fetching a chunk of entries from a single
IMap partition. |
class |
MapFetchKeysOperation
Operation for fetching a chunk of keys from a single
IMap partition. |
class |
MapFetchWithQueryOperation
Fetches by query a batch of
fetchSize items from a single partition ID for a map. |
class |
MapFlushBackupOperation
Empties backup write-behind-queues upon
IMap.flush() |
class |
MapFlushOperation
Flushes dirty entries upon call of
IMap.flush() |
class |
MapIsEmptyOperation |
class |
MapSizeOperation |
class |
MergeOperation |
class |
MultipleEntryBackupOperation |
class |
MultipleEntryOperation |
class |
MultipleEntryWithPredicateBackupOperation |
class |
MultipleEntryWithPredicateOperation |
class |
MutatingKeyBasedMapOperation |
class |
NotifyMapFlushOperation
|
class |
PartitionWideEntryBackupOperation |
class |
PartitionWideEntryOperation
GOTCHA: This operation does NOT load missing keys from map-store for now.
|
class |
PartitionWideEntryWithPredicateBackupOperation |
class |
PartitionWideEntryWithPredicateOperation |
class |
PutAllBackupOperation |
class |
PutAllOperation
Inserts the
MapEntries for a single partition to the local RecordStore . |
class |
PutBackupOperation |
class |
PutFromLoadAllBackupOperation
Runs on backups.
|
class |
PutFromLoadAllOperation
Puts records to map which are loaded from map store by
IMap.loadAll(boolean) |
class |
PutIfAbsentOperation |
class |
PutOperation |
class |
PutTransientOperation |
class |
ReadonlyKeyBasedMapOperation
Abstract
MapOperation that serves as based for readonly operations. |
class |
RemoveBackupOperation |
class |
RemoveFromLoadAllOperation
Removes keys that are contained in the
RecordStore from the provided list,
leaving only keys which are not contained in the record store. |
class |
RemoveIfSameOperation |
class |
RemoveOperation |
class |
ReplaceIfSameOperation |
class |
ReplaceOperation |
class |
SetOperation |
class |
TriggerLoadIfNeededOperation
Triggers key loading on member with SENDER or SENDER_BACKUP key loader role, if keys have not finished loading yet.
|
class |
TryPutOperation |
class |
TryRemoveOperation |
Modifier and Type | Method and Description |
---|---|
MapOperation |
MapOperationProvider.createClearOperation(String name) |
MapOperation |
DefaultMapOperationProvider.createClearOperation(String name) |
MapOperation |
MapOperationProvider.createContainsKeyOperation(String name,
Data dataKey) |
MapOperation |
DefaultMapOperationProvider.createContainsKeyOperation(String name,
Data dataKey) |
MapOperation |
WANAwareOperationProvider.createDeleteOperation(String name,
Data key,
boolean disableWanReplicationEvent) |
MapOperation |
MapOperationProvider.createDeleteOperation(String name,
Data key,
boolean disableWanReplicationEvent)
Creates a delete operation for an entry with key equal to
key from the map named name . |
MapOperation |
DefaultMapOperationProvider.createDeleteOperation(String name,
Data key,
boolean disableWanReplicationEvent) |
MapOperation |
WANAwareOperationProvider.createEntryOperation(String name,
Data dataKey,
EntryProcessor entryProcessor) |
MapOperation |
MapOperationProvider.createEntryOperation(String name,
Data dataKey,
EntryProcessor entryProcessor) |
MapOperation |
DefaultMapOperationProvider.createEntryOperation(String name,
Data dataKey,
EntryProcessor entryProcessor) |
MapOperation |
MapOperationProvider.createEvictAllOperation(String name) |
MapOperation |
DefaultMapOperationProvider.createEvictAllOperation(String name) |
MapOperation |
MapOperationProvider.createEvictOperation(String name,
Data dataKey,
boolean asyncBackup) |
MapOperation |
DefaultMapOperationProvider.createEvictOperation(String name,
Data dataKey,
boolean asyncBackup) |
MapOperation |
MapOperationProvider.createFetchEntriesOperation(String name,
int lastTableIndex,
int fetchSize) |
MapOperation |
DefaultMapOperationProvider.createFetchEntriesOperation(String name,
int lastTableIndex,
int fetchSize) |
MapOperation |
MapOperationProvider.createFetchKeysOperation(String name,
int lastTableIndex,
int fetchSize) |
MapOperation |
DefaultMapOperationProvider.createFetchKeysOperation(String name,
int lastTableIndex,
int fetchSize) |
MapOperation |
MapOperationProvider.createFetchWithQueryOperation(String name,
int lastTableIndex,
int fetchSize,
Query query)
Creates an operation for fetching a segment of a query result from a single partition.
|
MapOperation |
DefaultMapOperationProvider.createFetchWithQueryOperation(String name,
int lastTableIndex,
int fetchSize,
Query query) |
MapOperation |
MapOperationProvider.createGetEntryViewOperation(String name,
Data dataKey) |
MapOperation |
DefaultMapOperationProvider.createGetEntryViewOperation(String name,
Data dataKey) |
MapOperation |
MapOperationProvider.createGetOperation(String name,
Data dataKey) |
MapOperation |
DefaultMapOperationProvider.createGetOperation(String name,
Data dataKey) |
MapOperation |
MapOperationProvider.createLoadAllOperation(String name,
List<Data> keys,
boolean replaceExistingValues) |
MapOperation |
DefaultMapOperationProvider.createLoadAllOperation(String name,
List<Data> keys,
boolean replaceExistingValues) |
MapOperation |
MapOperationProvider.createLoadMapOperation(String name,
boolean replaceExistingValues) |
MapOperation |
DefaultMapOperationProvider.createLoadMapOperation(String name,
boolean replaceExistingValues) |
MapOperation |
MapOperationProvider.createMapFlushOperation(String name) |
MapOperation |
DefaultMapOperationProvider.createMapFlushOperation(String name) |
MapOperation |
MapOperationProvider.createMergeOperation(String name,
Data dataKey,
EntryView<Data,Data> entryView,
MapMergePolicy policy,
boolean disableWanReplicationEvent) |
MapOperation |
DefaultMapOperationProvider.createMergeOperation(String name,
Data dataKey,
EntryView<Data,Data> entryView,
MapMergePolicy policy,
boolean disableWanReplicationEvent) |
MapOperation |
WANAwareOperationProvider.createPutAllOperation(String name,
MapEntries mapEntries) |
MapOperation |
MapOperationProvider.createPutAllOperation(String name,
MapEntries mapEntries) |
MapOperation |
DefaultMapOperationProvider.createPutAllOperation(String name,
MapEntries mapEntries) |
MapOperation |
WANAwareOperationProvider.createPutFromLoadAllOperation(String name,
List<Data> keyValueSequence) |
MapOperation |
MapOperationProvider.createPutFromLoadAllOperation(String name,
List<Data> keyValueSequence) |
MapOperation |
DefaultMapOperationProvider.createPutFromLoadAllOperation(String name,
List<Data> keyValueSequence) |
MapOperation |
WANAwareOperationProvider.createPutIfAbsentOperation(String name,
Data key,
Data value,
long ttl) |
MapOperation |
MapOperationProvider.createPutIfAbsentOperation(String name,
Data key,
Data value,
long ttl) |
MapOperation |
DefaultMapOperationProvider.createPutIfAbsentOperation(String name,
Data key,
Data value,
long ttl) |
MapOperation |
WANAwareOperationProvider.createPutOperation(String name,
Data key,
Data value,
long ttl) |
MapOperation |
MapOperationProvider.createPutOperation(String name,
Data key,
Data value,
long ttl) |
MapOperation |
DefaultMapOperationProvider.createPutOperation(String name,
Data key,
Data value,
long ttl) |
MapOperation |
WANAwareOperationProvider.createPutTransientOperation(String name,
Data key,
Data value,
long ttl) |
MapOperation |
MapOperationProvider.createPutTransientOperation(String name,
Data key,
Data value,
long ttl) |
MapOperation |
DefaultMapOperationProvider.createPutTransientOperation(String name,
Data key,
Data value,
long ttl) |
MapOperation |
WANAwareOperationProvider.createQueryOperation(Query query) |
MapOperation |
MapOperationProvider.createQueryOperation(Query query) |
MapOperation |
DefaultMapOperationProvider.createQueryOperation(Query query) |
MapOperation |
WANAwareOperationProvider.createQueryPartitionOperation(Query query) |
MapOperation |
MapOperationProvider.createQueryPartitionOperation(Query query) |
MapOperation |
DefaultMapOperationProvider.createQueryPartitionOperation(Query query) |
MapOperation |
WANAwareOperationProvider.createRemoveIfSameOperation(String name,
Data dataKey,
Data value) |
MapOperation |
MapOperationProvider.createRemoveIfSameOperation(String name,
Data dataKey,
Data value) |
MapOperation |
DefaultMapOperationProvider.createRemoveIfSameOperation(String name,
Data dataKey,
Data value) |
MapOperation |
WANAwareOperationProvider.createRemoveOperation(String name,
Data key,
boolean disableWanReplicationEvent) |
MapOperation |
MapOperationProvider.createRemoveOperation(String name,
Data key,
boolean disableWanReplicationEvent) |
MapOperation |
DefaultMapOperationProvider.createRemoveOperation(String name,
Data key,
boolean disableWanReplicationEvent) |
MapOperation |
WANAwareOperationProvider.createReplaceIfSameOperation(String name,
Data dataKey,
Data expect,
Data update) |
MapOperation |
MapOperationProvider.createReplaceIfSameOperation(String name,
Data dataKey,
Data expect,
Data update) |
MapOperation |
DefaultMapOperationProvider.createReplaceIfSameOperation(String name,
Data dataKey,
Data expect,
Data update) |
MapOperation |
WANAwareOperationProvider.createReplaceOperation(String name,
Data dataKey,
Data value) |
MapOperation |
MapOperationProvider.createReplaceOperation(String name,
Data dataKey,
Data value) |
MapOperation |
DefaultMapOperationProvider.createReplaceOperation(String name,
Data dataKey,
Data value) |
MapOperation |
WANAwareOperationProvider.createSetOperation(String name,
Data dataKey,
Data value,
long ttl) |
MapOperation |
MapOperationProvider.createSetOperation(String name,
Data dataKey,
Data value,
long ttl) |
MapOperation |
DefaultMapOperationProvider.createSetOperation(String name,
Data dataKey,
Data value,
long ttl) |
MapOperation |
WANAwareOperationProvider.createTryPutOperation(String name,
Data dataKey,
Data value,
long timeout) |
MapOperation |
MapOperationProvider.createTryPutOperation(String name,
Data dataKey,
Data value,
long timeout) |
MapOperation |
DefaultMapOperationProvider.createTryPutOperation(String name,
Data dataKey,
Data value,
long timeout) |
MapOperation |
WANAwareOperationProvider.createTryRemoveOperation(String name,
Data dataKey,
long timeout) |
MapOperation |
MapOperationProvider.createTryRemoveOperation(String name,
Data dataKey,
long timeout) |
MapOperation |
DefaultMapOperationProvider.createTryRemoveOperation(String name,
Data dataKey,
long timeout) |
MapOperation |
WANAwareOperationProvider.createTxnDeleteOperation(String name,
Data dataKey,
long version) |
MapOperation |
MapOperationProvider.createTxnDeleteOperation(String name,
Data dataKey,
long version) |
MapOperation |
DefaultMapOperationProvider.createTxnDeleteOperation(String name,
Data dataKey,
long version) |
MapOperation |
MapOperationProvider.createTxnLockAndGetOperation(String name,
Data dataKey,
long timeout,
long ttl,
String ownerUuid,
boolean shouldLoad,
boolean blockReads) |
MapOperation |
DefaultMapOperationProvider.createTxnLockAndGetOperation(String name,
Data dataKey,
long timeout,
long ttl,
String ownerUuid,
boolean shouldLoad,
boolean blockReads) |
MapOperation |
WANAwareOperationProvider.createTxnSetOperation(String name,
Data dataKey,
Data value,
long version,
long ttl) |
MapOperation |
MapOperationProvider.createTxnSetOperation(String name,
Data dataKey,
Data value,
long version,
long ttl) |
MapOperation |
DefaultMapOperationProvider.createTxnSetOperation(String name,
Data dataKey,
Data value,
long version,
long ttl) |
Modifier and Type | Method and Description |
---|---|
static EntryOperator |
EntryOperator.operator(MapOperation mapOperation) |
static EntryOperator |
EntryOperator.operator(MapOperation mapOperation,
Object processor) |
static EntryOperator |
EntryOperator.operator(MapOperation mapOperation,
Object processor,
Predicate predicate) |
static EntryOperator |
EntryOperator.operator(MapOperation mapOperation,
Object processor,
Predicate predicate,
boolean collectWanEvents) |
Modifier and Type | Class and Description |
---|---|
class |
QueryOperation
Native handling only for RU compatibility purposes, can be deleted in 3.10 master
An old member may send a QueryOperation (and not HDQueryOperation) to an HD member.
|
class |
QueryPartitionOperation |
Modifier and Type | Class and Description |
---|---|
class |
DestroyQueryCacheOperation
This operation removes all
QueryCache resources on a node. |
class |
MadePublishableOperation
Sets
AccumulatorInfo.publishable to true . |
class |
PublisherCreateOperation
An idempotent create operation which creates publisher side functionality.
|
class |
ReadAndResetAccumulatorOperation
Reads all available items from the accumulator of the partition and resets it.
|
class |
SetReadCursorOperation
Sets read cursor of
Accumulator in this partition to the supplied sequence number. |
Modifier and Type | Class and Description |
---|---|
class |
TxnDeleteOperation
Transactional delete operation
|
class |
TxnLockAndGetOperation
Transactional lock and get operation.
|
class |
TxnPrepareBackupOperation
An operation to prepare transaction by locking the key on key backup owner.
|
class |
TxnPrepareOperation
An operation to prepare transaction by locking the key on the key owner.
|
class |
TxnRollbackBackupOperation
An operation to rollback transaction by unlocking the key on key backup owner.
|
class |
TxnRollbackOperation
An operation to rollback transaction by unlocking the key on key owner.
|
class |
TxnSetOperation
An operation to unlock and set (key,value) on the partition .
|
class |
TxnUnlockBackupOperation
An operation to unlock key on the backup owner.
|
class |
TxnUnlockOperation
An operation to unlock key on the partition owner.
|
Copyright © 2018 Hazelcast, Inc.. All Rights Reserved.