com.hazelcast.map.impl.operation

Interface MapOperationProvider

All Known Implementing Classes:

DefaultMapOperationProvider, WANAwareOperationProvider

public interface MapOperationProvider

Provides InMemoryFormat specific operations for IMap.

Method Summary

Modifier and Type	Method and Description
MapOperation	createClearOperation(String name)
OperationFactory	createClearOperationFactory(String name)
MapOperation	createContainsKeyOperation(String name, Data dataKey)
OperationFactory	createContainsValueOperationFactory(String name, Data testValue)
MapOperation	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	createEntryOperation(String name, Data dataKey, EntryProcessor entryProcessor)
MapOperation	createEvictAllOperation(String name)
OperationFactory	createEvictAllOperationFactory(String name)
MapOperation	createEvictOperation(String name, Data dataKey, boolean asyncBackup)
MapOperation	createFetchEntriesOperation(String name, int lastTableIndex, int fetchSize)
MapOperation	createFetchKeysOperation(String name, int lastTableIndex, int fetchSize)
MapOperation	createFetchWithQueryOperation(String name, int lastTableIndex, int fetchSize, Query query) Creates an operation for fetching a segment of a query result from a single partition.
OperationFactory	createGetAllOperationFactory(String name, List<Data> keys)
MapOperation	createGetEntryViewOperation(String name, Data dataKey)
MapOperation	createGetOperation(String name, Data dataKey)
MapOperation	createLegacyMergeOperation(String name, EntryView<Data,Data> entryView, MapMergePolicy policy, boolean disableWanReplicationEvent)
MapOperation	createLoadAllOperation(String name, List<Data> keys, boolean replaceExistingValues) Creates an operation to load entry values for the provided keys on the partition owner.
OperationFactory	createLoadAllOperationFactory(String name, List<Data> keys, boolean replaceExistingValues)
MapOperation	createLoadMapOperation(String name, boolean replaceExistingValues)
MapOperation	createMapFlushOperation(String name)
OperationFactory	createMapFlushOperationFactory(String name)
OperationFactory	createMapSizeOperationFactory(String name)
MapOperation	createMergeOperation(String name, SplitBrainMergeTypes.MapMergeTypes mergingValue, SplitBrainMergePolicy<Data,SplitBrainMergeTypes.MapMergeTypes> mergePolicy, boolean disableWanReplicationEvent)
OperationFactory	createMergeOperationFactory(String name, int[] partitions, List<SplitBrainMergeTypes.MapMergeTypes>[] mergingEntries, SplitBrainMergePolicy<Data,SplitBrainMergeTypes.MapMergeTypes> mergePolicy)
OperationFactory	createMultipleEntryOperationFactory(String name, Set<Data> keys, EntryProcessor entryProcessor)
OperationFactory	createPartitionWideEntryOperationFactory(String name, EntryProcessor entryProcessor)
OperationFactory	createPartitionWideEntryWithPredicateOperationFactory(String name, EntryProcessor entryProcessor, Predicate predicate)
MapOperation	createPutAllOperation(String name, MapEntries mapEntries)
OperationFactory	createPutAllOperationFactory(String name, int[] partitions, MapEntries[] mapEntries)
MapOperation	createPutFromLoadAllOperation(String name, List<Data> keyValueSequence)
MapOperation	createPutIfAbsentOperation(String name, Data key, Data value, long ttl, long maxIdle)
MapOperation	createPutOperation(String name, Data key, Data value, long ttl, long maxIdle)
MapOperation	createPutTransientOperation(String name, Data key, Data value, long ttl, long maxIdle)
MapOperation	createQueryOperation(Query query)
MapOperation	createQueryPartitionOperation(Query query)
MapOperation	createRemoveIfSameOperation(String name, Data dataKey, Data value)
MapOperation	createRemoveOperation(String name, Data key, boolean disableWanReplicationEvent)
MapOperation	createReplaceIfSameOperation(String name, Data dataKey, Data expect, Data update)
MapOperation	createReplaceOperation(String name, Data dataKey, Data value)
MapOperation	createSetOperation(String name, Data dataKey, Data value, long ttl, long maxIdle)
MapOperation	createSetTtlOperation(String name, Data key, long ttl)
MapOperation	createTryPutOperation(String name, Data dataKey, Data value, long timeout)
MapOperation	createTryRemoveOperation(String name, Data dataKey, long timeout)
MapOperation	createTxnDeleteOperation(String name, Data dataKey, long version)
MapOperation	createTxnLockAndGetOperation(String name, Data dataKey, long timeout, long ttl, String ownerUuid, boolean shouldLoad, boolean blockReads)
MapOperation	createTxnSetOperation(String name, Data dataKey, Data value, long version, long ttl)

