com.hazelcast.cache.operation

Class WANAwareCacheOperationProvider

java.lang.Object

com.hazelcast.cache.impl.DefaultOperationProvider

com.hazelcast.cache.operation.EnterpriseCacheOperationProvider

com.hazelcast.cache.operation.WANAwareCacheOperationProvider

All Implemented Interfaces:

com.hazelcast.cache.impl.CacheOperationProvider

public class WANAwareCacheOperationProvider
extends EnterpriseCacheOperationProvider

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

Field Summary

Fields inherited from class com.hazelcast.cache.impl.DefaultOperationProvider

nameWithPrefix

Constructor Summary

Constructors

Constructor and Description
WANAwareCacheOperationProvider(String nameWithPrefix, EnterpriseCacheOperationProvider delegate, com.hazelcast.util.function.Function<String,com.hazelcast.wan.WanReplicationPublisher> publisherLookupFunction)

Method Summary

Modifier and Type	Method and Description
com.hazelcast.spi.OperationFactory	createClearOperationFactory()
com.hazelcast.spi.Operation	createContainsKeyOperation(com.hazelcast.nio.serialization.Data key)
com.hazelcast.spi.Operation	createEntryProcessorOperation(com.hazelcast.nio.serialization.Data key, Integer completionId, javax.cache.processor.EntryProcessor entryProcessor, Object... args)
com.hazelcast.spi.OperationFactory	createGetAllOperationFactory(Set<com.hazelcast.nio.serialization.Data> keySet, javax.cache.expiry.ExpiryPolicy policy)
com.hazelcast.spi.Operation	createGetAndRemoveOperation(com.hazelcast.nio.serialization.Data key, int completionId)
com.hazelcast.spi.Operation	createGetAndReplaceOperation(com.hazelcast.nio.serialization.Data key, com.hazelcast.nio.serialization.Data value, javax.cache.expiry.ExpiryPolicy policy, int completionId)
com.hazelcast.spi.Operation	createGetOperation(com.hazelcast.nio.serialization.Data key, javax.cache.expiry.ExpiryPolicy policy)
com.hazelcast.spi.Operation	createKeyIteratorOperation(int lastTableIndex, int fetchSize)
com.hazelcast.spi.Operation	createLegacyWanMergeOperation(String origin, com.hazelcast.cache.CacheEntryView<com.hazelcast.nio.serialization.Data,com.hazelcast.nio.serialization.Data> cacheEntryView, com.hazelcast.cache.CacheMergePolicy mergePolicy, int completionId)
com.hazelcast.spi.OperationFactory	createLoadAllOperationFactory(Set<com.hazelcast.nio.serialization.Data> keySet, boolean replaceExistingValues)
com.hazelcast.spi.Operation	createPutAllOperation(List<Map.Entry<com.hazelcast.nio.serialization.Data,com.hazelcast.nio.serialization.Data>> entries, javax.cache.expiry.ExpiryPolicy policy, int completionId)
com.hazelcast.spi.Operation	createPutIfAbsentOperation(com.hazelcast.nio.serialization.Data key, com.hazelcast.nio.serialization.Data value, javax.cache.expiry.ExpiryPolicy policy, int completionId)
com.hazelcast.spi.Operation	createPutOperation(com.hazelcast.nio.serialization.Data key, com.hazelcast.nio.serialization.Data value, javax.cache.expiry.ExpiryPolicy policy, boolean get, int completionId)
com.hazelcast.spi.OperationFactory	createRemoveAllOperationFactory(Set<com.hazelcast.nio.serialization.Data> keySet, Integer completionId)
com.hazelcast.spi.Operation	createRemoveOperation(com.hazelcast.nio.serialization.Data key, com.hazelcast.nio.serialization.Data value, int completionId)
com.hazelcast.spi.Operation	createReplaceOperation(com.hazelcast.nio.serialization.Data key, com.hazelcast.nio.serialization.Data oldValue, com.hazelcast.nio.serialization.Data newValue, javax.cache.expiry.ExpiryPolicy policy, int completionId)
com.hazelcast.spi.Operation	createSetExpiryPolicyOperation(List<com.hazelcast.nio.serialization.Data> keys, com.hazelcast.nio.serialization.Data expiryPolicy)
com.hazelcast.spi.OperationFactory	createSizeOperationFactory()
com.hazelcast.spi.Operation	createWanMergeOperation(String origin, com.hazelcast.spi.merge.SplitBrainMergeTypes.CacheMergeTypes mergingEntry, com.hazelcast.spi.merge.SplitBrainMergePolicy<com.hazelcast.nio.serialization.Data,com.hazelcast.spi.merge.SplitBrainMergeTypes.CacheMergeTypes> mergePolicy, int completionId)
com.hazelcast.spi.Operation	createWanRemoveOperation(String origin, com.hazelcast.nio.serialization.Data key, int completionId)

