com.hazelcast.cache.operation

Class WanCacheMergeOperation

java.lang.Object

com.hazelcast.spi.Operation

com.hazelcast.spi.impl.AbstractNamedOperation

com.hazelcast.cache.impl.operation.CacheOperation

com.hazelcast.cache.impl.operation.KeyBasedCacheOperation

com.hazelcast.cache.impl.operation.MutatingCacheOperation

com.hazelcast.cache.operation.WanCacheMergeOperation

All Implemented Interfaces:

com.hazelcast.cache.impl.operation.MutableOperation, com.hazelcast.nio.serialization.DataSerializable, com.hazelcast.nio.serialization.IdentifiedDataSerializable, com.hazelcast.spi.BackupAwareOperation, com.hazelcast.spi.impl.MutatingOperation, com.hazelcast.spi.NamedOperation, com.hazelcast.spi.PartitionAwareOperation, com.hazelcast.spi.ServiceNamespaceAware

public class WanCacheMergeOperation
extends com.hazelcast.cache.impl.operation.MutatingCacheOperation

Operation implementation for merging entries. This operation is used by WAN replication services.

Since:

3.10

Field Summary

Fields inherited from class com.hazelcast.cache.impl.operation.MutatingCacheOperation

completionId

Fields inherited from class com.hazelcast.cache.impl.operation.KeyBasedCacheOperation

backupRecord, key, response

Fields inherited from class com.hazelcast.cache.impl.operation.CacheOperation

cacheService, dontCreateCacheRecordStoreIfNotExist, recordStore, tenantContext, wanEventPublisher

Fields inherited from class com.hazelcast.spi.impl.AbstractNamedOperation

name

Fields inherited from class com.hazelcast.spi.Operation

GENERIC_PARTITION_ID

Fields inherited from interface com.hazelcast.cache.impl.operation.MutableOperation

IGNORE_COMPLETION

Constructor Summary

Constructors

Constructor and Description
WanCacheMergeOperation()
WanCacheMergeOperation(String name, String wanGroupName, 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)

Method Summary

Modifier and Type	Method and Description
com.hazelcast.spi.Operation	getBackupOperation()
int	getFactoryId()
int	getId()
protected void	readInternal(com.hazelcast.nio.ObjectDataInput in)
void	run()
boolean	shouldBackup()
protected void	writeInternal(com.hazelcast.nio.ObjectDataOutput out)

Methods inherited from class com.hazelcast.cache.impl.operation.MutatingCacheOperation

getCompletionId, setCompletionId

Methods inherited from class com.hazelcast.cache.impl.operation.KeyBasedCacheOperation

getResponse

Methods inherited from class com.hazelcast.cache.impl.operation.CacheOperation

afterRun, beforeRun, beforeRunInternal, dispose, getAsyncBackupCount, getServiceName, getServiceNamespace, getSyncBackupCount, logError, onInvocationException, publishWanRemove, publishWanUpdate, publishWanUpdate, publishWanUpdate

Methods inherited from class com.hazelcast.spi.impl.AbstractNamedOperation

getName, toString

Methods inherited from class com.hazelcast.spi.Operation

call, executedLocally, getCallerAddress, getCallerUuid, getCallId, getCallTimeout, getConnection, getInvocationTime, getLogger, getNodeEngine, getOperationResponseHandler, getPartitionId, getReplicaIndex, getService, getWaitTimeout, isUrgent, onExecutionFailure, onSetCallId, readData, requiresExplicitServiceName, returnsResponse, sendResponse, setCallerUuid, setNodeEngine, setOperationResponseHandler, setPartitionId, setReplicaIndex, setService, setServiceName, setValidateTarget, setWaitTimeout, toString, validatesTarget, writeData

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.hazelcast.spi.BackupAwareOperation

getAsyncBackupCount, getSyncBackupCount

Methods inherited from interface com.hazelcast.spi.PartitionAwareOperation

getPartitionId

Methods inherited from interface com.hazelcast.nio.serialization.DataSerializable

readData, writeData

Constructor Detail

WanCacheMergeOperation

public WanCacheMergeOperation()

WanCacheMergeOperation

public WanCacheMergeOperation(String name,
                              String wanGroupName,
                              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)

Method Detail

run

public void run()
         throws Exception

Overrides:

run in class com.hazelcast.spi.Operation

Throws:

Exception

shouldBackup

public boolean shouldBackup()

getBackupOperation

public com.hazelcast.spi.Operation getBackupOperation()

writeInternal

protected void writeInternal(com.hazelcast.nio.ObjectDataOutput out)
                      throws IOException

Overrides:

writeInternal in class com.hazelcast.cache.impl.operation.MutatingCacheOperation

Throws:

IOException

readInternal

protected void readInternal(com.hazelcast.nio.ObjectDataInput in)
                     throws IOException

Overrides:

readInternal in class com.hazelcast.cache.impl.operation.MutatingCacheOperation

Throws:

IOException

getId

public int getId()

getFactoryId

public int getFactoryId()

Specified by:

getFactoryId in interface com.hazelcast.nio.serialization.IdentifiedDataSerializable

Overrides:

getFactoryId in class com.hazelcast.cache.impl.operation.CacheOperation