Method Detail

createPutOperation

MapOperation createPutOperation(String name,
                                Data key,
                                Data value,
                                long ttl,
                                long maxIdle)

createTryPutOperation

MapOperation createTryPutOperation(String name,
                                   Data dataKey,
                                   Data value,
                                   long timeout)

createSetOperation

MapOperation createSetOperation(String name,
                                Data dataKey,
                                Data value,
                                long ttl,
                                long maxIdle)

createPutIfAbsentOperation

MapOperation createPutIfAbsentOperation(String name,
                                        Data key,
                                        Data value,
                                        long ttl,
                                        long maxIdle)

createPutTransientOperation

MapOperation createPutTransientOperation(String name,
                                         Data key,
                                         Data value,
                                         long ttl,
                                         long maxIdle)

createSetTtlOperation

MapOperation createSetTtlOperation(String name,
                                   Data key,
                                   long ttl)

createTryRemoveOperation

MapOperation createTryRemoveOperation(String name,
                                      Data dataKey,
                                      long timeout)

createReplaceOperation

MapOperation createReplaceOperation(String name,
                                    Data dataKey,
                                    Data value)

createRemoveIfSameOperation

MapOperation createRemoveIfSameOperation(String name,
                                         Data dataKey,
                                         Data value)

createReplaceIfSameOperation

MapOperation createReplaceIfSameOperation(String name,
                                          Data dataKey,
                                          Data expect,
                                          Data update)

createRemoveOperation

MapOperation createRemoveOperation(String name,
                                   Data key,
                                   boolean disableWanReplicationEvent)

createDeleteOperation

MapOperation createDeleteOperation(String name,
                                   Data key,
                                   boolean disableWanReplicationEvent)

Creates a delete operation for an entry with key equal to key from the map named name. You can also specify whether this operation should trigger a WAN replication event.

Parameters:

name - the map name

key - the entry key

disableWanReplicationEvent - if the delete operation should not send a WAN replication event

Returns:

the delete operation

createClearOperation

MapOperation createClearOperation(String name)

createEntryOperation

MapOperation createEntryOperation(String name,
                                  Data dataKey,
                                  EntryProcessor entryProcessor)

createEvictOperation

MapOperation createEvictOperation(String name,
                                  Data dataKey,
                                  boolean asyncBackup)

createEvictAllOperation

MapOperation createEvictAllOperation(String name)

createContainsKeyOperation

MapOperation createContainsKeyOperation(String name,
                                        Data dataKey)

createGetEntryViewOperation

MapOperation createGetEntryViewOperation(String name,
                                         Data dataKey)

createGetOperation

MapOperation createGetOperation(String name,
                                Data dataKey)

createQueryOperation

MapOperation createQueryOperation(Query query)

createQueryPartitionOperation

MapOperation createQueryPartitionOperation(Query query)

createLoadAllOperation

MapOperation createLoadAllOperation(String name,
                                    List<Data> keys,
                                    boolean replaceExistingValues)

Creates an operation to load entry values for the provided keys on the partition owner.

Parameters:

name - the map name

keys - the keys for which values are to be loaded

replaceExistingValues - if the existing entries for the loaded keys should be replaced

Returns:

