com.hazelcast.map.impl.operation

Class HDMapOperationProvider

java.lang.Object

com.hazelcast.map.impl.operation.HDMapOperationProvider

All Implemented Interfaces:

com.hazelcast.map.impl.operation.MapOperationProvider

public class HDMapOperationProvider
extends Object
implements com.hazelcast.map.impl.operation.MapOperationProvider

Provides IMap operations when InMemoryFormat is NATIVE.

Constructor Summary

Constructors

Constructor and Description
HDMapOperationProvider()

Method Summary

Modifier and Type	Method and Description
com.hazelcast.map.impl.operation.MapOperation	createClearOperation(String name)
com.hazelcast.spi.OperationFactory	createClearOperationFactory(String name)
com.hazelcast.map.impl.operation.MapOperation	createContainsKeyOperation(String name, com.hazelcast.nio.serialization.Data dataKey)
com.hazelcast.spi.OperationFactory	createContainsValueOperationFactory(String name, com.hazelcast.nio.serialization.Data testValue)
com.hazelcast.map.impl.operation.MapOperation	createDeleteOperation(String name, com.hazelcast.nio.serialization.Data key, boolean disableWanReplicationEvent)
com.hazelcast.map.impl.operation.MapOperation	createEntryOperation(String name, com.hazelcast.nio.serialization.Data dataKey, com.hazelcast.map.EntryProcessor entryProcessor)
com.hazelcast.map.impl.operation.MapOperation	createEvictAllOperation(String name)
com.hazelcast.spi.OperationFactory	createEvictAllOperationFactory(String name)
com.hazelcast.map.impl.operation.MapOperation	createEvictOperation(String name, com.hazelcast.nio.serialization.Data dataKey, boolean asyncBackup)
com.hazelcast.map.impl.operation.MapOperation	createFetchEntriesOperation(String name, int lastTableIndex, int fetchSize)
com.hazelcast.map.impl.operation.MapOperation	createFetchKeysOperation(String name, int lastTableIndex, int fetchSize)
com.hazelcast.map.impl.operation.MapOperation	createFetchWithQueryOperation(String name, int lastTableIndex, int fetchSize, com.hazelcast.map.impl.query.Query query)
com.hazelcast.spi.OperationFactory	createGetAllOperationFactory(String name, List<com.hazelcast.nio.serialization.Data> keys)
com.hazelcast.map.impl.operation.MapOperation	createGetEntryViewOperation(String name, com.hazelcast.nio.serialization.Data dataKey)
com.hazelcast.map.impl.operation.MapOperation	createGetOperation(String name, com.hazelcast.nio.serialization.Data dataKey)
com.hazelcast.map.impl.operation.MapOperation	createLegacyMergeOperation(String name, com.hazelcast.core.EntryView<com.hazelcast.nio.serialization.Data,com.hazelcast.nio.serialization.Data> entryView, com.hazelcast.map.merge.MapMergePolicy policy, boolean disableWanReplicationEvent)
com.hazelcast.map.impl.operation.MapOperation	createLoadAllOperation(String name, List<com.hazelcast.nio.serialization.Data> keys, boolean replaceExistingValues)
com.hazelcast.spi.OperationFactory	createLoadAllOperationFactory(String name, List<com.hazelcast.nio.serialization.Data> keys, boolean replaceExistingValues)
com.hazelcast.map.impl.operation.MapOperation	createLoadMapOperation(String name, boolean replaceExistingValues)
com.hazelcast.map.impl.operation.MapOperation	createMapFlushOperation(String name)
com.hazelcast.spi.OperationFactory	createMapFlushOperationFactory(String name)
com.hazelcast.spi.OperationFactory	createMapSizeOperationFactory(String name)
com.hazelcast.map.impl.operation.MapOperation	createMergeOperation(String name, com.hazelcast.spi.merge.SplitBrainMergeTypes.MapMergeTypes mergingEntry, com.hazelcast.spi.merge.SplitBrainMergePolicy<com.hazelcast.nio.serialization.Data,com.hazelcast.spi.merge.SplitBrainMergeTypes.MapMergeTypes> policy, boolean disableWanReplicationEvent)
com.hazelcast.spi.OperationFactory	createMergeOperationFactory(String name, int[] partitions, List<com.hazelcast.spi.merge.SplitBrainMergeTypes.MapMergeTypes>[] mergingEntries, com.hazelcast.spi.merge.SplitBrainMergePolicy<com.hazelcast.nio.serialization.Data,com.hazelcast.spi.merge.SplitBrainMergeTypes.MapMergeTypes> policy)
com.hazelcast.spi.OperationFactory	createMultipleEntryOperationFactory(String name, Set<com.hazelcast.nio.serialization.Data> keys, com.hazelcast.map.EntryProcessor entryProcessor)
com.hazelcast.spi.OperationFactory	createPartitionWideEntryOperationFactory(String name, com.hazelcast.map.EntryProcessor entryProcessor)
com.hazelcast.spi.OperationFactory	createPartitionWideEntryWithPredicateOperationFactory(String name, com.hazelcast.map.EntryProcessor entryProcessor, com.hazelcast.query.Predicate predicate)
com.hazelcast.map.impl.operation.MapOperation	createPutAllOperation(String name, com.hazelcast.map.impl.MapEntries mapEntries)
com.hazelcast.spi.OperationFactory	createPutAllOperationFactory(String name, int[] partitions, com.hazelcast.map.impl.MapEntries[] mapEntries)
com.hazelcast.map.impl.operation.MapOperation	createPutFromLoadAllOperation(String name, List<com.hazelcast.nio.serialization.Data> keyValueSequence)
com.hazelcast.map.impl.operation.MapOperation	createPutIfAbsentOperation(String name, com.hazelcast.nio.serialization.Data key, com.hazelcast.nio.serialization.Data value, long ttl, long maxIdle)
com.hazelcast.map.impl.operation.MapOperation	createPutOperation(String name, com.hazelcast.nio.serialization.Data key, com.hazelcast.nio.serialization.Data value, long ttl, long maxIdle)
com.hazelcast.map.impl.operation.MapOperation	createPutTransientOperation(String name, com.hazelcast.nio.serialization.Data key, com.hazelcast.nio.serialization.Data value, long ttl, long maxIdle)
com.hazelcast.map.impl.operation.MapOperation	createQueryOperation(com.hazelcast.map.impl.query.Query query)
com.hazelcast.map.impl.operation.MapOperation	createQueryPartitionOperation(com.hazelcast.map.impl.query.Query query)
com.hazelcast.map.impl.operation.MapOperation	createRemoveIfSameOperation(String name, com.hazelcast.nio.serialization.Data dataKey, com.hazelcast.nio.serialization.Data value)
com.hazelcast.map.impl.operation.MapOperation	createRemoveOperation(String name, com.hazelcast.nio.serialization.Data key, boolean disableWanReplicationEvent)
com.hazelcast.map.impl.operation.MapOperation	createReplaceIfSameOperation(String name, com.hazelcast.nio.serialization.Data dataKey, com.hazelcast.nio.serialization.Data expect, com.hazelcast.nio.serialization.Data update)
com.hazelcast.map.impl.operation.MapOperation	createReplaceOperation(String name, com.hazelcast.nio.serialization.Data dataKey, com.hazelcast.nio.serialization.Data value)
com.hazelcast.map.impl.operation.MapOperation	createSetOperation(String name, com.hazelcast.nio.serialization.Data dataKey, com.hazelcast.nio.serialization.Data value, long ttl, long maxIdle)
com.hazelcast.map.impl.operation.MapOperation	createSetTtlOperation(String name, com.hazelcast.nio.serialization.Data dataKey, long ttl)
com.hazelcast.map.impl.operation.MapOperation	createTryPutOperation(String name, com.hazelcast.nio.serialization.Data dataKey, com.hazelcast.nio.serialization.Data value, long timeout)
com.hazelcast.map.impl.operation.MapOperation	createTryRemoveOperation(String name, com.hazelcast.nio.serialization.Data dataKey, long timeout)
com.hazelcast.map.impl.operation.MapOperation	createTxnDeleteOperation(String name, com.hazelcast.nio.serialization.Data dataKey, long version)
com.hazelcast.map.impl.operation.MapOperation	createTxnLockAndGetOperation(String name, com.hazelcast.nio.serialization.Data dataKey, long timeout, long ttl, String ownerUuid, boolean shouldLoad, boolean blockReads)
com.hazelcast.map.impl.operation.MapOperation	createTxnSetOperation(String name, com.hazelcast.nio.serialization.Data dataKey, com.hazelcast.nio.serialization.Data value, long version, long ttl)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

