com.bigdata.striterator

Class ChunkedStriterator<I extends IChunkedIterator<E>,E>

java.lang.Object

com.bigdata.striterator.Striterator<I,E>

com.bigdata.striterator.ChunkedStriterator<I,E>

All Implemented Interfaces:

IChunkedIterator<E>, IChunkedStriterator<I,E>, IStriterator<I,E>, ICloseable, ICloseableIterator<E>, Enumeration<E>, Iterator<E>

Direct Known Subclasses:

ChunkedOrderedStriterator, GenericChunkedStriterator

public class ChunkedStriterator<I extends IChunkedIterator<E>,E>
extends Striterator<I,E>
implements IChunkedStriterator<I,E>

Chunked streaming iterator.

Version:

$Id$

Author:

Bryan Thompson

Field Summary

Fields inherited from class com.bigdata.striterator.Striterator

realSource, src

Fields inherited from interface com.bigdata.striterator.IChunkedIterator

DEFAULT_CHUNK_SIZE

Constructor Summary

Constructors

Constructor and Description
ChunkedStriterator(I src)
ChunkedStriterator(int chunkSize, Iterator<E> src) Wraps the source iterator as a chunked iterator.
ChunkedStriterator(Iterator<E> src) Wraps the source iterator as a chunked iterator using a default chunk size.

Method Summary

Methods

Modifier and Type	Method and Description
IChunkedStriterator<I,E>	addFilter(IFilter<I,?,E> filter) Strengthened return type.
E[]	nextChunk() Return the next "chunk" from the iterator.

Methods inherited from class com.bigdata.striterator.Striterator

addInstanceOfFilter, append, close, exclude, hasMoreElements, hasNext, makeUnique, map, next, nextElement, remove

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.bigdata.striterator.IChunkedIterator

next, remove

Methods inherited from interface com.bigdata.striterator.IStriterator

addInstanceOfFilter, append

Methods inherited from interface cutthecrap.utils.striterators.ICloseableIterator

close

Methods inherited from interface java.util.Iterator

hasNext

Methods inherited from interface java.util.Enumeration

hasMoreElements, nextElement

Constructor Detail

ChunkedStriterator

public ChunkedStriterator(I src)

ChunkedStriterator

public ChunkedStriterator(Iterator<E> src)

Wraps the source iterator as a chunked iterator using a default chunk size.

Parameters:

src - The source iterator.

ChunkedStriterator

public ChunkedStriterator(int chunkSize,
                  Iterator<E> src)

Wraps the source iterator as a chunked iterator.

Parameters:

chunkSize - The chunk size.

src - The source iterator.

Method Detail

nextChunk

public final E[] nextChunk()

Description copied from interface: IChunkedIterator

Return the next "chunk" from the iterator.

Specified by:

nextChunk in interface IChunkedIterator<E>

Returns:

The next chunk.

addFilter

public IChunkedStriterator<I,E> addFilter(IFilter<I,?,E> filter)

Strengthened return type.

Specified by:

addFilter in interface IChunkedStriterator<I extends IChunkedIterator<E>,E>

Specified by:

addFilter in interface IStriterator<I extends IChunkedIterator<E>,E>

Overrides:

addFilter in class Striterator<I extends IChunkedIterator<E>,E>

Parameters:

filter - The filter.

Returns:

The filtered iterator.