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

Class MultipleBucketOrderedPacket

java.lang.Object

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

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

All Implemented Interfaces:

IMultiBucketSingleFileReplicationOrderedPacket, IReplicationOrderedPacket, ISwapExternalizable, Externalizable, Serializable, Cloneable

public class MultipleBucketOrderedPacket
extends AbstractMultiBucketOrderedPacket

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
MultipleBucketOrderedPacket()
MultipleBucketOrderedPacket(long globalKey, ShortObjectMap<BucketKey> bucketsKeys, IReplicationPacketData<?> data)

Method Summary

Modifier and Type	Method and Description
MultipleBucketOrderedPacket	clone()
MultipleBucketOrderedPacket	cloneWithNewData(IReplicationPacketData<?> newData) Clones the packet replacing its data with the new data
PacketConsumeState	getConsumeState(short bucketIndex)
IReplicationPacketData<?>	getData()
boolean	isDataPacket()
boolean	isDiscardedPacket()
MultiBucketSingleFileProcessResult	process(String sourceLookupName, IMultiBucketSingleFileProcessLog processLog, IReplicationInFilterCallback inFilterCallback, ParallelBatchProcessingContext context, int segmentIndex)
void	readExternal(ObjectInput in)
void	readFromSwap(ObjectInput in)
AbstractMultiBucketOrderedPacket	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, getEndKey, getKey, getReliableAsyncBeforeFilterPacket, hashCode, processResult, readBucketKeys, reliableAsyncKeysUpdate, setReliableAsyncBeforeFilterPacket, toString, writeBucketKeys

Methods inherited from class java.lang.Object

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

Constructor Detail

MultipleBucketOrderedPacket

public MultipleBucketOrderedPacket()

MultipleBucketOrderedPacket

public MultipleBucketOrderedPacket(long globalKey,
                                   ShortObjectMap<BucketKey> bucketsKeys,
                                   IReplicationPacketData<?> data)

Method Detail

getData

public IReplicationPacketData<?> getData()

Returns:

the actual packet data that is needed for the processing

isDataPacket

public boolean isDataPacket()

isDiscardedPacket

public boolean isDiscardedPacket()

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

process

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

clone

public MultipleBucketOrderedPacket clone()

Specified by:

clone in interface IMultiBucketSingleFileReplicationOrderedPacket

Specified by:

clone in interface IReplicationOrderedPacket

Specified by:

clone in class AbstractMultiBucketOrderedPacket

cloneWithNewData

public MultipleBucketOrderedPacket cloneWithNewData(IReplicationPacketData<?> newData)

Description copied from interface: IReplicationOrderedPacket

Clones the packet replacing its data with the new data

getConsumeState

public PacketConsumeState getConsumeState(short bucketIndex)

setConsumed

public boolean setConsumed()

replaceWithDiscarded

public AbstractMultiBucketOrderedPacket replaceWithDiscarded()