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

Class SingleBucketOrderedPacket

java.lang.Object

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

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

All Implemented Interfaces:

IMultiBucketSingleFileReplicationOrderedPacket, ISingleBucketReplicationOrderedPacket, IReplicationOrderedPacket, ISwapExternalizable, Externalizable, Serializable, Cloneable

public class SingleBucketOrderedPacket
extends AbstractSingleBucketOrderedPacket

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
SingleBucketOrderedPacket()
SingleBucketOrderedPacket(long globalKey, long bucketKey, short bucketIndex, IReplicationPacketData<?> data)

Method Summary

Modifier and Type	Method and Description
SingleBucketOrderedPacket	clone()
SingleBucketOrderedPacket	cloneWithNewData(IReplicationPacketData<?> newData) Clones the packet replacing its data with the new data
IReplicationPacketData<?>	getData()
int	getWeight()
boolean	isDataPacket()
boolean	isDiscardedPacket()
MultiBucketSingleFileProcessResult	process(String sourceLookupName, IMultiBucketSingleFileProcessLog processLog, IReplicationInFilterCallback inFilterCallback, ParallelBatchProcessingContext context, int segmentIndex)
void	readExternal(ObjectInput in)
void	readFromSwap(ObjectInput in)
DiscardedSingleBucketOrderedPacket	replaceWithDiscarded()
void	writeExternal(ObjectOutput out)
void	writeToSwap(ObjectOutput out)

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

associateToBuckets, bucketCount, equals, getBucketIndex, getBucketKey, getBucketKey, getBuckets, getConsumeState, getEndKey, getKey, getReliableAsyncBeforeFilterPacket, hashCode, processResult, reliableAsyncKeysUpdate, setConsumed, setReliableAsyncBeforeFilterPacket, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

SingleBucketOrderedPacket

public SingleBucketOrderedPacket()

SingleBucketOrderedPacket

public SingleBucketOrderedPacket(long globalKey,
                                 long bucketKey,
                                 short bucketIndex,
                                 IReplicationPacketData<?> data)

Method Detail

writeExternal

public void writeExternal(ObjectOutput out)
                   throws IOException

Specified by:

writeExternal in interface Externalizable

Overrides:

writeExternal in class AbstractSingleBucketOrderedPacket

Throws:

IOException

writeToSwap

public void writeToSwap(ObjectOutput out)
                 throws IOException

Specified by:

writeToSwap in interface ISwapExternalizable

Overrides:

writeToSwap in class AbstractSingleBucketOrderedPacket

Throws:

IOException

readExternal

public void readExternal(ObjectInput in)
                  throws IOException,
                         ClassNotFoundException

Specified by:

readExternal in interface Externalizable

Overrides:

readExternal in class AbstractSingleBucketOrderedPacket

Throws:

IOException

ClassNotFoundException

readFromSwap

public void readFromSwap(ObjectInput in)
                  throws IOException,
                         ClassNotFoundException

Specified by:

readFromSwap in interface ISwapExternalizable

Overrides:

readFromSwap in class AbstractSingleBucketOrderedPacket

Throws:

IOException

ClassNotFoundException

getData

public IReplicationPacketData<?> getData()

Returns:

the actual packet data that is needed for the processing

isDataPacket

public boolean isDataPacket()

isDiscardedPacket

public boolean isDiscardedPacket()

process

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

replaceWithDiscarded

public DiscardedSingleBucketOrderedPacket replaceWithDiscarded()

clone

public SingleBucketOrderedPacket clone()

Specified by:

clone in interface IMultiBucketSingleFileReplicationOrderedPacket

Specified by:

clone in interface ISingleBucketReplicationOrderedPacket

Specified by:

clone in interface IReplicationOrderedPacket

Specified by:

clone in class AbstractSingleBucketOrderedPacket

cloneWithNewData

public SingleBucketOrderedPacket cloneWithNewData(IReplicationPacketData<?> newData)

Description copied from interface: IReplicationOrderedPacket

Clones the packet replacing its data with the new data

getWeight

public int getWeight()

Specified by:

getWeight in interface IReplicationOrderedPacket

Overrides:

getWeight in class AbstractSingleBucketOrderedPacket