com.neurosys.etl.readers

Interface ResourceAwareRealTimeLineReader<T>

All Superinterfaces:

RealTimeLineReader<T>

All Known Implementing Classes:

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

public interface ResourceAwareRealTimeLineReader<T>
extends RealTimeLineReader<T>

A RealTimeLineReader that is aware of other aspects of the resource it is reading in addition to just the line its reading

Author:

Arjun Dhar

Method Summary

Modifier and Type	Method and Description
Long	getCurrentIndex() Depending on the resource the size() may factor in redundant rows also that maybe filtered by the reader if it uses some sort of filter.
Long	size() Get number of tuples/records in resource

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

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

Method Detail

size

Long size()

Get number of tuples/records in resource

Returns:

Long

getCurrentIndex

Long getCurrentIndex()

Depending on the resource the size() may factor in redundant rows also that maybe filtered by the reader if it uses some sort of filter.
This method allows to keep track of the real position, since the calling API may/will not be notified of skipped rows. Numbering starts from 0.

Size and getCurrentIndex reflect on valid rows being processed. But there maybe noise and extra un-processable rows due to which getCurrentIndex() on the last record maybe < what size() gives.
Hence @ the end of your process normalize to 100% when we are sure its done without errors/abort.

Returns: