com.bigdata.btree.filter

Class TupleTransformer<E,F>

java.lang.Object

cutthecrap.utils.striterators.FilterBase

com.bigdata.btree.filter.TupleTransformer<E,F>

All Implemented Interfaces:

ITupleFilter<F>, IFilter, IPropertySet, Serializable, Cloneable

Direct Known Subclasses:

AtomicRowFilter

public abstract class TupleTransformer<E,F>
extends FilterBase
implements ITupleFilter<F>

Abstract base class for an ITupleFilter that transforms the data type of the keys and/or values.

Version:

$Id$

Author:

Bryan Thompson

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected ITupleSerializer<? extends Object,F>	tupleSer The serialization provider for the transformed tuples.

Constructor Summary

Constructors

Constructor and Description
TupleTransformer(ITupleSerializer<? extends Object,F> tupleSer)

Method Summary

Methods

Modifier and Type	Method and Description
ITupleIterator<F>	filterOnce(Iterator src, Object context) Wrap the source iterator with this filter.
protected abstract ITupleIterator<F>	newTransformer(LookaheadTupleFilter.ILookaheadTupleIterator<E> src, Object context) Method responsible for creating a new instance of the iterator that reads from the lookahead source whose tuples are of the source type and visits the transformed tuples.

Methods inherited from class cutthecrap.utils.striterators.FilterBase

addFilter, filter, getProperty, getRequiredProperty, setProperty, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface cutthecrap.utils.striterators.IFilter

filter

Methods inherited from interface cutthecrap.utils.striterators.IPropertySet

getProperty

Field Detail

tupleSer

protected final ITupleSerializer<? extends Object,F> tupleSer

The serialization provider for the transformed tuples.

Constructor Detail

TupleTransformer

public TupleTransformer(ITupleSerializer<? extends Object,F> tupleSer)

Parameters:

tupleSer - The serialization provider for the transformed tuples.

Method Detail

filterOnce

public ITupleIterator<F> filterOnce(Iterator src,
                           Object context)

Description copied from class: FilterBase

Wrap the source iterator with this filter.

Specified by:

filterOnce in interface ITupleFilter<F>

Specified by:

filterOnce in class FilterBase

Parameters:

src - The source iterator.

context - The iterator evaluation context.

Returns:

The wrapped iterator.

newTransformer

protected abstract ITupleIterator<F> newTransformer(LookaheadTupleFilter.ILookaheadTupleIterator<E> src,
                               Object context)

Method responsible for creating a new instance of the iterator that reads from the lookahead source whose tuples are of the source type and visits the transformed tuples.