com.hazelcast.map.impl.operation

Class WANAwareOperationProvider

java.lang.Object

com.hazelcast.map.impl.operation.WANAwareOperationProvider

All Implemented Interfaces:

MapOperationProvider

public class WANAwareOperationProvider
extends Object

This class is responsible for WAN replication related checks for supported mutating operations. Operation creations are delegated to underlying MapOperationProvider instance after checks.

Constructor Summary

Constructors

Constructor and Description
WANAwareOperationProvider(MapServiceContext mapServiceContext, MapOperationProvider operationProviderDelegate)

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> mergingEntry, 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)

Methods inherited from class java.lang.Object

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

Constructor Detail

WANAwareOperationProvider

public WANAwareOperationProvider(MapServiceContext mapServiceContext,
                                 MapOperationProvider operationProviderDelegate)

Method Detail

createPutOperation

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

Specified by:

createPutOperation in interface MapOperationProvider

createTryPutOperation

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

Specified by:

createTryPutOperation in interface MapOperationProvider

createSetOperation

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

Specified by:

createSetOperation in interface MapOperationProvider

createPutIfAbsentOperation

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

Specified by:

createPutIfAbsentOperation in interface MapOperationProvider

createPutTransientOperation

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

Specified by:

createPutTransientOperation in interface MapOperationProvider

createRemoveOperation

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

Specified by:

createRemoveOperation in interface MapOperationProvider

createSetTtlOperation

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

Specified by:

createSetTtlOperation in interface MapOperationProvider

createTryRemoveOperation

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

Specified by:

createTryRemoveOperation in interface MapOperationProvider

createReplaceOperation

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

Specified by:

createReplaceOperation in interface MapOperationProvider

createRemoveIfSameOperation

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

Specified by:

createRemoveIfSameOperation in interface MapOperationProvider

createReplaceIfSameOperation

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

Specified by:

createReplaceIfSameOperation in interface MapOperationProvider

createDeleteOperation

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

Description copied from interface: MapOperationProvider

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.

Specified by:

createDeleteOperation in interface MapOperationProvider

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

createEntryOperation

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

Specified by:

createEntryOperation in interface MapOperationProvider

createQueryOperation

public MapOperation createQueryOperation(Query query)

Specified by:

createQueryOperation in interface MapOperationProvider

createQueryPartitionOperation

public MapOperation createQueryPartitionOperation(Query query)

Specified by:

createQueryPartitionOperation in interface MapOperationProvider

createPutAllOperation

public MapOperation createPutAllOperation(String name,
                                          MapEntries mapEntries)

Specified by:

createPutAllOperation in interface MapOperationProvider

createPutAllOperationFactory

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

Specified by:

createPutAllOperationFactory in interface MapOperationProvider

createPutFromLoadAllOperation

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

Specified by:

createPutFromLoadAllOperation in interface MapOperationProvider

createTxnDeleteOperation

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

Specified by:

createTxnDeleteOperation in interface MapOperationProvider

createTxnSetOperation

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

Specified by:

createTxnSetOperation in interface MapOperationProvider

createLegacyMergeOperation

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

Specified by:

createLegacyMergeOperation in interface MapOperationProvider

createMergeOperation

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

Specified by:

createMergeOperation in interface MapOperationProvider

createPartitionWideEntryOperationFactory

public OperationFactory createPartitionWideEntryOperationFactory(String name,
                                                                 EntryProcessor entryProcessor)

Specified by:

createPartitionWideEntryOperationFactory in interface MapOperationProvider

createPartitionWideEntryWithPredicateOperationFactory

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

Specified by:

createPartitionWideEntryWithPredicateOperationFactory in interface MapOperationProvider

createMultipleEntryOperationFactory

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

Specified by:

createMultipleEntryOperationFactory in interface MapOperationProvider

createClearOperation

public MapOperation createClearOperation(String name)

Specified by:

createClearOperation in interface MapOperationProvider

createEvictOperation

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

Specified by:

createEvictOperation in interface MapOperationProvider

createEvictAllOperation

public MapOperation createEvictAllOperation(String name)

Specified by:

createEvictAllOperation in interface MapOperationProvider

createContainsKeyOperation

public MapOperation createContainsKeyOperation(String name,
                                               Data dataKey)

Specified by:

createContainsKeyOperation in interface MapOperationProvider

createGetEntryViewOperation

public MapOperation createGetEntryViewOperation(String name,
                                                Data dataKey)

Specified by:

createGetEntryViewOperation in interface MapOperationProvider

createGetOperation

public MapOperation createGetOperation(String name,
                                       Data dataKey)

Specified by:

createGetOperation in interface MapOperationProvider

createLoadAllOperation

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

Description copied from interface: MapOperationProvider

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

Specified by:

createLoadAllOperation in interface MapOperationProvider

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

createMergeOperationFactory

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

Specified by:

createMergeOperationFactory in interface MapOperationProvider

createTxnLockAndGetOperation

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

Specified by:

createTxnLockAndGetOperation in interface MapOperationProvider

createContainsValueOperationFactory

public OperationFactory createContainsValueOperationFactory(String name,
                                                            Data testValue)

Specified by:

createContainsValueOperationFactory in interface MapOperationProvider

createEvictAllOperationFactory

public OperationFactory createEvictAllOperationFactory(String name)

Specified by:

createEvictAllOperationFactory in interface MapOperationProvider

createClearOperationFactory

public OperationFactory createClearOperationFactory(String name)

Specified by:

createClearOperationFactory in interface MapOperationProvider

createMapFlushOperationFactory

public OperationFactory createMapFlushOperationFactory(String name)

Specified by:

createMapFlushOperationFactory in interface MapOperationProvider

createLoadAllOperationFactory

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

Specified by:

createLoadAllOperationFactory in interface MapOperationProvider

createGetAllOperationFactory

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

Specified by:

createGetAllOperationFactory in interface MapOperationProvider

createMapSizeOperationFactory

public OperationFactory createMapSizeOperationFactory(String name)

Specified by:

createMapSizeOperationFactory in interface MapOperationProvider

createMapFlushOperation

public MapOperation createMapFlushOperation(String name)

Specified by:

createMapFlushOperation in interface MapOperationProvider

createLoadMapOperation

public MapOperation createLoadMapOperation(String name,
                                           boolean replaceExistingValues)

Specified by:

createLoadMapOperation in interface MapOperationProvider

createFetchKeysOperation

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

Specified by:

createFetchKeysOperation in interface MapOperationProvider

createFetchEntriesOperation

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

Specified by:

createFetchEntriesOperation in interface MapOperationProvider

createFetchWithQueryOperation

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

Description copied from interface: MapOperationProvider

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

Specified by:

createFetchWithQueryOperation in interface MapOperationProvider

See Also:

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