net.fortytwo.flow

Interface Sink<T>

Type Parameters:

T - the type of data being passed

All Known Implementing Classes:

Buffer, Collector, DistinctFilter, HistorySink, LazyStackEvaluator.EvaluatorSink, NullSink, ParserExceptionSink, QueryPipe, Switch, SynchronizedSink, Tee, TurtleView

public interface Sink<T>

The next step in a data pipeline. Data items which are passed into a Sink may be transformed or passed along verbatim to downstream components, or even thrown away; a Sink is a black box with respect to upstream components passing data into it.

Method Summary

Methods

Modifier and Type	Method and Description
void	put(T t) Passes a data item into the Sink

Method Detail

put

void put(T t)
         throws RippleException

Passes a data item into the Sink

Parameters:

t - the data item being passed

Throws:

RippleException - if a data handling error occors