the operation for triggering entry value loading

createPutAllOperation

MapOperation createPutAllOperation(String name,
                                   MapEntries mapEntries)

createPutFromLoadAllOperation

MapOperation createPutFromLoadAllOperation(String name,
                                           List<Data> keyValueSequence)

createTxnDeleteOperation

MapOperation createTxnDeleteOperation(String name,
                                      Data dataKey,
                                      long version)

createTxnLockAndGetOperation

MapOperation createTxnLockAndGetOperation(String name,
                                          Data dataKey,
                                          long timeout,
                                          long ttl,
                                          String ownerUuid,
                                          boolean shouldLoad,
                                          boolean blockReads)

createTxnSetOperation

MapOperation createTxnSetOperation(String name,
                                   Data dataKey,
                                   Data value,
                                   long version,
                                   long ttl)

createLegacyMergeOperation

MapOperation createLegacyMergeOperation(String name,
                                        EntryView<Data,Data> entryView,
                                        MapMergePolicy policy,
                                        boolean disableWanReplicationEvent)

createMergeOperation

MapOperation createMergeOperation(String name,
                                  SplitBrainMergeTypes.MapMergeTypes mergingValue,
                                  SplitBrainMergePolicy<Data,SplitBrainMergeTypes.MapMergeTypes> mergePolicy,
                                  boolean disableWanReplicationEvent)

createMapFlushOperation

MapOperation createMapFlushOperation(String name)

createLoadMapOperation

MapOperation createLoadMapOperation(String name,
                                    boolean replaceExistingValues)

createFetchKeysOperation

MapOperation createFetchKeysOperation(String name,
                                      int lastTableIndex,
                                      int fetchSize)

createFetchEntriesOperation

MapOperation createFetchEntriesOperation(String name,
                                         int lastTableIndex,
                                         int fetchSize)

createFetchWithQueryOperation

MapOperation createFetchWithQueryOperation(String name,
                                           int lastTableIndex,
                                           int fetchSize,
                                           Query query)

Creates an operation for fetching a segment of a query result from a single partition.

Since:

3.9

See Also:

MapProxyImpl.iterator(int, int, com.hazelcast.projection.Projection, Predicate)

createPartitionWideEntryOperationFactory

OperationFactory createPartitionWideEntryOperationFactory(String name,
                                                          EntryProcessor entryProcessor)

createPartitionWideEntryWithPredicateOperationFactory

OperationFactory createPartitionWideEntryWithPredicateOperationFactory(String name,
                                                                       EntryProcessor entryProcessor,
                                                                       Predicate predicate)

createMultipleEntryOperationFactory

OperationFactory createMultipleEntryOperationFactory(String name,
                                                     Set<Data> keys,
                                                     EntryProcessor entryProcessor)

createContainsValueOperationFactory

OperationFactory createContainsValueOperationFactory(String name,
                                                     Data testValue)

createEvictAllOperationFactory

OperationFactory createEvictAllOperationFactory(String name)

createClearOperationFactory

OperationFactory createClearOperationFactory(String name)

createMapFlushOperationFactory

OperationFactory createMapFlushOperationFactory(String name)

createLoadAllOperationFactory

OperationFactory createLoadAllOperationFactory(String name,
                                               List<Data> keys,
                                               boolean replaceExistingValues)

createGetAllOperationFactory

OperationFactory createGetAllOperationFactory(String name,
                                              List<Data> keys)

createMapSizeOperationFactory

OperationFactory createMapSizeOperationFactory(String name)

createPutAllOperationFactory

OperationFactory createPutAllOperationFactory(String name,
                                              int[] partitions,
                                              MapEntries[] mapEntries)

createMergeOperationFactory

OperationFactory createMergeOperationFactory(String name,
                                             int[] partitions,
                                             List<SplitBrainMergeTypes.MapMergeTypes>[] mergingEntries,
                                             SplitBrainMergePolicy<Data,SplitBrainMergeTypes.MapMergeTypes> mergePolicy)