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

See:
Description

Interface Summary

IAbstractAccessPath<R>	A common interface for all access paths.
IAccessPath<R>	An abstraction for efficient reads of IElements from a IRelation using the index selected by an IPredicate constraint.
IAsynchronousIterator<E>	Interface for iterators that are running asynchronously.
IBindingSetAccessPath<R>	An interface for access paths which visit solutions (versus IElement s).
IBlockingBuffer<E>	Interface provides an iterator to drain chunks from an IBuffer.
IBuffer<E>	A buffer abstraction.
IElementFilter<E>	Filter for accepting or rejecting visited elements.
IMultiSourceCloseableIterator<E>	An interface which permits new sources to be attached dynamically.
IRunnableBuffer<E>	An IBuffer that may be closed.

Class Summary

AbstractArrayBuffer<E>	A thread-safe buffer backed by a fixed capacity array.
AbstractElementBuffer<R>	Base class for IBuffer of IRelation elements whose target is a mutation (insert, delete, or update) of some IMutableRelation.
AbstractElementBuffer.DeleteBuffer<R>	Buffer writes on IMutableRelation.delete(IChunkedOrderedIterator) when it is flushed.
AbstractElementBuffer.InsertBuffer<R>	Buffer writes on IMutableRelation.insert(IChunkedOrderedIterator) when it is flushed.
AbstractUnsynchronizedArrayBuffer<E>	An abstract implementation of an unsynchronized buffer backed by a fixed capacity array.
AccessPath<R>	Abstract base class for type-specific IAccessPath implementations.
AccessPathFusedView<E>	Deprecated. by BOps using the UNION of JOINs.
ArrayAccessPath<E>	An access path over an array of elements.
BlockingBuffer<E>	A buffer that will block when it is full.
ChunkConsumerIterator<E>	A class that aligns a buffer of E[]s (a buffer of chunks) with an IChunkedOrderedIterator.
ChunkMergeSortHelper	Utility for merge sort of chunks.
DelegateBuffer<E>	A delegation pattern which does not pass on the DelegateBuffer.close() method.
ElementFilter<R>	Align the predicate's IElementFilter constraint with ITupleFilter so that the IElementFilter can be evaluated close to the data by an ITupleIterator.
EmptyAccessPath<E>	An access path that is known to be empty.
EmptyAsynchronousIterator<E>	An empty IAsynchronousIterator.
EmptyCloseableIterator<E>	An empty ICloseableIterator.
FlushBufferTask	Task invokes IBuffer.flush() and returns its return value.
MultiplexBlockingBuffer<E>	A factory for skins which may be used to multiplex writes against a shared BlockingBuffer instance.
MultiSourceSequentialCloseableIterator<E>	Class allows new sources to be attached dynamically.
SameVariableConstraintTupleFilter<E>	TupleFilter class wrapping the SameVariableConstraint.
ThickAsynchronousIterator<E>	An IAsynchronousIterator that may be serialized and sent to a remote JVM for consumption.
ThickCloseableIterator<E>	An ICloseableIterator that may be serialized and sent to a remote JVM for consumption.
ThreadLocalBufferFactory<T extends IBuffer<E>,E>	A factory pattern for per-thread objects whose life cycle is tied to some container.
TupleObjectResolver<R>	Resolve an ITuple to its AbstractTuple.getObject().
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).
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().
UnsyncLocalOutputBuffer<E extends IBindingSet>	Wraps the base class to update the caller's BOpStats.
WrappedAsynchronousIterator<E,F>	An IAsynchronousIterator that wraps an IChunkedIterator or a ICloseableIterator.

Exception Summary

BufferClosedException

Exception thrown by IBlockingBuffer#add() if the buffer is closed.

Package com.bigdata.relation.accesspath Description

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. The main purpose of access paths is to support the evaluation of rules (aka JOINs or high-level query).