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

Class LocalClusterRemoveOperationData

java.lang.Object

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

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

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

All Implemented Interfaces:

DataConflictOperation, DataSyncOperation

public class LocalClusterRemoveOperationData
extends LocalClusterRemoveByUIDOperationData

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:

9.0.1

Author:

eitany

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

Method Summary

Modifier and Type	Method	Description
SpaceDocument	getDataAsDocument()
Object	getDataAsObject()
DataSyncOperationType	getDataSyncOperationType()
Object	getOperationEntry()
DataConflictOperation.OperationType	getOperationType()
Object	getSpaceId()
boolean	supportsDataAsDocument()
boolean	supportsDataAsObject()
boolean	supportsGetSpaceId()

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

execute, getUid, isSameOperationType, supportsBatching, 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 Details

LocalClusterRemoveOperationData

public LocalClusterRemoveOperationData(ISpaceProxy spaceProxy,
 IEntryPacket entryPacket)

Method Details

getOperationType

public DataConflictOperation.OperationType getOperationType()

Specified by:

getOperationType in interface DataConflictOperation

Overrides:

getOperationType in class LocalClusterRemoveByUIDOperationData

Returns:

The operation type.

getDataSyncOperationType

public DataSyncOperationType getDataSyncOperationType()

Specified by:

getDataSyncOperationType in interface DataSyncOperation

Overrides:

getDataSyncOperationType in class LocalClusterRemoveByUIDOperationData

Returns:

the operation type.

getOperationEntry

public Object getOperationEntry()

Specified by:

getOperationEntry in interface DataConflictOperation

Overrides:

getOperationEntry in class LocalClusterRemoveByUIDOperationData

Returns:

The user entry the operation had a conflict for.

supportsDataAsDocument

public boolean supportsDataAsDocument()

Specified by:

supportsDataAsDocument in interface DataSyncOperation

Overrides:

supportsDataAsDocument in class LocalClusterRemoveByUIDOperationData

Returns:

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

getDataAsDocument

public SpaceDocument getDataAsDocument()

Specified by:

getDataAsDocument in interface DataSyncOperation

Overrides:

getDataAsDocument in class LocalClusterRemoveByUIDOperationData

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()

Specified by:

supportsDataAsObject in interface DataSyncOperation

Overrides:

supportsDataAsObject in class LocalClusterRemoveByUIDOperationData

Returns:

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

getDataAsObject

public Object getDataAsObject()

Specified by:

getDataAsObject in interface DataSyncOperation

Overrides:

getDataAsObject in class LocalClusterRemoveByUIDOperationData

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()

Specified by:

supportsGetSpaceId in interface DataSyncOperation

Overrides:

supportsGetSpaceId in class LocalClusterRemoveByUIDOperationData

Returns:

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

getSpaceId

public Object getSpaceId()

Specified by:

getSpaceId in interface DataSyncOperation

Overrides:

getSpaceId in class LocalClusterRemoveByUIDOperationData

Returns:

The operation's data Id.