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

Class DiscardedMultiBucketOrderedPacket

java.lang.Object

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

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

All Implemented Interfaces:

IMultiBucketSingleFileReplicationOrderedPacket, IReplicationOrderedPacket, ISwapExternalizable, Externalizable, Serializable, Cloneable

public class DiscardedMultiBucketOrderedPacket
extends AbstractMultiBucketOrderedPacket

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
DiscardedMultiBucketOrderedPacket()
DiscardedMultiBucketOrderedPacket(long globalKey, ShortObjectMap<BucketKey> bucketsKeys)

Method Summary

Modifier and Type	Method and Description
AbstractMultiBucketOrderedPacket	clone()
IMultiBucketSingleFileReplicationOrderedPacket	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)
AbstractMultiBucketOrderedPacket	replaceWithDiscarded()
boolean	setConsumed()

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

associateToBuckets, bucketCount, equals, getBucketKey, getBuckets, getBucketsKeys, getEndKey, getKey, getReliableAsyncBeforeFilterPacket, getWeight, hashCode, processResult, readBucketKeys, readExternal, readFromSwap, reliableAsyncKeysUpdate, setReliableAsyncBeforeFilterPacket, toString, writeBucketKeys, writeExternal, writeToSwap

Methods inherited from class java.lang.Object

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

Constructor Detail

DiscardedMultiBucketOrderedPacket

public DiscardedMultiBucketOrderedPacket()

DiscardedMultiBucketOrderedPacket

public DiscardedMultiBucketOrderedPacket(long globalKey,
                                         ShortObjectMap<BucketKey> bucketsKeys)

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()

process

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

getConsumeState

public PacketConsumeState getConsumeState(short bucketIndex)

setConsumed

public boolean setConsumed()

replaceWithDiscarded

public AbstractMultiBucketOrderedPacket replaceWithDiscarded()

clone

public AbstractMultiBucketOrderedPacket 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