com.bigdata.striterator

Class MergeFilter<I extends Iterator<E>,E extends Comparable<E>>

java.lang.Object

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

All Implemented Interfaces:

IFilter<I,E,E>, Serializable

public class MergeFilter<I extends Iterator<E>,E extends Comparable<E>>
extends Object
implements IFilter<I,E,E>

Merge sort of two iterators with duplicates suppressed. The elements must be comparable. Each source iterator must deliver its elements in a total ordering in order for the aggregate iterator to maintain a total ordering.

Version:

$Id$

Author:

Bryan Thompson

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
MergeFilter(I src2)
MergeFilter(int chunkSize, I src2)

Method Summary

Methods

Modifier and Type	Method and Description
I	filter(I src) Wrap the source iterator with an iterator that applies this filter.

Methods inherited from class java.lang.Object

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

Constructor Detail

MergeFilter

public MergeFilter(I src2)

MergeFilter

public MergeFilter(int chunkSize,
           I src2)

Method Detail

filter

public I filter(I src)

Description copied from interface: IFilter

Wrap the source iterator with an iterator that applies this filter.

Specified by:

filter in interface IFilter<I extends Iterator<E>,E extends Comparable<E>,E extends Comparable<E>>

Parameters:

src - The source iterator.

Returns:

The filtered iterator.