Package com.gigaspaces.internal.transport.mvcc

Class MVCCShellEntryPacket

java.lang.Object

com.gigaspaces.internal.transport.mvcc.MVCCShellEntryPacket

All Implemented Interfaces:

RawEntry, ISwapExternalizable, IEntryPacket, ITransportPacket, SmartExternalizable, Externalizable, Serializable, Cloneable

public class MVCCShellEntryPacket
extends Object
implements IEntryPacket

MVCC shell entry packet, built from MVCCShellEntryCacheInfo, is intended for space recovery with enabled mvcc. EntryPackets list has same ascending order as in the shell. Each entryPacket in the list is built from corresponded eHolder in the shell and has to be instanceof IMVCCEntryPacket (keep mvcc entry metadata)

Since:

16.4.0

Author:

Davyd Savitskyi

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
MVCCShellEntryPacket()
MVCCShellEntryPacket(MVCCShellEntryCacheInfo pEntryShell)

Method Summary

Modifier and Type	Method	Description
void	addEntryVersionPacket(IMVCCEntryPacket packet)
IEntryPacket	clone()
String	getCodebase()
ICustomQuery	getCustomQuery()
Map<String,Object>	getDynamicProperties()
EntryType	getEntryType()
List<IMVCCEntryPacket>	getEntryVersionsPackets()
String	getExternalEntryImplClassName()
Object	getFieldValue(int index)
Object[]	getFieldValues()
Object	getID()
String[]	getMultipleUIDs()
OperationID	getOperationID()
TransportPacketType	getPacketType()
int	getPreviousVersion()	Gets the entry's previous version in space before update
Object	getPropertyValue(String name)
Object	getRoutingFieldValue()
long	getTTL()
int	getTypeDescChecksum()
ITypeDesc	getTypeDescriptor()
String	getTypeName()
String	getUID()
int	getVersion()
boolean	hasFixedPropertiesArray()	true if the entry packet has an array of fixed properties
boolean	hasPreviousVersion()	Gets whether this packet has a previous version set.
boolean	isExternalizableEntryPacket()
boolean	isFifo()
boolean	isNoWriteLease()
boolean	isSerializeTypeDesc()
boolean	isTransient()
void	readExternal(ObjectInput in)
void	readFromSwap(ObjectInput in)
void	setCustomQuery(ICustomQuery customQuery)
void	setDynamicProperties(Map<String,Object> properties)
void	setFieldsValues(Object[] values)
void	setFieldValue(int index, Object value)
void	setMultipleUIDs(String[] uids)
void	setOperationID(OperationID operationID)
void	setPreviousVersion(int version)	Sets the entry's previous version in space before update, relevant for replication update operation
void	setPropertyValue(String name, Object value)
void	setSerializeTypeDesc(boolean serializeTypeDesc)
void	setTTL(long ttl)
void	setTypeDesc(ITypeDesc typeDesc, boolean serializeTypeDesc)
void	setUID(String uid)
void	setVersion(int version)
boolean	supportsTypeDescChecksum()
Object	toObject(QueryResultTypeInternal resultType)
Object	toObject(QueryResultTypeInternal resultType, StorageTypeDeserialization storageTypeDeserialization)
Object	toObject(EntryType entryType)
Object	toObject(EntryType entryType, StorageTypeDeserialization storageTypeDeserialization)
String	toString()
void	writeExternal(ObjectOutput out)
void	writeToSwap(ObjectOutput out)

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.gigaspaces.internal.transport.IEntryPacket

allNullFieldValues, isHybrid

Methods inherited from interface com.gigaspaces.serialization.SmartExternalizable

enabledSmartExternalizableWithReference

Constructor Details

MVCCShellEntryPacket

public MVCCShellEntryPacket()

MVCCShellEntryPacket

public MVCCShellEntryPacket(MVCCShellEntryCacheInfo pEntryShell)

Method Details

getEntryVersionsPackets

public List<IMVCCEntryPacket> getEntryVersionsPackets()

addEntryVersionPacket

public void addEntryVersionPacket(IMVCCEntryPacket packet)

setUID

public void setUID(String uid)

Specified by:

setUID in interface IEntryPacket

getID

public Object getID()

Specified by:

getID in interface IEntryPacket

getTTL

public long getTTL()

Specified by:

getTTL in interface IEntryPacket

setTTL

public void setTTL(long ttl)

Specified by:

setTTL in interface IEntryPacket

clone

public IEntryPacket clone()

Specified by:

clone in interface IEntryPacket

Overrides:

clone in class Object

setCustomQuery

public void setCustomQuery(ICustomQuery customQuery)

Specified by:

setCustomQuery in interface IEntryPacket

setPreviousVersion

public void setPreviousVersion(int version)

Description copied from interface: IEntryPacket

Sets the entry's previous version in space before update, relevant for replication update operation

Specified by:

setPreviousVersion in interface IEntryPacket

getPreviousVersion

public int getPreviousVersion()

Description copied from interface: IEntryPacket

Gets the entry's previous version in space before update

Specified by:

getPreviousVersion in interface IEntryPacket

hasPreviousVersion

public boolean hasPreviousVersion()

Description copied from interface: IEntryPacket

Gets whether this packet has a previous version set.

Specified by:

hasPreviousVersion in interface IEntryPacket

hasFixedPropertiesArray

public boolean hasFixedPropertiesArray()

