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

Packages that use IBlockingBuffer

Package	Description
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

Modifier and Type	Method and Description
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

Modifier and Type	Method and Description
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).
static <E> BOpContext<E>	BOpContext.newMock(IRunningQuery runningQuery, IBigdataFederation<?> fed, IIndexManager localIndexManager, int partitionId, BOpStats stats, PipelineOp op, boolean lastInvocation, ICloseableIterator<E[]> source, IBlockingBuffer<E[]> sink, IBlockingBuffer<E[]> sink2) Test suite helper.
static <E> BOpContext<E>	BOpContext.newMock(IRunningQuery runningQuery, IBigdataFederation<?> fed, IIndexManager localIndexManager, int partitionId, BOpStats stats, PipelineOp op, boolean lastInvocation, ICloseableIterator<E[]> source, IBlockingBuffer<E[]> sink, IBlockingBuffer<E[]> sink2) Test suite helper.

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

Constructor and Description
BOpContext(IRunningQuery runningQuery, int partitionId, BOpStats stats, PipelineOp op, boolean lastInvocation, ICloseableIterator<E[]> source, IBlockingBuffer<E[]> sink, IBlockingBuffer<E[]> sink2)
BOpContext(IRunningQuery runningQuery, int partitionId, BOpStats stats, PipelineOp op, boolean lastInvocation, 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

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.
class	OutputStatsBuffer<E> Delegation pattern handles the SinkTransitionMetadata.

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

Modifier and Type	Method and Description
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

Constructor and Description
OutputStatsBuffer(IBlockingBuffer<E> b, BOpStats stats)

Uses of IBlockingBuffer in com.bigdata.relation.accesspath

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

Modifier and Type	Class and Description
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

Modifier and Type	Method and Description
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

Constructor and Description
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

Modifier and Type	Method and Description
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.
IBlockingBuffer<ISolution[]>	IJoinNexus.newQueryBuffer() Return a thread-safe buffer onto which chunks of computed ISolutions will be written.

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

Modifier and Type	Method and Description
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

Constructor and Description
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

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