Package com.neurosys.etl.readers

Interface Summary

Interface	Description
OneLoadReader<T>	Reads some Data Source and returns a List
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.
ResourceAwareRealTimeLineReader<T>	A RealTimeLineReader that is aware of other aspects of the resource it is reading in addition to just the line its reading
TransformAwareReader	A reader that has a Transformer
TupleContextAwareReader<I,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.

Class Summary

Class	Description
AbstractReader<TUPLE_IN,RECORD_OUT,STATE>	Support generic Process Aware aspects for Read operations and their boiler plate management
BaseIterativeProcessor<TUPLE_IN,RECORD_OUT,STATE>	Support generic Process Aware aspects for Read operations and their boiler plate management
ChainIterativeReader<TUPLE_IN,RECORD_OUT,STATE>	Chain multiple BaseIterativeProcessors
ExecuteJobReader	Simply executes a Job If the BaseIterativeProcessor.getTransformer() is a TransformerChain then the first level chain elements are each considered a Different Job and each passed the BaseIterativeProcessor.getParams() If the BaseIterativeProcessor.getTransformer() return any String or List of String then those will be added to BaseIterativeProcessor.getMessages() TODO: Add unit test case for Single & multiple Jobs in TransformerChain
FileReader<T,S>	For a given Root Folder (File as a Resource), read each file in all the directories (nested optional); and for each file return a n entity of type T.