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

Class LocalClusterUpdateOperationData

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

All Implemented Interfaces:

DataConflictOperation, DataSyncOperation

Direct Known Subclasses:

LocalClusterPartialUpdateOperationData

public class LocalClusterUpdateOperationData
extends AbstractLocalClusterWriteOperationData

Operation executor for an update operation by a gateway sink component against an ISpaceProxy instance representing the 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
LocalClusterUpdateOperationData(ISpaceProxy spaceProxy, IEntryPacket entryPacket)

Method Summary

Modifier and Type	Method and Description
DataSyncOperationType	getDataSyncOperationType()
DataConflictOperation.OperationType	getOperationType()
protected int	getOverrideUpdateModifiers()
protected int	getUpdateModifiersImpl()
protected boolean	isConflictError(Throwable error)
boolean	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, supportsOverride

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

LocalClusterUpdateOperationData

public LocalClusterUpdateOperationData(ISpaceProxy spaceProxy,
                                       IEntryPacket entryPacket)

Method Detail

getUpdateModifiersImpl

protected int getUpdateModifiersImpl()

Specified by:

getUpdateModifiersImpl in class AbstractLocalClusterWriteOperationData

supportsBatching

public boolean supportsBatching()

Specified by:

supportsBatching in class AbstractLocalClusterOperationData

Returns:

true if the operation supports batching.

isConflictError

protected boolean isConflictError(Throwable error)

Specified by:

isConflictError in class AbstractLocalClusterWriteOperationData

getOperationType

public DataConflictOperation.OperationType getOperationType()

Returns:

The operation type.

getDataSyncOperationType

public DataSyncOperationType getDataSyncOperationType()

Returns:

the operation type.

getOverrideUpdateModifiers

protected int getOverrideUpdateModifiers()

Specified by:

getOverrideUpdateModifiers in class AbstractLocalClusterWriteOperationData