Package com.gigaspaces.internal.cluster.node.impl.backlog.multibucketsinglefile

Class DeletedMultiBucketOrderedPacket

java.lang.Object

com.gigaspaces.internal.cluster.node.impl.backlog.multibucketsinglefile.AbstractMultiBucketOrderedPacket

com.gigaspaces.internal.cluster.node.impl.backlog.multibucketsinglefile.DeletedMultiBucketOrderedPacket

All Implemented Interfaces:

IMultiBucketSingleFileReplicationOrderedPacket, IReplicationOrderedPacket, ISwapExternalizable, SmartExternalizable, Externalizable, Serializable, Cloneable

public class DeletedMultiBucketOrderedPacket
extends AbstractMultiBucketOrderedPacket

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
DeletedMultiBucketOrderedPacket()
DeletedMultiBucketOrderedPacket(long startGlobalKey, long endGlobalKey, ShortObjectMap<BucketKey> bucketsStartKeys, ShortLongMap bucketEndKeys)

Method Summary

Modifier and Type	Method	Description
DeletedMultiBucketOrderedPacket	clone()
IMultiBucketSingleFileReplicationOrderedPacket	cloneWithNewData(IReplicationPacketData<?> newData)	Clones the packet replacing its data with the new data
long	getBucketEndKey(short bucketIndex)
PacketConsumeState	getConsumeState(short bucketIndex)
IReplicationPacketData<?>	getData()
long	getEndKey()	return the last key for given packets - relevant to range packets - merged discarded/deleted packets
boolean	isDataPacket()
boolean	isDiscardedPacket()
MultiBucketSingleFileProcessResult	process(String sourceLookupName, IMultiBucketSingleFileProcessLog processLog, IReplicationInFilterCallback inFilterCallback, ParallelBatchProcessingContext context, int segmentIndex)
long	processResult(String memberName, MultiBucketSingleFileProcessResult processResult, MultiBucketSingleFileConfirmationHolder confirmationHolder)
void	readExternal(ObjectInput in)
void	readFromSwap(ObjectInput in)
void	reliableAsyncKeysUpdate(long[] bucketLastKeys, MultiBucketSingleFileConfirmationHolder confirmationHolder)
IMultiBucketSingleFileReplicationOrderedPacket	replaceWithDiscarded()
boolean	setConsumed()
void	writeExternal(ObjectOutput out)
void	writeToSwap(ObjectOutput out)

Methods inherited from class com.gigaspaces.internal.cluster.node.impl.backlog.multibucketsinglefile.AbstractMultiBucketOrderedPacket

associateToBuckets, bucketCount, equals, getBucketKey, getBuckets, getBucketsKeys, getKey, getReliableAsyncBeforeFilterPacket, getWeight, hashCode, readBucketKeys, setReliableAsyncBeforeFilterPacket, toString, writeBucketKeys

Methods inherited from class java.lang.Object

finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface com.gigaspaces.serialization.SmartExternalizable

enabledSmartExternalizableWithReference

Constructor Details

DeletedMultiBucketOrderedPacket

public DeletedMultiBucketOrderedPacket()

DeletedMultiBucketOrderedPacket

public DeletedMultiBucketOrderedPacket(long startGlobalKey,
 long endGlobalKey,
 ShortObjectMap<BucketKey> bucketsStartKeys,
 ShortLongMap bucketEndKeys)

Method Details

writeExternal

public void writeExternal(ObjectOutput out)
                   throws IOException

Specified by:

writeExternal in interface Externalizable

Overrides:

writeExternal in class AbstractMultiBucketOrderedPacket

Throws:

IOException

writeToSwap

public void writeToSwap(ObjectOutput out)
                 throws IOException

Specified by:

writeToSwap in interface ISwapExternalizable

Overrides:

writeToSwap in class AbstractMultiBucketOrderedPacket

Throws:

IOException

readExternal

public void readExternal(ObjectInput in)
                  throws IOException,
ClassNotFoundException

Specified by:

readExternal in interface Externalizable

Overrides:

readExternal in class AbstractMultiBucketOrderedPacket

Throws:

IOException

ClassNotFoundException

readFromSwap

public void readFromSwap(ObjectInput in)
                  throws IOException,
ClassNotFoundException

Specified by:

readFromSwap in interface ISwapExternalizable

Overrides:

readFromSwap in class AbstractMultiBucketOrderedPacket

Throws:

IOException

ClassNotFoundException

getData

public IReplicationPacketData<?> getData()

Returns:

the actual packet data that is needed for the processing

getEndKey

public long getEndKey()

Description copied from interface: IReplicationOrderedPacket

return the last key for given packets - relevant to range packets - merged discarded/deleted packets

Specified by:

getEndKey in interface IReplicationOrderedPacket

Overrides:

getEndKey in class AbstractMultiBucketOrderedPacket

getBucketEndKey

public long getBucketEndKey(short bucketIndex)

isDataPacket

public boolean isDataPacket()

isDiscardedPacket

public boolean isDiscardedPacket()

clone

public DeletedMultiBucketOrderedPacket clone()

Specified by:

clone in interface IMultiBucketSingleFileReplicationOrderedPacket

Specified by:

clone in interface IReplicationOrderedPacket

Specified by:

clone in class AbstractMultiBucketOrderedPacket

cloneWithNewData

public IMultiBucketSingleFileReplicationOrderedPacket cloneWithNewData(IReplicationPacketData<?> newData)

Description copied from interface: IReplicationOrderedPacket

Clones the packet replacing its data with the new data

process

public MultiBucketSingleFileProcessResult process(String sourceLookupName,
 IMultiBucketSingleFileProcessLog processLog,
 IReplicationInFilterCallback inFilterCallback,
 ParallelBatchProcessingContext context,
 int segmentIndex)

processResult

public long processResult(String memberName,
 MultiBucketSingleFileProcessResult processResult,
 MultiBucketSingleFileConfirmationHolder confirmationHolder)

Specified by:

processResult in interface IMultiBucketSingleFileReplicationOrderedPacket

Overrides:

processResult in class AbstractMultiBucketOrderedPacket

reliableAsyncKeysUpdate

public void reliableAsyncKeysUpdate(long[] bucketLastKeys,
 MultiBucketSingleFileConfirmationHolder confirmationHolder)

Specified by:

reliableAsyncKeysUpdate in interface IMultiBucketSingleFileReplicationOrderedPacket

Overrides:

reliableAsyncKeysUpdate in class AbstractMultiBucketOrderedPacket

getConsumeState

public PacketConsumeState getConsumeState(short bucketIndex)

setConsumed

public boolean setConsumed()

replaceWithDiscarded

public IMultiBucketSingleFileReplicationOrderedPacket replaceWithDiscarded()