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

Class LocalClusterChangeOperationData

java.lang.Object

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

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

All Implemented Interfaces:

DataConflictOperation, DataSyncChangeSet, DataSyncOperation

public class LocalClusterChangeOperationData
extends AbstractLocalClusterOperationData
implements DataSyncChangeSet

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
LocalClusterChangeOperationData(ISpaceProxy spaceProxy, ITypeDesc typeDescriptor, String uid, Object id, int version, int previousVersion, int routingHash, long timeToLive, Collection<SpaceEntryMutator> mutators)

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	getId()
Object	getOperationEntry() Deprecated.
Collection	getOperations()
DataConflictOperation.OperationType	getOperationType() Deprecated.
Object	getSpaceId()
long	getTimeToLive()
String	getUid()
int	getVersion()
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, isSameOperationType, 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

LocalClusterChangeOperationData

public LocalClusterChangeOperationData(ISpaceProxy spaceProxy,
                                       ITypeDesc typeDescriptor,
                                       String uid,
                                       Object id,
                                       int version,
                                       int previousVersion,
                                       int routingHash,
                                       long timeToLive,
                                       Collection<SpaceEntryMutator> mutators)

Method Detail

getOperationType

@Deprecated
public DataConflictOperation.OperationType getOperationType()

Deprecated.

Specified by:

getOperationType in interface DataConflictOperation

Returns:

The operation type.

getOperationEntry

@Deprecated
public Object getOperationEntry()

Deprecated.

Specified by:

getOperationEntry in interface DataConflictOperation

Returns:

The user entry the operation had a conflict for.

supportsOverride

public boolean supportsOverride()

Specified by:

supportsOverride in interface DataConflictOperation

Returns:

true if overriding the operation is supported, otherwise false.

getUid

public String getUid()

Specified by:

getUid in interface DataSyncOperation

Returns:

The operation's data UID.

getDataSyncOperationType

public DataSyncOperationType getDataSyncOperationType()

Specified by:

getDataSyncOperationType in interface DataSyncOperation

Returns:

the operation type.

getDataAsObject

public Object getDataAsObject()

Specified by:

getDataAsObject in interface DataSyncOperation

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.

getDataAsDocument

public SpaceDocument getDataAsDocument()

Specified by:

getDataAsDocument in interface DataSyncOperation

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

Returns:

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

supportsDataAsDocument

public boolean supportsDataAsDocument()

Specified by:

supportsDataAsDocument in interface DataSyncOperation

Returns:

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

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

supportsBatching

public boolean supportsBatching()

Specified by:

supportsBatching in class AbstractLocalClusterOperationData

Returns:

true if the operation supports batching.

getOperations

public Collection getOperations()

Specified by:

getOperations in interface DataSyncChangeSet

Returns:

the change operations.

getId

public Object getId()

Specified by:

getId in interface DataSyncChangeSet

Returns:

the id of the object which was changed.

getVersion

public int getVersion()

Specified by:

getVersion in interface DataSyncChangeSet

Returns:

the version of the object after the change was applied.

getTimeToLive

public long getTimeToLive()

Specified by:

getTimeToLive in interface DataSyncChangeSet

Returns:

the remaining time to live of the object after the change was applied.

supportsGetSpaceId

public boolean supportsGetSpaceId()

Specified by:

supportsGetSpaceId in interface DataSyncOperation

Returns:

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

getSpaceId

public Object getSpaceId()

Specified by:

getSpaceId in interface DataSyncOperation

Returns:

The operation's data Id.