com.gigaspaces.internal.sync.mirror

Class MirrorChangeBulkDataItem

java.lang.Object

com.gigaspaces.internal.sync.mirror.MirrorChangeBulkDataItem

All Implemented Interfaces:

BulkItem, DataSyncChangeSet, DataSyncOperation, InternalBulkItem

public class MirrorChangeBulkDataItem
extends Object
implements InternalBulkItem, DataSyncChangeSet

Wraps a change operation as bulk item

Since:

9.5

Author:

eitany

Field Summary

Fields inherited from interface com.gigaspaces.datasource.BulkItem

CHANGE, PARTIAL_UPDATE, REMOVE, UPDATE, WRITE

Constructor Summary

Constructors

Constructor and Description
MirrorChangeBulkDataItem(ITypeDesc typeDesc, String uid, Object id, int version, long timeToLive, Collection<SpaceEntryMutator> mutators)

Method Summary

Modifier and Type	Method and Description
SpaceDocument	getDataAsDocument()
Object	getDataAsObject()
DataSyncOperationType	getDataSyncOperationType()
Object	getId()
String	getIdPropertyName()
Object	getIdPropertyValue()
Object	getItem() Return the data item
Map<String,Object>	getItemValues()
short	getOperation() Return the operation to execute
Collection<ChangeOperation>	getOperations()
Object	getSpaceId()
long	getTimeToLive()
SpaceTypeDescriptor	getTypeDescriptor()
String	getTypeName()
String	getUid()
int	getVersion()
void	setConverter(IDataConverter<IEntryPacket> converter)
boolean	supportsDataAsDocument()
boolean	supportsDataAsObject()
boolean	supportsGetSpaceId()
boolean	supportsGetTypeDescriptor()
IEntryPacket	toEntryPacket()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

MirrorChangeBulkDataItem

public MirrorChangeBulkDataItem(ITypeDesc typeDesc,
                                String uid,
                                Object id,
                                int version,
                                long timeToLive,
                                Collection<SpaceEntryMutator> mutators)

Method Detail

getItem

public Object getItem()

Description copied from interface: BulkItem

Return the data item

Specified by:

getItem in interface BulkItem

Returns:

data item

getOperation

public short getOperation()

Description copied from interface: BulkItem

Return the operation to execute

Specified by:

getOperation in interface BulkItem

Returns:

operation type BulkItem.REMOVE/BulkItem.UPDATE/BulkItem.WRITE/BulkItem.PARTIAL_UPDATE

getTypeName

public String getTypeName()

Specified by:

getTypeName in interface BulkItem

Returns:

the name of the type/class

getIdPropertyName

public String getIdPropertyName()

Specified by:

getIdPropertyName in interface BulkItem

Returns:

the name of the id property

getIdPropertyValue

public Object getIdPropertyValue()

Specified by:

getIdPropertyValue in interface BulkItem

Returns:

the value of the id property

getItemValues

public Map<String,Object> getItemValues()

Specified by:

getItemValues in interface BulkItem

Returns:

a map of the object properties. The keys are the names of the properties and their values is the object values. In case of a partial update - only the updated values are returned.s

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.

getTypeDescriptor

public SpaceTypeDescriptor getTypeDescriptor()

Specified by:

getTypeDescriptor in interface DataSyncOperation

Returns:

the type descriptor of the data type. this can only be used if DataSyncOperation.supportsGetTypeDescriptor() return true, otherwise an exception will be thrown.

supportsGetTypeDescriptor

public boolean supportsGetTypeDescriptor()

Specified by:

supportsGetTypeDescriptor in interface DataSyncOperation

Returns:

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

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.

setConverter

public void setConverter(IDataConverter<IEntryPacket> converter)

Specified by:

setConverter in interface InternalBulkItem

toEntryPacket

public IEntryPacket toEntryPacket()

Specified by:

toEntryPacket in interface InternalBulkItem

getOperations

public Collection<ChangeOperation> 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.

toString

public String toString()

Overrides:

toString in class Object