Uses of Class
com.bigdata.relation.accesspath.BlockingBuffer

Packages that use BlockingBuffer

Package	Description
com.bigdata.bop.engine
com.bigdata.relation.rule.eval.pipeline	This package implements a pipeline join.
com.bigdata.service.master
com.bigdata.service.ndx
com.bigdata.service.ndx.pipeline
com.bigdata.striterator	Streaming iterator patterns based on Martyn Cutcher's striterator design but supporting generics and with extensions for closable, chunked, and ordered streaming iterators.

Uses of BlockingBuffer in com.bigdata.bop.engine

Subclasses of BlockingBuffer in com.bigdata.bop.engine

Modifier and Type	Class and Description
class	BlockingBufferWithStats<E> Extended to use the BufferAnnotations to provision the BlockingBuffer and to track the BOpStats as chunks are added to the buffer.

Uses of BlockingBuffer in com.bigdata.relation.rule.eval.pipeline

Fields in com.bigdata.relation.rule.eval.pipeline declared as BlockingBuffer

Modifier and Type	Field and Description
protected BlockingBuffer<IBindingSet[]>	LocalJoinTask.syncBuffer The BlockingBuffer whose queue will be drained by the downstream LocalJoinTask -or- null IFF [lastJoin == true].

Uses of BlockingBuffer in com.bigdata.service.master

Methods in com.bigdata.service.master with parameters of type BlockingBuffer

Modifier and Type	Method and Description
AbstractResourceScanner<V>	IResourceScannerFactory.newScanner(BlockingBuffer<V[]> buffer) Return a new scanner instance.

Constructors in com.bigdata.service.master with parameters of type BlockingBuffer

Constructor and Description
AbstractResourceScanner(BlockingBuffer<V[]> buffer)
FileSystemScanner(BlockingBuffer<File[]> buffer, File fileOrDir, FilenameFilter filter)

Uses of BlockingBuffer in com.bigdata.service.ndx

Methods in com.bigdata.service.ndx that return BlockingBuffer

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)

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

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

Modifier and Type	Field and Description
protected BlockingBuffer<E[]>	AbstractSubtask.buffer The buffer on which the AbstractSubtask.master is writing.
protected BlockingBuffer<E[]>	AbstractMasterTask.buffer The top-level buffer on which the application is writing.

Methods in com.bigdata.service.ndx.pipeline that return BlockingBuffer

Modifier and Type	Method and Description
BlockingBuffer<E[]>	AbstractMasterTask.getBuffer()
BlockingBuffer<E[]>	IMasterTask.getBuffer() The top-level buffer on which the application is writing.
protected BlockingBuffer<E[]>	IndexWriteTask.newSubtaskBuffer() Factory for a new buffer for a subtask.
protected abstract BlockingBuffer<E[]>	AbstractMasterTask.newSubtaskBuffer() Factory for a new buffer for a subtask.

Methods in com.bigdata.service.ndx.pipeline with parameters of type BlockingBuffer

Modifier and Type	Method and Description
protected S	IndexWriteTask.newSubtask(L locator, BlockingBuffer<E[]> out)
protected abstract S	AbstractMasterTask.newSubtask(L locator, BlockingBuffer<E[]> out) Factory for a new subtask.

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

Constructor and Description
AbstractMasterTask(H stats, BlockingBuffer<E[]> buffer, long sinkIdleTimeoutNanos, long sinkPollTimeoutNanos)
AbstractPendingSetMasterTask(AbstractDistributedFederation<?> fed, H stats, BlockingBuffer<E[]> buffer, long sinkIdleTimeoutNanos, long sinkPollTimeoutNanos)
AbstractPendingSetSubtask(M master, L locator, IAsynchronousClientTask<?,E> clientTask, BlockingBuffer<E[]> buffer)
AbstractSubtask(M master, L locator, BlockingBuffer<E[]> buffer)
IndexPartitionWriteTask(M master, L locator, IDataService dataService, BlockingBuffer<E[]> buffer)
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)
MockMaster(H stats, BlockingBuffer<E[]> buffer, long sinkIdleTimeout, long sinkPollTimeout)
MockSubtask(M master, L locator, BlockingBuffer<E[]> buffer)

Uses of BlockingBuffer in com.bigdata.striterator

Constructors in com.bigdata.striterator with parameters of type BlockingBuffer

Constructor and Description
AbstractChunkedResolverator(S state, IChunkedOrderedIterator<E> src, BlockingBuffer<F[]> buffer)