com.hazelcast.cache.impl

Class DefaultOperationProvider

java.lang.Object

com.hazelcast.cache.impl.DefaultOperationProvider

All Implemented Interfaces:

CacheOperationProvider

public class DefaultOperationProvider
extends Object
implements CacheOperationProvider

Provide operations other then InMemoryFormat.NATIVE

Field Summary

Fields

Modifier and Type	Field and Description
protected String	nameWithPrefix

Constructor Summary

Constructors

Constructor and Description
DefaultOperationProvider(String nameWithPrefix)

Method Summary

Modifier and Type	Method and Description
OperationFactory	createClearOperationFactory()
Operation	createContainsKeyOperation(Data key)
Operation	createEntryIteratorOperation(int lastTableIndex, int fetchSize)
Operation	createEntryProcessorOperation(Data key, Integer completionId, javax.cache.processor.EntryProcessor entryProcessor, Object... arguments)
OperationFactory	createGetAllOperationFactory(Set<Data> keySet, javax.cache.expiry.ExpiryPolicy policy)
Operation	createGetAndRemoveOperation(Data key, int completionId)
Operation	createGetAndReplaceOperation(Data key, Data value, javax.cache.expiry.ExpiryPolicy policy, int completionId)
Operation	createGetOperation(Data key, javax.cache.expiry.ExpiryPolicy policy)
Operation	createKeyIteratorOperation(int lastTableIndex, int fetchSize)
OperationFactory	createLoadAllOperationFactory(Set<Data> keySet, boolean replaceExistingValues)
Operation	createMergeOperation(String name, List<SplitBrainMergeTypes.CacheMergeTypes> mergingEntries, SplitBrainMergePolicy<Data,SplitBrainMergeTypes.CacheMergeTypes> policy)
OperationFactory	createMergeOperationFactory(String name, int[] partitions, List<SplitBrainMergeTypes.CacheMergeTypes>[] mergingEntries, SplitBrainMergePolicy<Data,SplitBrainMergeTypes.CacheMergeTypes> policy)
Operation	createPutAllOperation(List<Map.Entry<Data,Data>> entries, javax.cache.expiry.ExpiryPolicy policy, int completionId)
Operation	createPutIfAbsentOperation(Data key, Data value, javax.cache.expiry.ExpiryPolicy policy, int completionId)
Operation	createPutOperation(Data key, Data value, javax.cache.expiry.ExpiryPolicy policy, boolean get, int completionId)
OperationFactory	createRemoveAllOperationFactory(Set<Data> keySet, Integer completionId)
Operation	createRemoveOperation(Data key, Data oldValue, int completionId)
Operation	createReplaceOperation(Data key, Data oldValue, Data newValue, javax.cache.expiry.ExpiryPolicy policy, int completionId)
OperationFactory	createSizeOperationFactory()

Methods inherited from class java.lang.Object

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

Field Detail

nameWithPrefix

protected final String nameWithPrefix

Constructor Detail

DefaultOperationProvider

public DefaultOperationProvider(String nameWithPrefix)

Method Detail

createPutOperation

public Operation createPutOperation(Data key,
                                    Data value,
                                    javax.cache.expiry.ExpiryPolicy policy,
                                    boolean get,
                                    int completionId)

Specified by:

createPutOperation in interface CacheOperationProvider

createPutAllOperation

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

Specified by:

createPutAllOperation in interface CacheOperationProvider

createGetOperation

public Operation createGetOperation(Data key,
                                    javax.cache.expiry.ExpiryPolicy policy)

Specified by:

createGetOperation in interface CacheOperationProvider

createContainsKeyOperation

public Operation createContainsKeyOperation(Data key)

Specified by:

createContainsKeyOperation in interface CacheOperationProvider

createPutIfAbsentOperation

public Operation createPutIfAbsentOperation(Data key,
                                            Data value,
                                            javax.cache.expiry.ExpiryPolicy policy,
                                            int completionId)

Specified by:

createPutIfAbsentOperation in interface CacheOperationProvider

createRemoveOperation

public Operation createRemoveOperation(Data key,
                                       Data oldValue,
                                       int completionId)

Specified by:

createRemoveOperation in interface CacheOperationProvider

createGetAndRemoveOperation

public Operation createGetAndRemoveOperation(Data key,
                                             int completionId)

Specified by:

createGetAndRemoveOperation in interface CacheOperationProvider

createReplaceOperation

public Operation createReplaceOperation(Data key,
                                        Data oldValue,
                                        Data newValue,
                                        javax.cache.expiry.ExpiryPolicy policy,
                                        int completionId)

Specified by:

createReplaceOperation in interface CacheOperationProvider

createGetAndReplaceOperation

public Operation createGetAndReplaceOperation(Data key,
                                              Data value,
                                              javax.cache.expiry.ExpiryPolicy policy,
                                              int completionId)

Specified by:

createGetAndReplaceOperation in interface CacheOperationProvider

createEntryProcessorOperation

public Operation createEntryProcessorOperation(Data key,
                                               Integer completionId,
                                               javax.cache.processor.EntryProcessor entryProcessor,
                                               Object... arguments)

Specified by:

createEntryProcessorOperation in interface CacheOperationProvider

createKeyIteratorOperation

public Operation createKeyIteratorOperation(int lastTableIndex,
                                            int fetchSize)

Specified by:

createKeyIteratorOperation in interface CacheOperationProvider

createEntryIteratorOperation

public Operation createEntryIteratorOperation(int lastTableIndex,
                                              int fetchSize)

Specified by:

createEntryIteratorOperation in interface CacheOperationProvider

createMergeOperation

public Operation createMergeOperation(String name,
                                      List<SplitBrainMergeTypes.CacheMergeTypes> mergingEntries,
                                      SplitBrainMergePolicy<Data,SplitBrainMergeTypes.CacheMergeTypes> policy)

Specified by:

createMergeOperation in interface CacheOperationProvider

createMergeOperationFactory

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

Specified by:

createMergeOperationFactory in interface CacheOperationProvider

createGetAllOperationFactory

public OperationFactory createGetAllOperationFactory(Set<Data> keySet,
                                                     javax.cache.expiry.ExpiryPolicy policy)

Specified by:

createGetAllOperationFactory in interface CacheOperationProvider

createLoadAllOperationFactory

public OperationFactory createLoadAllOperationFactory(Set<Data> keySet,
                                                      boolean replaceExistingValues)

Specified by:

createLoadAllOperationFactory in interface CacheOperationProvider

createClearOperationFactory

public OperationFactory createClearOperationFactory()

Specified by:

createClearOperationFactory in interface CacheOperationProvider

createRemoveAllOperationFactory

public OperationFactory createRemoveAllOperationFactory(Set<Data> keySet,
                                                        Integer completionId)

Specified by:

createRemoveAllOperationFactory in interface CacheOperationProvider

createSizeOperationFactory

public OperationFactory createSizeOperationFactory()

Specified by:

createSizeOperationFactory in interface CacheOperationProvider