com.bigdata.striterator

Interface IChunkConverter<E,F>

Type Parameters:

E - The generic type of the source elements.

F - The generic type of the converted elements.

All Known Implementing Classes:

BulkCompleteConverter, BulkFilterConverter, DistinctFilter

public interface IChunkConverter<E,F>

This is a chunk at a time type processor. Elements can be dropped, have their state changed, or have their state replaced by another element, potentially of a different generic type.

Version:

$Id: SPOConvertingIterator.java,v 1.6 2008/08/25 17:21:01 thompsonbry Exp $

Author:

Bryan Thompson

Method Summary

Methods

Modifier and Type	Method and Description
F[]	convert(IChunkedOrderedIterator<E> src) Convert the next chunk of element(s) from the source iterator into target element(s).

Method Detail

convert

F[] convert(IChunkedOrderedIterator<E> src)

Convert the next chunk of element(s) from the source iterator into target element(s).

Note: This method will only be invoked if ChunkedConvertingIterator.hasNext() reports true for the source iterator.

Note: Iterators are single-threaded so the implementation of this method does not need to be thread-safe.

Parameters:

src - The source iterator.

Returns:

The target chunk (not null, but may be empty).