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

Class DiscardedSingleBucketOrderedPacket

java.lang.Object

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

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

All Implemented Interfaces:

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

public class DiscardedSingleBucketOrderedPacket
extends AbstractSingleBucketOrderedPacket

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
DiscardedSingleBucketOrderedPacket()
DiscardedSingleBucketOrderedPacket(long globalKey, short bucketIndex, long bucketKey)

Method Summary

Modifier and Type	Method and Description
DiscardedSingleBucketOrderedPacket	clone()
DiscardedSingleBucketOrderedPacket	cloneWithNewData(IReplicationPacketData<?> newData) Clones the packet replacing its data with the new data
IReplicationPacketData<?>	getData()
boolean	isDataPacket()
boolean	isDiscardedPacket()
MultiBucketSingleFileProcessResult	process(String sourceLookupName, IMultiBucketSingleFileProcessLog processLog, IReplicationInFilterCallback inFilterCallback, ParallelBatchProcessingContext context, int segmentIndex)
DiscardedSingleBucketOrderedPacket	replaceWithDiscarded()

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, readExternal, readFromSwap, reliableAsyncKeysUpdate, setConsumed, setReliableAsyncBeforeFilterPacket, toString, writeExternal, writeToSwap

Methods inherited from class java.lang.Object

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

Constructor Detail

DiscardedSingleBucketOrderedPacket

public DiscardedSingleBucketOrderedPacket()

DiscardedSingleBucketOrderedPacket

public DiscardedSingleBucketOrderedPacket(long globalKey,
                                          short bucketIndex,
                                          long bucketKey)

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)

replaceWithDiscarded

public DiscardedSingleBucketOrderedPacket replaceWithDiscarded()

clone

public DiscardedSingleBucketOrderedPacket 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 DiscardedSingleBucketOrderedPacket cloneWithNewData(IReplicationPacketData<?> newData)

Description copied from interface: IReplicationOrderedPacket

Clones the packet replacing its data with the new data