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

Packages that use AbstractUnsynchronizedArrayBuffer

Package	Description
com.bigdata.bop.fed.shards
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.pipeline	This package implements a pipeline join.

Uses of AbstractUnsynchronizedArrayBuffer in com.bigdata.bop.fed.shards

Subclasses of AbstractUnsynchronizedArrayBuffer in com.bigdata.bop.fed.shards

Modifier and Type	Class and Description
class	MapBindingSetsOverShardsBuffer<E extends IBindingSet,F> A stream of IBindingSet are mapped across the shards which will have the data for the IPredicate.asBound(IBindingSet) IPredicate.

Uses of AbstractUnsynchronizedArrayBuffer in com.bigdata.relation.accesspath

Subclasses of AbstractUnsynchronizedArrayBuffer in com.bigdata.relation.accesspath

Modifier and Type	Class and Description
class	UnsynchronizedArrayBuffer<E> An unsynchronized buffer backed by a fixed capacity array that migrates references onto the caller's buffer (which is normally thread-safe) using IBuffer#add(int).
class	UnsynchronizedUnboundedChunkBuffer<E> An unsynchronized buffer backed by a fixed capacity array that migrates references onto an internal Queue, which may be drained by an UnsynchronizedUnboundedChunkBuffer.iterator().
class	UnsyncLocalOutputBuffer<E extends IBindingSet> Wraps the base class to update the caller's BOpStats.

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

Methods in com.bigdata.relation.rule.eval.pipeline that return AbstractUnsynchronizedArrayBuffer

Modifier and Type	Method and Description
protected AbstractUnsynchronizedArrayBuffer<IBindingSet>	LocalJoinTask.newUnsyncOutputBuffer() Note: The target buffer on which the unsynchronized buffer writes depends on whether or not there is a downstream sink for this LocalJoinTask.
protected abstract AbstractUnsynchronizedArrayBuffer<IBindingSet>	JoinTask.newUnsyncOutputBuffer() A method used by the JoinTask.threadLocalBufferFactory to create new output buffer as required.
protected AbstractUnsynchronizedArrayBuffer<IBindingSet>	DistributedJoinTask.newUnsyncOutputBuffer()

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

Constructor and Description
JoinTask.ChunkTask(IBindingSet[] bindingSet, AbstractUnsynchronizedArrayBuffer<IBindingSet> unsyncBuffer, Object[] chunk)