HDMapOperationProvider

public HDMapOperationProvider()

Method Detail

createMapSizeOperationFactory

public com.hazelcast.spi.OperationFactory createMapSizeOperationFactory(String name)

Specified by:

createMapSizeOperationFactory in interface com.hazelcast.map.impl.operation.MapOperationProvider

createPutOperation

public com.hazelcast.map.impl.operation.MapOperation createPutOperation(String name,
                                                                        com.hazelcast.nio.serialization.Data key,
                                                                        com.hazelcast.nio.serialization.Data value,
                                                                        long ttl,
                                                                        long maxIdle)

Specified by:

createPutOperation in interface com.hazelcast.map.impl.operation.MapOperationProvider

createTryPutOperation

public com.hazelcast.map.impl.operation.MapOperation createTryPutOperation(String name,
                                                                           com.hazelcast.nio.serialization.Data dataKey,
                                                                           com.hazelcast.nio.serialization.Data value,
                                                                           long timeout)

Specified by:

createTryPutOperation in interface com.hazelcast.map.impl.operation.MapOperationProvider

createSetOperation

public com.hazelcast.map.impl.operation.MapOperation createSetOperation(String name,
                                                                        com.hazelcast.nio.serialization.Data dataKey,
                                                                        com.hazelcast.nio.serialization.Data value,
                                                                        long ttl,
                                                                        long maxIdle)

