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

Class LocalClusterRemoveByUIDOperationData

java.lang.Object

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

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

All Implemented Interfaces:

DataConflictOperation, DataSyncOperation

Direct Known Subclasses:

LocalClusterRemoveOperationData

public class LocalClusterRemoveByUIDOperationData
extends AbstractLocalClusterOperationData

Operation executer for a remove replication sink gateway operation against a local cluster. The remove operation is made by using the removed entries Uids.

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
LocalClusterRemoveByUIDOperationData(ISpaceProxy spaceProxy, String uid, ITypeDesc typeDescriptor)

Method Summary

Modifier and Type	Method and Description
boolean	execute(Transaction transaction) Executes the operation against the provided ISpaceProxy with the provided Transaction instance.
SpaceDocument	getDataAsDocument()
Object	getDataAsObject()
DataSyncOperationType	getDataSyncOperationType()
Object	getOperationEntry()
DataConflictOperation.OperationType	getOperationType()
Object	getSpaceId()
String	getUid()
boolean	isSameOperationType(AbstractLocalClusterOperationData operationData)
boolean	supportsBatching()
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, isOverriden, isRetryable, override, overrideImpl, reset, setConflictCause, supportsAbort, supportsGetTypeDescriptor, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

LocalClusterRemoveByUIDOperationData

public LocalClusterRemoveByUIDOperationData(ISpaceProxy spaceProxy,
                                            String uid,
                                            ITypeDesc typeDescriptor)

Method Detail

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

isSameOperationType

public boolean isSameOperationType(AbstractLocalClusterOperationData operationData)

Overrides:

isSameOperationType in class AbstractLocalClusterOperationData

Returns:

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

supportsBatching

public boolean supportsBatching()

Specified by:

supportsBatching in class AbstractLocalClusterOperationData

Returns:

true if the operation supports batching.

getOperationType

public DataConflictOperation.OperationType getOperationType()

Returns:

The operation type.

getDataSyncOperationType

public DataSyncOperationType getDataSyncOperationType()

Returns:

the operation type.

getOperationEntry

public Object getOperationEntry()

Returns:

The user entry the operation had a conflict for.

getUid

public String getUid()

Returns:

The operation's data UID.

supportsOverride

public boolean supportsOverride()

Returns:

true if overriding the operation is supported, otherwise false.

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.