com.gigaspaces.internal.cluster.node.impl.packets.data.operations

Class AbstractReplicationPacketSingleEntryData

java.lang.Object

com.gigaspaces.internal.cluster.node.impl.packets.data.operations.AbstractReplicationPacketSingleEntryData

All Implemented Interfaces:

IExecutableReplicationPacketData<IReplicationPacketEntryData>, IReplicationPacketData<IReplicationPacketEntryData>, IReplicationPacketEntryData, ISwapExternalizable, Externalizable, Serializable, Cloneable, Iterable<IReplicationPacketEntryData>, Collection<IReplicationPacketEntryData>

Direct Known Subclasses:

DataTypeAddIndexPacketData, DataTypeIntroducePacketData, DiscardReplicationPacketData, SingleReplicationPacketData, SingleUidReplicationPacketData

public abstract class AbstractReplicationPacketSingleEntryData
extends Object
implements IExecutableReplicationPacketData<IReplicationPacketEntryData>, IReplicationPacketEntryData

A base class for IReplicationPacketData implementations that contains only one IReplicationPacketEntryData

Since:

8.0

Author:

eitany

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	AbstractReplicationPacketSingleEntryData.SingleEntryIterator
static class	AbstractReplicationPacketSingleEntryData.SingleFilterIterable

Constructor Summary

Constructors

Constructor and Description
AbstractReplicationPacketSingleEntryData()
AbstractReplicationPacketSingleEntryData(boolean fromGateway)

Method Summary

Modifier and Type	Method and Description
boolean	add(IReplicationPacketEntryData o)
boolean	addAll(Collection<? extends IReplicationPacketEntryData> c)
void	clear()
AbstractReplicationPacketSingleEntryData	clone()
boolean	contains(Object o)
boolean	containsAll(Collection<?> c)
IExecutableReplicationPacketData<IReplicationPacketEntryData>	createEmptyMultipleEntryData()
protected IEntryData	deserializeEntryData(ObjectInput in)
int	getBlobstoreBulkId()
Object	getCustomContent()
abstract IEntryData	getMainEntryData()
String	getMainTypeName()
ReplicationMultipleOperationType	getMultipleOperationType()
OperationID	getOperationId()
Object	getRecoveryFilteringId()
abstract IEntryData	getSecondaryEntryData()
IReplicationPacketEntryData	getSingleEntryData()
boolean	isEmpty()
boolean	isFromGateway()
boolean	isMultiParticipantData() Gets whether this data is part of multiple participants data
boolean	isPartOfBlobstoreBulk()
boolean	isSingleEntryData()
Iterator<IReplicationPacketEntryData>	iterator()
void	readExternal(ObjectInput in)
void	readFromSwap(ObjectInput in)
boolean	remove(Object o)
boolean	removeAll(Collection<?> c)
boolean	requiresRecoveryDuplicationProtection()
boolean	requiresRecoveryFiltering()
boolean	retainAll(Collection<?> c)
protected void	serializeEntryData(IEntryData entryData, ObjectOutput out)
void	setBlobstoreBulkId(int blobStoreBulkReplicationId)
int	size()
boolean	supportsReplicationFilter()
Object[]	toArray()
<T> T[]	toArray(T[] a)
Iterable<IReplicationFilterEntry>	toFilterEntries(SpaceTypeManager spaceTypeManager)
protected abstract IReplicationFilterEntry	toFilterEntry(SpaceTypeManager spaceTypeManager)
long	updateTimeToLiveIfNeeded(long expirationTime, long currentTimeToLive)
void	writeExternal(ObjectOutput out)
void	writeToSwap(ObjectOutput out)

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.gigaspaces.internal.cluster.node.impl.packets.data.IExecutableReplicationPacketData

execute

Methods inherited from interface com.gigaspaces.internal.cluster.node.impl.packets.data.IReplicationPacketData

beforeDelayedReplication

Methods inherited from interface java.util.Collection

equals, hashCode, parallelStream, removeIf, spliterator, stream

Methods inherited from interface java.lang.Iterable

forEach

Methods inherited from interface com.gigaspaces.internal.cluster.node.impl.packets.data.IReplicationPacketEntryData

containsFullEntryData, filterIfNotPresentInReplicaState, getOperationType, getOrderCode, getUid, isTransient

Constructor Detail

AbstractReplicationPacketSingleEntryData

public AbstractReplicationPacketSingleEntryData()

AbstractReplicationPacketSingleEntryData

public AbstractReplicationPacketSingleEntryData(boolean fromGateway)

Method Detail

isPartOfBlobstoreBulk

public boolean isPartOfBlobstoreBulk()

Specified by:

isPartOfBlobstoreBulk in interface IExecutableReplicationPacketData<IReplicationPacketEntryData>

setBlobstoreBulkId

public void setBlobstoreBulkId(int blobStoreBulkReplicationId)

getBlobstoreBulkId

public int getBlobstoreBulkId()

isFromGateway

public boolean isFromGateway()

Specified by:

isFromGateway in interface IReplicationPacketData<IReplicationPacketEntryData>