Specified by:

createSetOperation in interface com.hazelcast.map.impl.operation.MapOperationProvider

createPutIfAbsentOperation

public com.hazelcast.map.impl.operation.MapOperation createPutIfAbsentOperation(String name,
                                                                                com.hazelcast.nio.serialization.Data key,
                                                                                com.hazelcast.nio.serialization.Data value,
                                                                                long ttl,
                                                                                long maxIdle)

Specified by:

createPutIfAbsentOperation in interface com.hazelcast.map.impl.operation.MapOperationProvider

createPutTransientOperation

public com.hazelcast.map.impl.operation.MapOperation createPutTransientOperation(String name,
                                                                                 com.hazelcast.nio.serialization.Data key,
                                                                                 com.hazelcast.nio.serialization.Data value,
                                                                                 long ttl,
                                                                                 long maxIdle)

Specified by:

createPutTransientOperation in interface com.hazelcast.map.impl.operation.MapOperationProvider

createRemoveOperation

public com.hazelcast.map.impl.operation.MapOperation createRemoveOperation(String name,
                                                                           com.hazelcast.nio.serialization.Data key,
                                                                           boolean disableWanReplicationEvent)

Specified by:

createRemoveOperation in interface com.hazelcast.map.impl.operation.MapOperationProvider

createTryRemoveOperation

public com.hazelcast.map.impl.operation.MapOperation createTryRemoveOperation(String name,
                                                                              com.hazelcast.nio.serialization.Data dataKey,
                                                                              long timeout)

Specified by:

createTryRemoveOperation in interface com.hazelcast.map.impl.operation.MapOperationProvider

createReplaceOperation

public com.hazelcast.map.impl.operation.MapOperation createReplaceOperation(String name,
                                                                            com.hazelcast.nio.serialization.Data dataKey,
                                                                            com.hazelcast.nio.serialization.Data value)

Specified by:

createReplaceOperation in interface com.hazelcast.map.impl.operation.MapOperationProvider

createRemoveIfSameOperation

public com.hazelcast.map.impl.operation.MapOperation createRemoveIfSameOperation(String name,
                                                                                 com.hazelcast.nio.serialization.Data dataKey,
                                                                                 com.hazelcast.nio.serialization.Data value)

Specified by:

createRemoveIfSameOperation in interface com.hazelcast.map.impl.operation.MapOperationProvider

createReplaceIfSameOperation

public com.hazelcast.map.impl.operation.MapOperation createReplaceIfSameOperation(String name,
                                                                                  com.hazelcast.nio.serialization.Data dataKey,
                                                                                  com.hazelcast.nio.serialization.Data expect,
                                                                                  com.hazelcast.nio.serialization.Data update)

Specified by:

createReplaceIfSameOperation in interface com.hazelcast.map.impl.operation.MapOperationProvider

createDeleteOperation

public com.hazelcast.map.impl.operation.MapOperation createDeleteOperation(String name,
                                                                           com.hazelcast.nio.serialization.Data key,
                                                                           boolean disableWanReplicationEvent)

Specified by:

createDeleteOperation in interface com.hazelcast.map.impl.operation.MapOperationProvider

createClearOperation

public com.hazelcast.map.impl.operation.MapOperation createClearOperation(String name)

Specified by:

createClearOperation in interface com.hazelcast.map.impl.operation.MapOperationProvider

createEntryOperation

public com.hazelcast.map.impl.operation.MapOperation createEntryOperation(String name,
                                                                          com.hazelcast.nio.serialization.Data dataKey,
                                                                          com.hazelcast.map.EntryProcessor entryProcessor)

Specified by:

createEntryOperation in interface com.hazelcast.map.impl.operation.MapOperationProvider

createEvictOperation

public com.hazelcast.map.impl.operation.MapOperation createEvictOperation(String name,
                                                                          com.hazelcast.nio.serialization.Data dataKey,
                                                                          boolean asyncBackup)

Specified by:

createEvictOperation in interface com.hazelcast.map.impl.operation.MapOperationProvider

createEvictAllOperation

public com.hazelcast.map.impl.operation.MapOperation createEvictAllOperation(String name)

Specified by:

createEvictAllOperation in interface com.hazelcast.map.impl.operation.MapOperationProvider

createSetTtlOperation

public com.hazelcast.map.impl.operation.MapOperation createSetTtlOperation(String name,
                                                                           com.hazelcast.nio.serialization.Data dataKey,
                                                                           long ttl)

Specified by:

createSetTtlOperation in interface com.hazelcast.map.impl.operation.MapOperationProvider

createContainsKeyOperation

public com.hazelcast.map.impl.operation.MapOperation createContainsKeyOperation(String name,
                                                                                com.hazelcast.nio.serialization.Data dataKey)

Specified by:

createContainsKeyOperation in interface com.hazelcast.map.impl.operation.MapOperationProvider

createContainsValueOperationFactory

public com.hazelcast.spi.OperationFactory createContainsValueOperationFactory(String name,
                                                                              com.hazelcast.nio.serialization.Data testValue)

Specified by:

createContainsValueOperationFactory in interface com.hazelcast.map.impl.operation.MapOperationProvider

createGetAllOperationFactory

public com.hazelcast.spi.OperationFactory createGetAllOperationFactory(String name,
                                                                       List<com.hazelcast.nio.serialization.Data> keys)

Specified by:

createGetAllOperationFactory in interface com.hazelcast.map.impl.operation.MapOperationProvider

createEvictAllOperationFactory

public com.hazelcast.spi.OperationFactory createEvictAllOperationFactory(String name)

Specified by:

createEvictAllOperationFactory in interface com.hazelcast.map.impl.operation.MapOperationProvider

createClearOperationFactory

public com.hazelcast.spi.OperationFactory createClearOperationFactory(String name)

Specified by:

createClearOperationFactory in interface com.hazelcast.map.impl.operation.MapOperationProvider

createMapFlushOperationFactory

public com.hazelcast.spi.OperationFactory createMapFlushOperationFactory(String name)

Specified by:

createMapFlushOperationFactory in interface com.hazelcast.map.impl.operation.MapOperationProvider

createLoadAllOperationFactory

public com.hazelcast.spi.OperationFactory createLoadAllOperationFactory(String name,
                                                                        List<com.hazelcast.nio.serialization.Data> keys,
                                                                        boolean replaceExistingValues)

