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

Class MultiBucketSingleFileReliableAsyncKeptDiscardedPacket

java.lang.Object

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

All Implemented Interfaces:

IMultiBucketSingleFileReplicationOrderedPacket, IReplicationOrderedPacket, ISwapExternalizable, Externalizable, Serializable, Cloneable

public class MultiBucketSingleFileReliableAsyncKeptDiscardedPacket
extends Object
implements IMultiBucketSingleFileReplicationOrderedPacket

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
MultiBucketSingleFileReliableAsyncKeptDiscardedPacket()
MultiBucketSingleFileReliableAsyncKeptDiscardedPacket(IMultiBucketSingleFileReplicationOrderedPacket beforeFilter, IMultiBucketSingleFileReplicationOrderedPacket afterFilter)

Method Summary

Modifier and Type	Method and Description
void	associateToBuckets(ShortObjectMap<List<IMultiBucketSingleFileReplicationOrderedPacket>> bucketsPackets)
short	bucketCount()
MultiBucketSingleFileReliableAsyncKeptDiscardedPacket	clone()
MultiBucketSingleFileReliableAsyncKeptDiscardedPacket	cloneWithNewData(IReplicationPacketData<?> newData) Clones the packet replacing its data with the new data
boolean	equals(Object obj)
long	getBucketKey(short bucketIndex)
short[]	getBuckets()
PacketConsumeState	getConsumeState(short bucketIndex)
IReplicationPacketData<?>	getData()
long	getEndKey() return the last key for given packets - relevant to range packets - merged discarded/deleted packets
long	getKey()
IMultiBucketSingleFileReplicationOrderedPacket	getReliableAsyncBeforeFilterPacket()
int	hashCode()
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	setReliableAsyncBeforeFilterPacket(IMultiBucketSingleFileReplicationOrderedPacket beforeFilterPacket)
IReplicationOrderedPacket	wrapWithReliableAsyncKeptDiscardedPacket(IMultiBucketSingleFileReplicationOrderedPacket typedAfterFilter)
void	writeExternal(ObjectOutput out)
void	writeToSwap(ObjectOutput out)

Methods inherited from class java.lang.Object

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

Constructor Detail

MultiBucketSingleFileReliableAsyncKeptDiscardedPacket

public MultiBucketSingleFileReliableAsyncKeptDiscardedPacket()

MultiBucketSingleFileReliableAsyncKeptDiscardedPacket

public MultiBucketSingleFileReliableAsyncKeptDiscardedPacket(IMultiBucketSingleFileReplicationOrderedPacket beforeFilter,
                                                             IMultiBucketSingleFileReplicationOrderedPacket afterFilter)

Method Detail

process

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

Specified by:

process in interface IMultiBucketSingleFileReplicationOrderedPacket

processResult

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

Specified by:

processResult in interface IMultiBucketSingleFileReplicationOrderedPacket

getBucketKey

public long getBucketKey(short bucketIndex)

Specified by:

getBucketKey in interface IMultiBucketSingleFileReplicationOrderedPacket

getConsumeState

public PacketConsumeState getConsumeState(short bucketIndex)

Specified by:

getConsumeState in interface IMultiBucketSingleFileReplicationOrderedPacket

setConsumed

public boolean setConsumed()

Specified by:

setConsumed in interface IMultiBucketSingleFileReplicationOrderedPacket

bucketCount

public short bucketCount()

Specified by:

bucketCount in interface IMultiBucketSingleFileReplicationOrderedPacket

getBuckets

public short[] getBuckets()

Specified by:

getBuckets in interface IMultiBucketSingleFileReplicationOrderedPacket

associateToBuckets

public void associateToBuckets(ShortObjectMap<List<IMultiBucketSingleFileReplicationOrderedPacket>> bucketsPackets)

Specified by:

associateToBuckets in interface IMultiBucketSingleFileReplicationOrderedPacket

replaceWithDiscarded

public IMultiBucketSingleFileReplicationOrderedPacket replaceWithDiscarded()

Specified by:

replaceWithDiscarded in interface IMultiBucketSingleFileReplicationOrderedPacket

reliableAsyncKeysUpdate

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

Specified by:

reliableAsyncKeysUpdate in interface IMultiBucketSingleFileReplicationOrderedPacket

getReliableAsyncBeforeFilterPacket

public IMultiBucketSingleFileReplicationOrderedPacket getReliableAsyncBeforeFilterPacket()

Specified by:

getReliableAsyncBeforeFilterPacket in interface IMultiBucketSingleFileReplicationOrderedPacket

setReliableAsyncBeforeFilterPacket

public void setReliableAsyncBeforeFilterPacket(IMultiBucketSingleFileReplicationOrderedPacket beforeFilterPacket)

Specified by:

setReliableAsyncBeforeFilterPacket in interface IMultiBucketSingleFileReplicationOrderedPacket

wrapWithReliableAsyncKeptDiscardedPacket

public IReplicationOrderedPacket wrapWithReliableAsyncKeptDiscardedPacket(IMultiBucketSingleFileReplicationOrderedPacket typedAfterFilter)

getData

public IReplicationPacketData<?> getData()

Specified by:

getData in interface IReplicationOrderedPacket

Returns:

the actual packet data that is needed for the processing

getKey

public long getKey()

Specified by:

getKey in interface IReplicationOrderedPacket

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

isDataPacket

public boolean isDataPacket()

Specified by:

isDataPacket in interface IReplicationOrderedPacket

isDiscardedPacket

public boolean isDiscardedPacket()

Specified by:

isDiscardedPacket in interface IReplicationOrderedPacket

writeExternal

public void writeExternal(ObjectOutput out)
                   throws IOException

Specified by:

writeExternal in interface Externalizable

Throws:

IOException

writeToSwap

public void writeToSwap(ObjectOutput out)
                 throws IOException

Specified by:

writeToSwap in interface ISwapExternalizable

Throws:

IOException

readExternal

public void readExternal(ObjectInput in)
                  throws IOException,
                         ClassNotFoundException

Specified by:

readExternal in interface Externalizable

Throws:

IOException

ClassNotFoundException

readFromSwap

public void readFromSwap(ObjectInput in)
                  throws IOException,
                         ClassNotFoundException

Specified by:

readFromSwap in interface ISwapExternalizable

Throws:

IOException

ClassNotFoundException

clone

public MultiBucketSingleFileReliableAsyncKeptDiscardedPacket clone()

Specified by:

clone in interface IMultiBucketSingleFileReplicationOrderedPacket

Specified by:

clone in interface IReplicationOrderedPacket

Overrides:

clone in class Object

cloneWithNewData

public MultiBucketSingleFileReliableAsyncKeptDiscardedPacket cloneWithNewData(IReplicationPacketData<?> newData)

Description copied from interface: IReplicationOrderedPacket

Clones the packet replacing its data with the new data

Specified by:

cloneWithNewData in interface IMultiBucketSingleFileReplicationOrderedPacket

Specified by:

cloneWithNewData in interface IReplicationOrderedPacket

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object obj)

Overrides:

equals in class Object