Specified by:

isFromGateway in interface IReplicationPacketEntryData

Returns:

Gets whether this packet was received from gateway replication

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

isSingleEntryData

public boolean isSingleEntryData()

Specified by:

isSingleEntryData in interface IReplicationPacketData<IReplicationPacketEntryData>

getSingleEntryData

public IReplicationPacketEntryData getSingleEntryData()

Specified by:

getSingleEntryData in interface IReplicationPacketData<IReplicationPacketEntryData>

add

public boolean add(IReplicationPacketEntryData o)

Specified by:

add in interface Collection<IReplicationPacketEntryData>

addAll

public boolean addAll(Collection<? extends IReplicationPacketEntryData> c)

Specified by:

addAll in interface Collection<IReplicationPacketEntryData>

clear

public void clear()

Specified by:

clear in interface Collection<IReplicationPacketEntryData>

contains

public boolean contains(Object o)

Specified by:

contains in interface Collection<IReplicationPacketEntryData>

containsAll

public boolean containsAll(Collection<?> c)

Specified by:

containsAll in interface Collection<IReplicationPacketEntryData>

isEmpty

public boolean isEmpty()

Specified by:

isEmpty in interface Collection<IReplicationPacketEntryData>

iterator

public Iterator<IReplicationPacketEntryData> iterator()

Specified by:

iterator in interface Iterable<IReplicationPacketEntryData>

Specified by:

iterator in interface Collection<IReplicationPacketEntryData>

remove

public boolean remove(Object o)

Specified by:

remove in interface Collection<IReplicationPacketEntryData>

removeAll

public boolean removeAll(Collection<?> c)

Specified by:

removeAll in interface Collection<IReplicationPacketEntryData>

retainAll

public boolean retainAll(Collection<?> c)

Specified by:

retainAll in interface Collection<IReplicationPacketEntryData>

size

public int size()

Specified by:

size in interface Collection<IReplicationPacketEntryData>

toArray

public Object[] toArray()

Specified by:

toArray in interface Collection<IReplicationPacketEntryData>

toArray

public <T> T[] toArray(T[] a)

Specified by:

toArray in interface Collection<IReplicationPacketEntryData>

clone

public AbstractReplicationPacketSingleEntryData clone()

Specified by:

clone in interface IReplicationPacketData<IReplicationPacketEntryData>

Overrides:

clone in class Object

supportsReplicationFilter

public boolean supportsReplicationFilter()

Specified by:

supportsReplicationFilter in interface IReplicationPacketData<IReplicationPacketEntryData>

requiresRecoveryDuplicationProtection

public boolean requiresRecoveryDuplicationProtection()

Specified by:

requiresRecoveryDuplicationProtection in interface IReplicationPacketEntryData

requiresRecoveryFiltering

public boolean requiresRecoveryFiltering()

Specified by:

requiresRecoveryFiltering in interface IReplicationPacketData<IReplicationPacketEntryData>

toFilterEntries

public Iterable<IReplicationFilterEntry> toFilterEntries(SpaceTypeManager spaceTypeManager)

Specified by:

toFilterEntries in interface IExecutableReplicationPacketData<IReplicationPacketEntryData>

toFilterEntry

protected abstract IReplicationFilterEntry toFilterEntry(SpaceTypeManager spaceTypeManager)

getMainEntryData

public abstract IEntryData getMainEntryData()

getSecondaryEntryData

public abstract IEntryData getSecondaryEntryData()

getMainTypeName

public String getMainTypeName()

createEmptyMultipleEntryData

public IExecutableReplicationPacketData<IReplicationPacketEntryData> createEmptyMultipleEntryData()

Specified by:

createEmptyMultipleEntryData in interface IExecutableReplicationPacketData<IReplicationPacketEntryData>

getOperationId

public OperationID getOperationId()

Specified by:

getOperationId in interface IReplicationPacketEntryData

isMultiParticipantData

public boolean isMultiParticipantData()

Description copied from interface: IReplicationPacketData

Gets whether this data is part of multiple participants data

Specified by:

isMultiParticipantData in interface IReplicationPacketData<IReplicationPacketEntryData>

getMultipleOperationType

public ReplicationMultipleOperationType getMultipleOperationType()

Specified by:

getMultipleOperationType in interface IReplicationPacketData<IReplicationPacketEntryData>

getRecoveryFilteringId

public Object getRecoveryFilteringId()

Specified by:

getRecoveryFilteringId in interface IReplicationPacketData<IReplicationPacketEntryData>

getCustomContent

public Object getCustomContent()

updateTimeToLiveIfNeeded

public long updateTimeToLiveIfNeeded(long expirationTime,
                                     long currentTimeToLive)

serializeEntryData

protected void serializeEntryData(IEntryData entryData,
                                  ObjectOutput out)
                           throws IOException

Throws:

IOException

deserializeEntryData

protected IEntryData deserializeEntryData(ObjectInput in)
                                   throws IOException,
                                          ClassNotFoundException

Throws:

IOException

ClassNotFoundException