Specified by:

createLoadAllOperationFactory in interface com.hazelcast.map.impl.operation.MapOperationProvider

createTxnDeleteOperation

public com.hazelcast.map.impl.operation.MapOperation createTxnDeleteOperation(String name,
                                                                              com.hazelcast.nio.serialization.Data dataKey,
                                                                              long version)

Specified by:

createTxnDeleteOperation in interface com.hazelcast.map.impl.operation.MapOperationProvider

createTxnLockAndGetOperation

public com.hazelcast.map.impl.operation.MapOperation createTxnLockAndGetOperation(String name,
                                                                                  com.hazelcast.nio.serialization.Data dataKey,
                                                                                  long timeout,
                                                                                  long ttl,
                                                                                  String ownerUuid,
                                                                                  boolean shouldLoad,
                                                                                  boolean blockReads)

Specified by:

createTxnLockAndGetOperation in interface com.hazelcast.map.impl.operation.MapOperationProvider

createTxnSetOperation

public com.hazelcast.map.impl.operation.MapOperation createTxnSetOperation(String name,
                                                                           com.hazelcast.nio.serialization.Data dataKey,
                                                                           com.hazelcast.nio.serialization.Data value,
                                                                           long version,
                                                                           long ttl)

Specified by:

createTxnSetOperation in interface com.hazelcast.map.impl.operation.MapOperationProvider

createLegacyMergeOperation

public com.hazelcast.map.impl.operation.MapOperation createLegacyMergeOperation(String name,
                                                                                com.hazelcast.core.EntryView<com.hazelcast.nio.serialization.Data,com.hazelcast.nio.serialization.Data> entryView,
                                                                                com.hazelcast.map.merge.MapMergePolicy policy,
                                                                                boolean disableWanReplicationEvent)

Specified by:

createLegacyMergeOperation in interface com.hazelcast.map.impl.operation.MapOperationProvider

createMergeOperation

public com.hazelcast.map.impl.operation.MapOperation createMergeOperation(String name,
                                                                          com.hazelcast.spi.merge.SplitBrainMergeTypes.MapMergeTypes mergingEntry,
                                                                          com.hazelcast.spi.merge.SplitBrainMergePolicy<com.hazelcast.nio.serialization.Data,com.hazelcast.spi.merge.SplitBrainMergeTypes.MapMergeTypes> policy,
                                                                          boolean disableWanReplicationEvent)

Specified by:

createMergeOperation in interface com.hazelcast.map.impl.operation.MapOperationProvider

createMapFlushOperation

public com.hazelcast.map.impl.operation.MapOperation createMapFlushOperation(String name)

Specified by:

createMapFlushOperation in interface com.hazelcast.map.impl.operation.MapOperationProvider

createLoadMapOperation

public com.hazelcast.map.impl.operation.MapOperation createLoadMapOperation(String name,
                                                                            boolean replaceExistingValues)

Specified by:

createLoadMapOperation in interface com.hazelcast.map.impl.operation.MapOperationProvider

createFetchKeysOperation

public com.hazelcast.map.impl.operation.MapOperation createFetchKeysOperation(String name,
                                                                              int lastTableIndex,
                                                                              int fetchSize)

Specified by:

createFetchKeysOperation in interface com.hazelcast.map.impl.operation.MapOperationProvider

createFetchEntriesOperation

public com.hazelcast.map.impl.operation.MapOperation createFetchEntriesOperation(String name,
                                                                                 int lastTableIndex,
                                                                                 int fetchSize)

Specified by:

createFetchEntriesOperation in interface com.hazelcast.map.impl.operation.MapOperationProvider

createFetchWithQueryOperation

public com.hazelcast.map.impl.operation.MapOperation createFetchWithQueryOperation(String name,
                                                                                   int lastTableIndex,
                                                                                   int fetchSize,
                                                                                   com.hazelcast.map.impl.query.Query query)

Specified by:

createFetchWithQueryOperation in interface com.hazelcast.map.impl.operation.MapOperationProvider

createGetEntryViewOperation

public com.hazelcast.map.impl.operation.MapOperation createGetEntryViewOperation(String name,
                                                                                 com.hazelcast.nio.serialization.Data dataKey)

