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

Class LocalClusterWriteOperationData

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.LocalClusterWriteOperationData

All Implemented Interfaces:

DataConflictOperation, DataSyncOperation

public class LocalClusterWriteOperationData
extends AbstractLocalClusterWriteOperationData

Operation executor for write 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
LocalClusterWriteOperationData(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

LocalClusterWriteOperationData

public LocalClusterWriteOperationData(ISpaceProxy spaceProxy,
                                      IEntryPacket entryPacket)

Method Detail

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

getUpdateModifiersImpl

protected int getUpdateModifiersImpl()

Specified by:

getUpdateModifiersImpl 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