com.gigaspaces.internal.cluster.node.impl.gateway.sink

Class LocalClusterPartialUpdateOperationData

java.lang.Object

com.gigaspaces.internal.cluster.node.impl.gateway.sink.AbstractLocalClusterOperationData

com.gigaspaces.internal.cluster.node.impl.gateway.sink.AbstractLocalClusterWriteOperationData

com.gigaspaces.internal.cluster.node.impl.gateway.sink.LocalClusterUpdateOperationData

com.gigaspaces.internal.cluster.node.impl.gateway.sink.LocalClusterPartialUpdateOperationData

All Implemented Interfaces:

DataConflictOperation, DataSyncOperation

public class LocalClusterPartialUpdateOperationData
extends LocalClusterUpdateOperationData

Operation executer for a partial update replication sink gateway operation against a local cluster.

Since:

8.0.3

Author:

idan

Nested Class Summary

Nested classes/interfaces inherited from interface com.gigaspaces.cluster.replication.gateway.conflict.DataConflictOperation

DataConflictOperation.OperationType

Field Summary

Fields inherited from class com.gigaspaces.internal.cluster.node.impl.gateway.sink.AbstractLocalClusterOperationData

_aborted, _conflictCause, _pendingOperations, _previousConflictCause, _retriesCount, _spaceProxy

Constructor Summary

Constructors

Constructor and Description
LocalClusterPartialUpdateOperationData(ISpaceProxy spaceProxy, IEntryPacket entryPacket)

Method Summary

Modifier and Type	Method and Description
DataSyncOperationType	getDataSyncOperationType()
DataConflictOperation.OperationType	getOperationType()
protected int	getOverrideUpdateModifiers()
protected int	getUpdateModifiersImpl()
boolean	supportsOverride()

Methods inherited from class com.gigaspaces.internal.cluster.node.impl.gateway.sink.LocalClusterUpdateOperationData

isConflictError, supportsBatching

Methods inherited from class com.gigaspaces.internal.cluster.node.impl.gateway.sink.AbstractLocalClusterWriteOperationData

execute, getDataAsDocument, getDataAsObject, getOperationEntry, getSpaceId, getUid, isOverriden, isSameOperationType, overrideImpl, setConflictCause, supportsDataAsDocument, supportsDataAsObject, supportsGetSpaceId

Methods inherited from class com.gigaspaces.internal.cluster.node.impl.gateway.sink.AbstractLocalClusterOperationData

abort, addPendingOperation, convertExceptionToConflict, getConflictCause, getResolutionDescription, getResolveAttempt, getRetriesCount, getTypeDescriptor, hasConflict, incrementResolveAttempt, incrementRetriesCounter, isAborted, isRetryable, override, reset, supportsAbort, supportsGetTypeDescriptor, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

LocalClusterPartialUpdateOperationData

public LocalClusterPartialUpdateOperationData(ISpaceProxy spaceProxy,
                                              IEntryPacket entryPacket)

Method Detail

getUpdateModifiersImpl

protected int getUpdateModifiersImpl()

Overrides:

getUpdateModifiersImpl in class LocalClusterUpdateOperationData

getOperationType

public DataConflictOperation.OperationType getOperationType()

Specified by:

getOperationType in interface DataConflictOperation

Overrides:

getOperationType in class LocalClusterUpdateOperationData

Returns:

The operation type.

getDataSyncOperationType

public DataSyncOperationType getDataSyncOperationType()

Specified by:

getDataSyncOperationType in interface DataSyncOperation

Overrides:

getDataSyncOperationType in class LocalClusterUpdateOperationData

Returns:

the operation type.

supportsOverride

public boolean supportsOverride()

Specified by:

supportsOverride in interface DataConflictOperation

Overrides:

supportsOverride in class AbstractLocalClusterWriteOperationData

Returns:

true if overriding the operation is supported, otherwise false.

getOverrideUpdateModifiers

protected int getOverrideUpdateModifiers()

Overrides:

getOverrideUpdateModifiers in class LocalClusterUpdateOperationData