Uses of Interface
com.bigdata.relation.accesspath.IBlockingBuffer

Packages that use IBlockingBuffer

com.bigdata.bop	This package provides an API for query operators.
com.bigdata.bop.engine
com.bigdata.relation.accesspath	This package includes an abstraction layer for efficient access paths, including chunked iterators, blocking buffers, and an abstraction corresponding to the natural order of an index.
com.bigdata.relation.rule.eval	This package supports rule evaluation.
com.bigdata.relation.rule.eval.pipeline	This package implements a pipeline join.

Uses of IBlockingBuffer in com.bigdata.bop

Methods in com.bigdata.bop that return IBlockingBuffer

IBlockingBuffer<E[]>	BOpContext.getSink() Where to write the output of the operator.
IBlockingBuffer<E[]>	BOpContext.getSink2() Optional alternative sink for the output of the operator.

Methods in com.bigdata.bop with parameters of type IBlockingBuffer

static long	BOpUtility.copy(Iterator<IBindingSet[]> source, IBlockingBuffer<IBindingSet[]> sink, IBlockingBuffer<IBindingSet[]> sink2, IBindingSet mergeSolution, IVariable<?>[] selectVars, IConstraint[] constraints, BOpStats stats) Copy binding sets from the source to the sink(s).
static long	BOpUtility.copy(Iterator<IBindingSet[]> source, IBlockingBuffer<IBindingSet[]> sink, IBlockingBuffer<IBindingSet[]> sink2, IBindingSet mergeSolution, IVariable<?>[] selectVars, IConstraint[] constraints, BOpStats stats) Copy binding sets from the source to the sink(s).

Constructors in com.bigdata.bop with parameters of type IBlockingBuffer

BOpContext(IRunningQuery runningQuery, int partitionId, BOpStats stats, ICloseableIterator<E[]> source, IBlockingBuffer<E[]> sink, IBlockingBuffer<E[]> sink2)

BOpContext(IRunningQuery runningQuery, int partitionId, BOpStats stats, ICloseableIterator<E[]> source, IBlockingBuffer<E[]> sink, IBlockingBuffer<E[]> sink2)

Uses of IBlockingBuffer in com.bigdata.bop.engine

Classes in com.bigdata.bop.engine that implement IBlockingBuffer

class	BlockingBufferWithStats<E> Extended to use the BufferAnnotations to provision the BlockingBuffer and to track the BOpStats as chunks are added to the buffer.
class	OutputStatsBuffer<E> Delegation pattern handles the SinkTransitionMetadata.

Methods in com.bigdata.bop.engine that return IBlockingBuffer

protected IBlockingBuffer<IBindingSet[]>	AbstractRunningQuery.getQueryBuffer() Return the buffer used for the overall output of the query pipeline and null if this is not the query controller.
protected IBlockingBuffer<IBindingSet[]>	AbstractRunningQuery.newQueryBuffer(PipelineOp query, BOpStats queryStats) Return the buffer that will be used to absorb solutions.

Constructors in com.bigdata.bop.engine with parameters of type IBlockingBuffer

OutputStatsBuffer(IBlockingBuffer<E> b, BOpStats stats)

Uses of IBlockingBuffer in com.bigdata.relation.accesspath

Classes in com.bigdata.relation.accesspath that implement IBlockingBuffer

class	BlockingBuffer<E> A buffer that will block when it is full.
class	DelegateBuffer<E> A delegation pattern which does not pass on the DelegateBuffer.close() method.

Methods in com.bigdata.relation.accesspath that return IBlockingBuffer

IBlockingBuffer<E>	MultiplexBlockingBuffer.getBackingBuffer() The IBlockingBuffer reference provided to the constructor.
IBlockingBuffer<E>	MultiplexBlockingBuffer.newInstance() Create a new skin for the shared buffer, incrementing the count of the #of open skins that buffer.

Constructors in com.bigdata.relation.accesspath with parameters of type IBlockingBuffer

DelegateBuffer(IBlockingBuffer<E> delegate)

MultiplexBlockingBuffer(IBlockingBuffer<E> b)

UnsyncLocalOutputBuffer(int capacity, IBlockingBuffer<E[]> syncBuffer)

UnsyncLocalOutputBuffer(int capacity, IBlockingBuffer<E[]> syncBuffer, IElementFilter<E> filter)

Uses of IBlockingBuffer in com.bigdata.relation.rule.eval

Methods in com.bigdata.relation.rule.eval that return IBlockingBuffer

IBlockingBuffer<ISolution[]>	IJoinNexus.newQueryBuffer() Return a thread-safe buffer onto which chunks of computed ISolutions will be written.
IBlockingBuffer<ISolution[]>	AbstractJoinNexus.newQueryBuffer() Note: ISolution (not relation elements) will be written on the buffer concurrently by different rules so there is no natural order for the elements in the buffer.

Methods in com.bigdata.relation.rule.eval with parameters of type IBlockingBuffer

protected List<Callable<RuleStats>>

QueryTask.newQueryTasks(IStep step, IJoinNexus joinNexus, IBlockingBuffer<ISolution[]> buffer) Builds a set of tasks for the program.

Constructors in com.bigdata.relation.rule.eval with parameters of type IBlockingBuffer

QueryTask(IStep step, IJoinNexusFactory joinNexusFactory, IBlockingBuffer<ISolution[]> buffer, IIndexManager indexManager, DataService dataService)

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

Constructors in com.bigdata.relation.rule.eval.pipeline with parameters of type IBlockingBuffer

UnsyncLocalOutputBuffer(JoinStats joinStats, int capacity, IBlockingBuffer<E[]> syncBuffer)