com.neurosys.etl.readers

Interface RealTimeLineReader<T>

All Known Subinterfaces:

ResourceAwareRealTimeLineReader<T>, TupleContextAwareReader<I,O>

All Known Implementing Classes:

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

public interface RealTimeLineReader<T>

From any connector that reads a stream Line by Line sequentially can pass data to the parser; the parser responds with a Generic Record type on completing one record or an Exception if something is going wrong. On Exception the context is reset..
The Parser is responsible for reading and maintaining context.

The implementations are not expected to be ThreadSafe. Per parsing activity only one unique instance should be used.

Author:

Arjun Dhar

Method Summary

Modifier and Type	Method and Description
void	close() Any cleanup
void	dispose() Un-initialize reader, so that it maybe re consumed Except for the main Resource & configuration set by Spring context all other instance variables used will be re-set/disposed/cleared.
String	getSourceLocation()
boolean	hasNext() True if there is another record that can be read by the parser, false implies end of parse/read
void	init() Allow lazy initialization of Reader in cases where the resource may not be known @ PostConstruct time
boolean	isInitialized() Allow the calling API to determine if the reader has been initialized via init() or PostConstruct phase If not init() should be called upon the instance.
T	next() Read line from Source, on Record construction complete return the Record.

Method Detail

next

T next()
throws Exception

Read line from Source, on Record construction complete return the Record.

Parameters:

line - as String

Returns:

Record

Throws:

Exception

hasNext

boolean hasNext()

True if there is another record that can be read by the parser, false implies end of parse/read

Returns:

boolean

close

void close()
    throws Exception

Any cleanup

Throws:

Exception

getSourceLocation

String getSourceLocation()

init

void init()
   throws Exception

Allow lazy initialization of Reader in cases where the resource may not be known @ PostConstruct time

Throws:

Exception

isInitialized

boolean isInitialized()
               throws Exception

Allow the calling API to determine if the reader has been initialized via init() or PostConstruct phase
If not init() should be called upon the instance.

Throws:

Exception

dispose

void dispose()
      throws Exception

Un-initialize reader, so that it maybe re consumed
Except for the main Resource & configuration set by Spring context all other instance variables used will be re-set/disposed/cleared.

Throws:

Exception