Uses of Interface
com.bigdata.service.ndx.pipeline.IDuplicateRemover

Packages that use IDuplicateRemover

Package	Description
com.bigdata.service.ndx
com.bigdata.service.ndx.pipeline

Uses of IDuplicateRemover in com.bigdata.service.ndx

Methods in com.bigdata.service.ndx with parameters of type IDuplicateRemover

Modifier and Type	Method and Description
<T extends IKeyArrayIndexProcedure,O,R,A> BlockingBuffer<KVO<O>[]>	AbstractScaleOutClientIndexView.newWriteBuffer(IResultHandler<R,A> resultHandler, IDuplicateRemover<O> duplicateRemover, AbstractKeyArrayIndexProcedureConstructor<T> ctor)
<T extends IKeyArrayIndexProcedure,O,R,A> IRunnableBuffer<KVO<O>[]>	ClientIndexView.newWriteBuffer(IResultHandler<R,A> resultHandler, IDuplicateRemover<O> duplicateRemover, AbstractKeyArrayIndexProcedureConstructor<T> ctor)
<T extends IKeyArrayIndexProcedure,O,R,A> IRunnableBuffer<KVO<O>[]>	IAsynchronousWriteBufferFactory.newWriteBuffer(IResultHandler<R,A> resultHandler, IDuplicateRemover<O> duplicateRemover, AbstractKeyArrayIndexProcedureConstructor<T> ctor) Asynchronous write API (streaming writes).

Uses of IDuplicateRemover in com.bigdata.service.ndx.pipeline

Classes in com.bigdata.service.ndx.pipeline that implement IDuplicateRemover

Modifier and Type	Class and Description
class	DefaultDuplicateRemover<O> Implementation which retains one instance of each tuple having the same unsigned byte[] key and the same byte[] value.
class	NOPDuplicateRemover<O> NOP implementation.

Fields in com.bigdata.service.ndx.pipeline declared as IDuplicateRemover

Modifier and Type	Field and Description
protected IDuplicateRemover<O>	IndexWriteTask.duplicateRemover
static IDuplicateRemover	DefaultDuplicateRemover.KEY_REF_VAL Instance verifies the same unsigned byte[] key and will accept the same non-null object reference as indicating the same value.
static IDuplicateRemover	DefaultDuplicateRemover.KEY_VAL Instance verifies the same unsigned byte[] key and the same byte[] value.,

Constructors in com.bigdata.service.ndx.pipeline with parameters of type IDuplicateRemover

Constructor and Description
IndexWriteTask.M(IScaleOutClientIndex ndx, long sinkIdleTimeoutNanos, long sinkPollTimeoutNanos, int sinkQueueCapacity, int sinkChunkSize, long sinkChunkTimeoutNanos, IDuplicateRemover<O> duplicateRemover, AbstractKeyArrayIndexProcedureConstructor<T> ctor, IResultHandler<R,A> resultHandler, IndexAsyncWriteStats<PartitionLocator,IndexPartitionWriteStats> stats, BlockingBuffer<KVO<O>[]> buffer)
IndexWriteTask(IScaleOutClientIndex ndx, long sinkIdleTimeoutNanos, long sinkPollTimeoutNanos, int sinkQueueCapacity, int sinkChunkSize, long sinkChunkTimeoutNanos, IDuplicateRemover<O> duplicateRemover, AbstractKeyArrayIndexProcedureConstructor<T> ctor, IResultHandler<R,A> resultHandler, H stats, BlockingBuffer<E[]> buffer)