com.hazelcast.map.impl.operation

Class WANAwareOperationProvider

java.lang.Object

com.hazelcast.map.impl.operation.MapOperationProviderDelegator

com.hazelcast.map.impl.operation.WANAwareOperationProvider

All Implemented Interfaces:

MapOperationProvider

public class WANAwareOperationProvider
extends MapOperationProviderDelegator

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

Methods

Modifier and Type	Method and Description
MapOperation	createDeleteOperation(String name, Data key)
MapOperation	createEntryOperation(String name, Data dataKey, EntryProcessor entryProcessor)
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, boolean initialLoad)
MapOperation	createPutFromLoadAllOperation(String name, List<Data> keyValueSequence)
MapOperation	createPutIfAbsentOperation(String name, Data key, Data value, long ttl)
MapOperation	createPutOperation(String name, Data key, Data value, long ttl)
MapOperation	createPutTransientOperation(String name, Data key, Data value, long ttl)
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)
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	createTxnSetOperation(String name, Data dataKey, Data value, long version, long ttl)

Methods inherited from class com.hazelcast.map.impl.operation.MapOperationProviderDelegator

createClearOperation, createClearOperationFactory, createContainsKeyOperation, createContainsValueOperationFactory, createEvictAllOperation, createEvictAllOperationFactory, createEvictOperation, createGetAllOperationFactory, createGetEntryViewOperation, createGetOperation, createLoadAllOperation, createLoadAllOperationFactory, createLoadMapOperation, createMapFlushOperation, createMapFlushOperationFactory, createMapSizeOperationFactory, createMergeOperation, createTxnLockAndGetOperation

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)

Specified by:

createPutOperation in interface MapOperationProvider

Overrides:

createPutOperation in class MapOperationProviderDelegator

createTryPutOperation

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

Specified by:

createTryPutOperation in interface MapOperationProvider

Overrides:

createTryPutOperation in class MapOperationProviderDelegator

createSetOperation

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

Specified by:

createSetOperation in interface MapOperationProvider

Overrides:

createSetOperation in class MapOperationProviderDelegator

createPutIfAbsentOperation

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

Specified by:

createPutIfAbsentOperation in interface MapOperationProvider

Overrides:

createPutIfAbsentOperation in class MapOperationProviderDelegator

createPutTransientOperation

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

Specified by:

createPutTransientOperation in interface MapOperationProvider

Overrides:

createPutTransientOperation in class MapOperationProviderDelegator

createRemoveOperation

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

Specified by:

createRemoveOperation in interface MapOperationProvider

Overrides:

createRemoveOperation in class MapOperationProviderDelegator

createTryRemoveOperation

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

Specified by:

createTryRemoveOperation in interface MapOperationProvider

Overrides:

createTryRemoveOperation in class MapOperationProviderDelegator

createReplaceOperation

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

Specified by:

createReplaceOperation in interface MapOperationProvider

Overrides:

createReplaceOperation in class MapOperationProviderDelegator

createRemoveIfSameOperation

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

Specified by:

createRemoveIfSameOperation in interface MapOperationProvider

Overrides:

createRemoveIfSameOperation in class MapOperationProviderDelegator

createReplaceIfSameOperation

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

Specified by:

createReplaceIfSameOperation in interface MapOperationProvider

Overrides:

createReplaceIfSameOperation in class MapOperationProviderDelegator

createDeleteOperation

public MapOperation createDeleteOperation(String name,
                                 Data key)

Specified by:

createDeleteOperation in interface MapOperationProvider

Overrides:

createDeleteOperation in class MapOperationProviderDelegator

createEntryOperation

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

Specified by:

createEntryOperation in interface MapOperationProvider

Overrides:

createEntryOperation in class MapOperationProviderDelegator

createPutAllOperation

public MapOperation createPutAllOperation(String name,
                                 MapEntries mapEntries,
                                 boolean initialLoad)

Specified by:

createPutAllOperation in interface MapOperationProvider

Overrides:

createPutAllOperation in class MapOperationProviderDelegator

createPutFromLoadAllOperation

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

Specified by:

createPutFromLoadAllOperation in interface MapOperationProvider

Overrides:

createPutFromLoadAllOperation in class MapOperationProviderDelegator

createTxnDeleteOperation

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

Specified by:

createTxnDeleteOperation in interface MapOperationProvider

Overrides:

createTxnDeleteOperation in class MapOperationProviderDelegator

createTxnSetOperation

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

Specified by:

createTxnSetOperation in interface MapOperationProvider

Overrides:

createTxnSetOperation in class MapOperationProviderDelegator

createPartitionWideEntryOperationFactory

public OperationFactory createPartitionWideEntryOperationFactory(String name,
                                                        EntryProcessor entryProcessor)

Specified by:

createPartitionWideEntryOperationFactory in interface MapOperationProvider

Overrides:

createPartitionWideEntryOperationFactory in class MapOperationProviderDelegator

createPartitionWideEntryWithPredicateOperationFactory

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

Specified by:

createPartitionWideEntryWithPredicateOperationFactory in interface MapOperationProvider

Overrides:

createPartitionWideEntryWithPredicateOperationFactory in class MapOperationProviderDelegator

createMultipleEntryOperationFactory

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

Specified by:

createMultipleEntryOperationFactory in interface MapOperationProvider

Overrides:

createMultipleEntryOperationFactory in class MapOperationProviderDelegator