com.neurosys.etl.readers

Interface TupleContextAwareReader<I,O>

All Superinterfaces:

RealTimeLineReader<O>

All Known Implementing Classes:

AbstractProcessBasedReporter, AbstractReader, BaseIterativeProcessor, ChainIterativeReader, ExcelContextualReader, ExcelRowByRowReader, ExecuteJobReader, FileReader

public interface TupleContextAwareReader<I,O>
extends RealTimeLineReader<O>

A special RealTimeLineReader that provides an option to retrieve the RealTimeLineReader.next() record with the context of the original tuple/record/object that resulted in the output entity from next.

Author:

Arjun Dhar

Method Summary

Modifier and Type	Method and Description
Map.Entry<I,O>	nextTupleResult() Get the next Output entity but also return the original Input tuple that resulted in the Output.

Methods inherited from interface com.neurosys.etl.readers.RealTimeLineReader

close, dispose, getSourceLocation, hasNext, init, isInitialized, next

Method Detail

nextTupleResult

Map.Entry<I,O> nextTupleResult()

Get the next Output entity but also return the original Input tuple that resulted in the Output.

Returns:

Map.Entry of Input to Output key-value pair