com.hazelcast.cache.hidensity.operation

Class CacheMergeOperationFactory

java.lang.Object

com.hazelcast.spi.impl.operationservice.impl.operations.PartitionAwareOperationFactory

com.hazelcast.cache.hidensity.operation.CacheMergeOperationFactory

All Implemented Interfaces:

com.hazelcast.nio.serialization.DataSerializable, com.hazelcast.nio.serialization.IdentifiedDataSerializable, com.hazelcast.spi.OperationFactory

public class CacheMergeOperationFactory
extends com.hazelcast.spi.impl.operationservice.impl.operations.PartitionAwareOperationFactory

Inserts the merging entries for all partitions of a member via locally invoked CacheMergeOperation.

Since:

3.10

Field Summary

Fields inherited from class com.hazelcast.spi.impl.operationservice.impl.operations.PartitionAwareOperationFactory

partitions

Constructor Summary

Constructors

Constructor and Description
CacheMergeOperationFactory()
CacheMergeOperationFactory(String name, int[] partitions, List<com.hazelcast.spi.merge.SplitBrainMergeTypes.CacheMergeTypes>[] mergingEntries, com.hazelcast.spi.merge.SplitBrainMergePolicy<com.hazelcast.nio.serialization.Data,com.hazelcast.spi.merge.SplitBrainMergeTypes.CacheMergeTypes> policy)

Method Summary

Modifier and Type	Method and Description
com.hazelcast.spi.Operation	createPartitionOperation(int partitionId)
int	getFactoryId()
int	getId()
void	readData(com.hazelcast.nio.ObjectDataInput in)
void	writeData(com.hazelcast.nio.ObjectDataOutput out)

Methods inherited from class com.hazelcast.spi.impl.operationservice.impl.operations.PartitionAwareOperationFactory

createFactoryOnRunner, createOperation

Methods inherited from class java.lang.Object

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

Constructor Detail

CacheMergeOperationFactory

public CacheMergeOperationFactory()

CacheMergeOperationFactory

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

Method Detail

createPartitionOperation

public com.hazelcast.spi.Operation createPartitionOperation(int partitionId)

Specified by:

createPartitionOperation in class com.hazelcast.spi.impl.operationservice.impl.operations.PartitionAwareOperationFactory

writeData

public void writeData(com.hazelcast.nio.ObjectDataOutput out)
               throws IOException

Throws:

IOException

readData

public void readData(com.hazelcast.nio.ObjectDataInput in)
              throws IOException

Throws:

IOException

getFactoryId

public int getFactoryId()

getId

public int getId()