Methods inherited from class com.hazelcast.cache.impl.DefaultOperationProvider

createEntryIteratorOperation, createMergeOperation, createMergeOperationFactory

Methods inherited from class java.lang.Object

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

Constructor Detail

WANAwareCacheOperationProvider

public WANAwareCacheOperationProvider(String nameWithPrefix,
                                      EnterpriseCacheOperationProvider delegate,
                                      com.hazelcast.util.function.Function<String,com.hazelcast.wan.WanReplicationPublisher> publisherLookupFunction)

Method Detail

createPutOperation

public com.hazelcast.spi.Operation createPutOperation(com.hazelcast.nio.serialization.Data key,
                                                      com.hazelcast.nio.serialization.Data value,
                                                      javax.cache.expiry.ExpiryPolicy policy,
                                                      boolean get,
                                                      int completionId)

Specified by:

createPutOperation in interface com.hazelcast.cache.impl.CacheOperationProvider

Overrides:

createPutOperation in class com.hazelcast.cache.impl.DefaultOperationProvider

createPutAllOperation

public com.hazelcast.spi.Operation createPutAllOperation(List<Map.Entry<com.hazelcast.nio.serialization.Data,com.hazelcast.nio.serialization.Data>> entries,
                                                         javax.cache.expiry.ExpiryPolicy policy,
                                                         int completionId)

Specified by:

createPutAllOperation in interface com.hazelcast.cache.impl.CacheOperationProvider

Overrides:

createPutAllOperation in class com.hazelcast.cache.impl.DefaultOperationProvider

createGetOperation

public com.hazelcast.spi.Operation createGetOperation(com.hazelcast.nio.serialization.Data key,
                                                      javax.cache.expiry.ExpiryPolicy policy)

Specified by:

createGetOperation in interface com.hazelcast.cache.impl.CacheOperationProvider

Overrides:

createGetOperation in class com.hazelcast.cache.impl.DefaultOperationProvider

createContainsKeyOperation

public com.hazelcast.spi.Operation createContainsKeyOperation(com.hazelcast.nio.serialization.Data key)

Specified by:

createContainsKeyOperation in interface com.hazelcast.cache.impl.CacheOperationProvider

Overrides:

createContainsKeyOperation in class com.hazelcast.cache.impl.DefaultOperationProvider

createPutIfAbsentOperation

public com.hazelcast.spi.Operation createPutIfAbsentOperation(com.hazelcast.nio.serialization.Data key,
                                                              com.hazelcast.nio.serialization.Data value,
                                                              javax.cache.expiry.ExpiryPolicy policy,
                                                              int completionId)

Specified by:

createPutIfAbsentOperation in interface com.hazelcast.cache.impl.CacheOperationProvider

Overrides:

createPutIfAbsentOperation in class com.hazelcast.cache.impl.DefaultOperationProvider

createRemoveOperation

public com.hazelcast.spi.Operation createRemoveOperation(com.hazelcast.nio.serialization.Data key,
                                                         com.hazelcast.nio.serialization.Data value,
                                                         int completionId)

Specified by:

createRemoveOperation in interface com.hazelcast.cache.impl.CacheOperationProvider

Overrides:

createRemoveOperation in class com.hazelcast.cache.impl.DefaultOperationProvider

createGetAndRemoveOperation

public com.hazelcast.spi.Operation createGetAndRemoveOperation(com.hazelcast.nio.serialization.Data key,
                                                               int completionId)

Specified by:

createGetAndRemoveOperation in interface com.hazelcast.cache.impl.CacheOperationProvider

Overrides:

createGetAndRemoveOperation in class com.hazelcast.cache.impl.DefaultOperationProvider

createReplaceOperation

public com.hazelcast.spi.Operation createReplaceOperation(com.hazelcast.nio.serialization.Data key,
                                                          com.hazelcast.nio.serialization.Data oldValue,
                                                          com.hazelcast.nio.serialization.Data newValue,
                                                          javax.cache.expiry.ExpiryPolicy policy,
                                                          int completionId)

Specified by:

createReplaceOperation in interface com.hazelcast.cache.impl.CacheOperationProvider

Overrides:

createReplaceOperation in class com.hazelcast.cache.impl.DefaultOperationProvider

createGetAndReplaceOperation

public com.hazelcast.spi.Operation createGetAndReplaceOperation(com.hazelcast.nio.serialization.Data key,
                                                                com.hazelcast.nio.serialization.Data value,
                                                                javax.cache.expiry.ExpiryPolicy policy,
                                                                int completionId)

Specified by:

createGetAndReplaceOperation in interface com.hazelcast.cache.impl.CacheOperationProvider

Overrides:

createGetAndReplaceOperation in class com.hazelcast.cache.impl.DefaultOperationProvider

createEntryProcessorOperation

public com.hazelcast.spi.Operation createEntryProcessorOperation(com.hazelcast.nio.serialization.Data key,
                                                                 Integer completionId,
                                                                 javax.cache.processor.EntryProcessor entryProcessor,
                                                                 Object... args)

Specified by:

createEntryProcessorOperation in interface com.hazelcast.cache.impl.CacheOperationProvider

Overrides:

createEntryProcessorOperation in class com.hazelcast.cache.impl.DefaultOperationProvider

createKeyIteratorOperation

public com.hazelcast.spi.Operation createKeyIteratorOperation(int lastTableIndex,
                                                              int fetchSize)

Specified by:

createKeyIteratorOperation in interface com.hazelcast.cache.impl.CacheOperationProvider

Overrides:

createKeyIteratorOperation in class com.hazelcast.cache.impl.DefaultOperationProvider

createSetExpiryPolicyOperation

public com.hazelcast.spi.Operation createSetExpiryPolicyOperation(List<com.hazelcast.nio.serialization.Data> keys,
                                                                  com.hazelcast.nio.serialization.Data expiryPolicy)

Specified by:

createSetExpiryPolicyOperation in interface com.hazelcast.cache.impl.CacheOperationProvider

Overrides:

createSetExpiryPolicyOperation in class com.hazelcast.cache.impl.DefaultOperationProvider

createGetAllOperationFactory

public com.hazelcast.spi.OperationFactory createGetAllOperationFactory(Set<com.hazelcast.nio.serialization.Data> keySet,
                                                                       javax.cache.expiry.ExpiryPolicy policy)

Specified by:

createGetAllOperationFactory in interface com.hazelcast.cache.impl.CacheOperationProvider

Overrides:

createGetAllOperationFactory in class com.hazelcast.cache.impl.DefaultOperationProvider

createLoadAllOperationFactory

public com.hazelcast.spi.OperationFactory createLoadAllOperationFactory(Set<com.hazelcast.nio.serialization.Data> keySet,
                                                                        boolean replaceExistingValues)

Specified by:

createLoadAllOperationFactory in interface com.hazelcast.cache.impl.CacheOperationProvider

Overrides:

createLoadAllOperationFactory in class com.hazelcast.cache.impl.DefaultOperationProvider

createClearOperationFactory

public com.hazelcast.spi.OperationFactory createClearOperationFactory()

Specified by:

createClearOperationFactory in interface com.hazelcast.cache.impl.CacheOperationProvider

Overrides:

createClearOperationFactory in class com.hazelcast.cache.impl.DefaultOperationProvider

createRemoveAllOperationFactory

public com.hazelcast.spi.OperationFactory createRemoveAllOperationFactory(Set<com.hazelcast.nio.serialization.Data> keySet,
                                                                          Integer completionId)

Specified by:

createRemoveAllOperationFactory in interface com.hazelcast.cache.impl.CacheOperationProvider

Overrides:

createRemoveAllOperationFactory in class com.hazelcast.cache.impl.DefaultOperationProvider

createSizeOperationFactory

public com.hazelcast.spi.OperationFactory createSizeOperationFactory()

Specified by:

createSizeOperationFactory in interface com.hazelcast.cache.impl.CacheOperationProvider

Overrides:

createSizeOperationFactory in class com.hazelcast.cache.impl.DefaultOperationProvider

createWanRemoveOperation

public com.hazelcast.spi.Operation createWanRemoveOperation(String origin,
                                                            com.hazelcast.nio.serialization.Data key,
                                                            int completionId)

Overrides:

createWanRemoveOperation in class EnterpriseCacheOperationProvider

createLegacyWanMergeOperation

public com.hazelcast.spi.Operation createLegacyWanMergeOperation(String origin,
                                                                 com.hazelcast.cache.CacheEntryView<com.hazelcast.nio.serialization.Data,com.hazelcast.nio.serialization.Data> cacheEntryView,
                                                                 com.hazelcast.cache.CacheMergePolicy mergePolicy,
                                                                 int completionId)

Overrides:

createLegacyWanMergeOperation in class EnterpriseCacheOperationProvider

createWanMergeOperation

public com.hazelcast.spi.Operation createWanMergeOperation(String origin,
                                                           com.hazelcast.spi.merge.SplitBrainMergeTypes.CacheMergeTypes mergingEntry,
                                                           com.hazelcast.spi.merge.SplitBrainMergePolicy<com.hazelcast.nio.serialization.Data,com.hazelcast.spi.merge.SplitBrainMergeTypes.CacheMergeTypes> mergePolicy,
                                                           int completionId)

Overrides:

createWanMergeOperation in class EnterpriseCacheOperationProvider