Specified by:

createGetEntryViewOperation in interface com.hazelcast.map.impl.operation.MapOperationProvider

createPartitionWideEntryOperationFactory

public com.hazelcast.spi.OperationFactory createPartitionWideEntryOperationFactory(String name,
                                                                                   com.hazelcast.map.EntryProcessor entryProcessor)

Specified by:

createPartitionWideEntryOperationFactory in interface com.hazelcast.map.impl.operation.MapOperationProvider

createPartitionWideEntryWithPredicateOperationFactory

public com.hazelcast.spi.OperationFactory createPartitionWideEntryWithPredicateOperationFactory(String name,
                                                                                                com.hazelcast.map.EntryProcessor entryProcessor,
                                                                                                com.hazelcast.query.Predicate predicate)

Specified by:

createPartitionWideEntryWithPredicateOperationFactory in interface com.hazelcast.map.impl.operation.MapOperationProvider

createMultipleEntryOperationFactory

public com.hazelcast.spi.OperationFactory createMultipleEntryOperationFactory(String name,
                                                                              Set<com.hazelcast.nio.serialization.Data> keys,
                                                                              com.hazelcast.map.EntryProcessor entryProcessor)

Specified by:

createMultipleEntryOperationFactory in interface com.hazelcast.map.impl.operation.MapOperationProvider

createGetOperation

public com.hazelcast.map.impl.operation.MapOperation createGetOperation(String name,
                                                                        com.hazelcast.nio.serialization.Data dataKey)

Specified by:

createGetOperation in interface com.hazelcast.map.impl.operation.MapOperationProvider

createQueryOperation

public com.hazelcast.map.impl.operation.MapOperation createQueryOperation(com.hazelcast.map.impl.query.Query query)

Specified by:

createQueryOperation in interface com.hazelcast.map.impl.operation.MapOperationProvider

createQueryPartitionOperation

public com.hazelcast.map.impl.operation.MapOperation createQueryPartitionOperation(com.hazelcast.map.impl.query.Query query)

Specified by:

createQueryPartitionOperation in interface com.hazelcast.map.impl.operation.MapOperationProvider

createLoadAllOperation

public com.hazelcast.map.impl.operation.MapOperation createLoadAllOperation(String name,
                                                                            List<com.hazelcast.nio.serialization.Data> keys,
                                                                            boolean replaceExistingValues)

Specified by:

createLoadAllOperation in interface com.hazelcast.map.impl.operation.MapOperationProvider

createPutAllOperationFactory

public com.hazelcast.spi.OperationFactory createPutAllOperationFactory(String name,
                                                                       int[] partitions,
                                                                       com.hazelcast.map.impl.MapEntries[] mapEntries)

Specified by:

createPutAllOperationFactory in interface com.hazelcast.map.impl.operation.MapOperationProvider

createMergeOperationFactory

public com.hazelcast.spi.OperationFactory createMergeOperationFactory(String name,
                                                                      int[] partitions,
                                                                      List<com.hazelcast.spi.merge.SplitBrainMergeTypes.MapMergeTypes>[] mergingEntries,
                                                                      com.hazelcast.spi.merge.SplitBrainMergePolicy<com.hazelcast.nio.serialization.Data,com.hazelcast.spi.merge.SplitBrainMergeTypes.MapMergeTypes> policy)

Specified by:

createMergeOperationFactory in interface com.hazelcast.map.impl.operation.MapOperationProvider

createPutAllOperation

public com.hazelcast.map.impl.operation.MapOperation createPutAllOperation(String name,
                                                                           com.hazelcast.map.impl.MapEntries mapEntries)

Specified by:

createPutAllOperation in interface com.hazelcast.map.impl.operation.MapOperationProvider

createPutFromLoadAllOperation

public com.hazelcast.map.impl.operation.MapOperation createPutFromLoadAllOperation(String name,
                                                                                   List<com.hazelcast.nio.serialization.Data> keyValueSequence)

Specified by:

createPutFromLoadAllOperation in interface com.hazelcast.map.impl.operation.MapOperationProvider