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

See:
Description

Interface Summary

IChunkConverter<E,F>	This is a chunk at a time type processor.
IChunkedIterator<E>	An iterator that is able visit items in chunks.
IChunkedOrderedIterator<R>	An extension of IChunkedIterator interface that knows about natural traversal orders and how to re-order the elements that are being visited to support JOINs where the natural order for the access paths is different for the left- and right-hand side of the JOIN.
IChunkedOrderedStriterator<I extends IChunkedOrderedIterator<E>,E>	Generic-enabled streaming iterator pattern for chunked ordered iterators.
IChunkedStriterator<I extends IChunkedIterator<E>,E>	Generic-enabled streaming iterator pattern for chunked iterators.
ICloseableIterator<E>	An iterator that defines a ICloseableIterator.close() method - you MUST close instances of this interface.
IFilter<I extends Iterator<E>,E,F>	Stackable filter pattern with generics.
IKeyOrder<E>	An interface representing the natural traversal orders for the different indices for some class of relation.
IStriterator<I extends Iterator<E>,E>	Streaming iterator pattern ala Martyn Cutcher with generics.

Class Summary

AbstractChunkedResolverator<E,F,S>	Wraps an IChunkedIterator and asynchronously resolves chunks.
Appender<I extends Iterator<E>,E>	Appender pattern tacks on another iterator when the source iterator is exhausted.
ChunkedArrayIterator<E>	Fully buffered iterator.
ChunkedConvertingIterator<E,F>	Supports the chunk-at-a-time filter and conversion operations.
ChunkedFilter<I extends IChunkedIterator<E>,E,F>	Chunk-at-a-time filter.
ChunkedOrderedStriterator<I extends IChunkedOrderedIterator<E>,E>	Chunked ordered streaming iterator.
ChunkedResolvingIterator<E,S>	Converts the type of the source iterator using #resolve().
ChunkedStriterator<I extends IChunkedIterator<E>,E>	Chunked streaming iterator.
ChunkedWrappedIterator<E>	Converts an Iterator into chunked iterator.
ClosableEmptyIterator<E>	A closable iterator that visits nothing.
ClosableSingleItemIterator<E>	A closable iterator that visits a single item.
CloseableIteratorWrapper<E>	Wraps a normal Iterator as an ICloseableIterator.
DelegateChunkedIterator<E>	Abstract class for delegation patterns for chunked iterators.
DistinctFilter<E>	A filter that imposes a DISTINCT constraint on the ISolutions generated by an IRule.
EmptyChunkedIterator<E>	An empty iterator.
Filter<I extends Iterator<E>,E>	Element-at-a-time filter with generics.
GenericChunkedOrderedStriterator<E>	Chunked ordered streaming iterator class that supresses generic types.
GenericChunkedStriterator<E>	Chunked streaming iterator class that supresses generic types.
GenericStriterator<E>	Streaming iterator class that supresses generic types.
MergeFilter<I extends Iterator<E>,E extends Comparable<E>>	Merge sort of two iterators with duplicates suppressed.
PushbackIterator<E>	Allows pushback of the most recently visited element onto the iterator.
Resolver<I extends Iterator<E>,E,F>	Pattern for resolving elements of an iterator.
SingleValueChunkedIterator<E>	An iterator that will visit a single value.
Striterator<I extends Iterator<E>,E>	Streaming iterator pattern.

Package com.bigdata.striterator Description

Streaming iterator patterns based on Martyn Cutcher's striterator design but supporting generics and with extensions for closable, chunked, and ordered streaming iterators.