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

Class AbstractLocalClusterWriteOperationData

java.lang.Object

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

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

All Implemented Interfaces:

DataConflictOperation, DataSyncOperation

Direct Known Subclasses:

LocalClusterUpdateOperationData, LocalClusterWriteOperationData

public abstract class AbstractLocalClusterWriteOperationData
extends AbstractLocalClusterOperationData

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	Description
AbstractLocalClusterWriteOperationData(ISpaceProxy spaceProxy, IEntryPacket entryPacket)

Method Summary

Modifier and Type	Method	Description
boolean	execute(Transaction transaction)	Executes the operation against the provided ISpaceProxy with the provided Transaction instance.
SpaceDocument	getDataAsDocument()
Object	getDataAsObject()
Object	getOperationEntry()
protected abstract int	getOverrideUpdateModifiers()
Object	getSpaceId()
String	getUid()
protected abstract int	getUpdateModifiersImpl()
protected abstract boolean	isConflictError(Throwable error)
protected boolean	isOverriden()
boolean	isSameOperationType(AbstractLocalClusterOperationData operationData)
protected void	overrideImpl()
void	setConflictCause(ConflictCause conflictCause)
boolean	supportsDataAsDocument()
boolean	supportsDataAsObject()
boolean	supportsGetSpaceId()
boolean	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, supportsBatching, supportsGetTypeDescriptor, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.gigaspaces.cluster.replication.gateway.conflict.DataConflictOperation

getOperationType

Methods inherited from interface com.gigaspaces.sync.DataSyncOperation

getDataSyncOperationType

Constructor Details

AbstractLocalClusterWriteOperationData

public AbstractLocalClusterWriteOperationData(ISpaceProxy spaceProxy,
 IEntryPacket entryPacket)

Method Details

execute

public boolean execute(Transaction transaction)
                throws Exception

Description copied from class: AbstractLocalClusterOperationData

Executes the operation against the provided ISpaceProxy with the provided Transaction instance.

Specified by:

execute in class AbstractLocalClusterOperationData

Parameters:

transaction - The Transaction to with the operations.

Throws:

Exception

supportsOverride

public boolean supportsOverride()

Returns:

true if overriding the operation is supported, otherwise false.

overrideImpl

protected void overrideImpl()

Overrides:

overrideImpl in class AbstractLocalClusterOperationData

isSameOperationType

public boolean isSameOperationType(AbstractLocalClusterOperationData operationData)

Overrides:

isSameOperationType in class AbstractLocalClusterOperationData

Returns:

true if the provided AbstractLocalClusterOperationData is of the same class type.

isConflictError

protected abstract boolean isConflictError(Throwable error)

getOverrideUpdateModifiers

protected abstract int getOverrideUpdateModifiers()

getUpdateModifiersImpl

protected abstract int getUpdateModifiersImpl()

getOperationEntry

public Object getOperationEntry()

Returns:

The user entry the operation had a conflict for.

getUid

public String getUid()

Returns:

The operation's data UID.

isOverriden

protected boolean isOverriden()

Overrides:

isOverriden in class AbstractLocalClusterOperationData

setConflictCause

public void setConflictCause(ConflictCause conflictCause)

Overrides:

setConflictCause in class AbstractLocalClusterOperationData

supportsDataAsDocument

public boolean supportsDataAsDocument()

Returns:

whether this data operation support the DataSyncOperation.getDataAsDocument() operation.

getDataAsDocument

public SpaceDocument getDataAsDocument()

Returns:

the operation data as space document, this can only be used if DataSyncOperation.supportsDataAsDocument() return true, otherwise an exception will be thrown.

supportsDataAsObject

public boolean supportsDataAsObject()

Returns:

whether this data operation support the DataSyncOperation.getDataAsObject() operation.

getDataAsObject

public Object getDataAsObject()

Returns:

the operation data as object (i.e pojo), this can only be used if DataSyncOperation.supportsDataAsObject() return true, otherwise an exception will be thrown.

supportsGetSpaceId

public boolean supportsGetSpaceId()

Returns:

whether this data operation support the DataSyncOperation.getSpaceId() operation.

getSpaceId

public Object getSpaceId()

Returns:

The operation's data Id.