Description copied from interface: IEntryPacket

true if the entry packet has an array of fixed properties

Specified by:

hasFixedPropertiesArray in interface IEntryPacket

isExternalizableEntryPacket

public boolean isExternalizableEntryPacket()

Specified by:

isExternalizableEntryPacket in interface IEntryPacket

getOperationID

public OperationID getOperationID()

Specified by:

getOperationID in interface ITransportPacket

setOperationID

public void setOperationID(OperationID operationID)

Specified by:

setOperationID in interface ITransportPacket

getEntryType

public EntryType getEntryType()

Specified by:

getEntryType in interface ITransportPacket

getPacketType

public TransportPacketType getPacketType()

Specified by:

getPacketType in interface ITransportPacket

getTypeName

public String getTypeName()

Specified by:

getTypeName in interface ITransportPacket

getCodebase

public String getCodebase()

Specified by:

getCodebase in interface ITransportPacket

getTypeDescriptor

public ITypeDesc getTypeDescriptor()

Specified by:

getTypeDescriptor in interface ITransportPacket

setTypeDesc

public void setTypeDesc(ITypeDesc typeDesc,
 boolean serializeTypeDesc)

Specified by:

setTypeDesc in interface ITransportPacket

getTypeDescChecksum

public int getTypeDescChecksum()

Specified by:

getTypeDescChecksum in interface ITransportPacket

supportsTypeDescChecksum

public boolean supportsTypeDescChecksum()

Specified by:

supportsTypeDescChecksum in interface ITransportPacket

isSerializeTypeDesc

public boolean isSerializeTypeDesc()

Specified by:

isSerializeTypeDesc in interface ITransportPacket

setSerializeTypeDesc

public void setSerializeTypeDesc(boolean serializeTypeDesc)

Specified by:

setSerializeTypeDesc in interface ITransportPacket

isFifo

public boolean isFifo()

Specified by:

isFifo in interface ITransportPacket

getVersion

public int getVersion()

Specified by:

getVersion in interface ITransportPacket

setVersion

public void setVersion(int version)

Specified by:

setVersion in interface ITransportPacket

isNoWriteLease

public boolean isNoWriteLease()

Specified by:

isNoWriteLease in interface ITransportPacket

getFieldValues

public Object[] getFieldValues()

Specified by:

getFieldValues in interface ITransportPacket

setFieldsValues

public void setFieldsValues(Object[] values)

Specified by:

setFieldsValues in interface ITransportPacket

getFieldValue

public Object getFieldValue(int index)

Specified by:

getFieldValue in interface ITransportPacket

setFieldValue

public void setFieldValue(int index,
 Object value)

Specified by:

setFieldValue in interface ITransportPacket

getPropertyValue

public Object getPropertyValue(String name)

Specified by:

getPropertyValue in interface ITransportPacket

setPropertyValue

public void setPropertyValue(String name,
 Object value)

Specified by:

setPropertyValue in interface ITransportPacket

getDynamicProperties

public Map<String,Object> getDynamicProperties()

Specified by:

getDynamicProperties in interface ITransportPacket

setDynamicProperties

public void setDynamicProperties(Map<String,Object> properties)

Specified by:

setDynamicProperties in interface ITransportPacket

getMultipleUIDs

public String[] getMultipleUIDs()

Specified by:

getMultipleUIDs in interface ITransportPacket

setMultipleUIDs

public void setMultipleUIDs(String[] uids)

Specified by:

setMultipleUIDs in interface ITransportPacket

getUID

public String getUID()

Specified by:

getUID in interface ITransportPacket

toObject

public Object toObject(QueryResultTypeInternal resultType)

Specified by:

toObject in interface ITransportPacket

toObject

public Object toObject(QueryResultTypeInternal resultType,
 StorageTypeDeserialization storageTypeDeserialization)

Specified by:

toObject in interface ITransportPacket

toObject

public Object toObject(EntryType entryType)

Specified by:

toObject in interface ITransportPacket

toObject

public Object toObject(EntryType entryType,
 StorageTypeDeserialization storageTypeDeserialization)

Specified by:

toObject in interface ITransportPacket

getExternalEntryImplClassName

public String getExternalEntryImplClassName()

Specified by:

getExternalEntryImplClassName in interface ITransportPacket

isTransient

public boolean isTransient()

Specified by:

isTransient in interface ITransportPacket

getCustomQuery

public ICustomQuery getCustomQuery()

Specified by:

getCustomQuery in interface ITransportPacket

getRoutingFieldValue

public Object getRoutingFieldValue()

Specified by:

getRoutingFieldValue in interface ITransportPacket

writeExternal

public void writeExternal(ObjectOutput out)
                   throws IOException

Specified by:

writeExternal in interface Externalizable

Throws:

IOException

readExternal

public void readExternal(ObjectInput in)
                  throws IOException,
ClassNotFoundException

Specified by:

readExternal in interface Externalizable

Throws:

IOException

ClassNotFoundException

writeToSwap

public void writeToSwap(ObjectOutput out)
                 throws IOException

Specified by:

writeToSwap in interface ISwapExternalizable

Throws:

IOException

readFromSwap

public void readFromSwap(ObjectInput in)
                  throws IOException,
ClassNotFoundException

Specified by:

readFromSwap in interface ISwapExternalizable

Throws:

IOException

ClassNotFoundException

toString

public String toString()

Overrides:

toString in class Object