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

Packages that use BlockingBuffer

com.bigdata.bop.engine
com.bigdata.relation.rule.eval.pipeline	This package implements a pipeline join.
com.bigdata.service.jini.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

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

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.jini.master

Methods in com.bigdata.service.jini.master that return BlockingBuffer

BlockingBuffer<V[]>	MappedTaskMaster.newResourceBuffer() Allocate and start processing for the buffer used to hand off resources for processing to the clients.
protected BlockingBuffer<E[]>	ResourceBufferTask.newSubtaskBuffer() Factory for a new buffer for a subtask.

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

AbstractResourceScanner<V>	IResourceScannerFactory.newScanner(BlockingBuffer<V[]> buffer) Return a new scanner instance.
protected S	ResourceBufferTask.newSubtask(L locator, BlockingBuffer<E[]> out)

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

AbstractResourceScanner(BlockingBuffer<V[]> buffer)

FileSystemScanner(BlockingBuffer<File[]> buffer, File fileOrDir, FilenameFilter filter)

ResourceBufferSubtask(M master, L locator, IAsynchronousClientTask<?,E> clientTask, BlockingBuffer<E[]> buffer)

ResourceBufferTask.M(MappedTaskMaster taskMaster, long sinkIdleTimeoutNanos, long sinkPollTimeoutNanos, int sinkQueueCapacity, int sinkChunkSize, long sinkChunkTimeoutNanos, ResourceBufferStatistics<ClientLocator,ResourceBufferSubtaskStatistics> stats, BlockingBuffer<E[]> buffer)

ResourceBufferTask(MappedTaskMaster taskMaster, long sinkIdleTimeoutNanos, long sinkPollTimeoutNanos, int sinkQueueCapacity, int sinkChunkSize, long sinkChunkTimeoutNanos, H stats, BlockingBuffer<E[]> buffer)

Uses of BlockingBuffer in com.bigdata.service.ndx

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

<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

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

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

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

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

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

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

AbstractMasterTask(H stats, BlockingBuffer<E[]> buffer, long sinkIdleTimeoutNanos, long sinkPollTimeoutNanos)

AbstractPendingSetMasterTask(JiniFederation<?> 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)

Uses of BlockingBuffer in com.bigdata.striterator

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

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