Package | Description |
---|---|
com.neurosys.bi.reporting | |
com.neurosys.etl.connectors | |
com.neurosys.etl.excel.readers | |
com.neurosys.etl.readers | |
com.neurosys.messenger.processors.readers |
Modifier and Type | Class and Description |
---|---|
class |
AbstractProcessBasedReporter<TUPLE_IN,RECORD_OUT,STATE>
Support generic Process Aware aspects for Report operations and their boiler plate management
|
Modifier and Type | Method and Description |
---|---|
void |
SimpleBufferedConnector.connectAndStream(RealTimeLineReader<T> parser,
RealTimeWriter<T> writer) |
void |
Connector.connectAndStream(RealTimeLineReader<T> parser,
RealTimeWriter<T> writer)
Synchronous call to connect to the source , parse and write it.
|
Modifier and Type | Class and Description |
---|---|
class |
ExcelContextualReader<T>
Reads an Excel sheet with Context in mind, supporting things like Look Aheads etc.
|
class |
ExcelRowByRowReader<T>
Parse an Excel File Row by Row; the Row is represented by A simple List of values.
|
Modifier and Type | Interface and Description |
---|---|
interface |
ResourceAwareRealTimeLineReader<T>
A
RealTimeLineReader that is aware of other aspects of the resource it is reading in addition to just the line its reading |
interface |
TupleContextAwareReader<I,O>
A special
RealTimeLineReader that provides an option to retrieve the next() record with the
context of the original tuple/record/object that resulted in the output entity from next. |
Modifier and Type | Class and Description |
---|---|
class |
AbstractReader<TUPLE_IN,RECORD_OUT,STATE>
Support generic Process Aware aspects for Read operations and their boiler plate management
|
class |
BaseIterativeProcessor<TUPLE_IN,RECORD_OUT,STATE>
Support generic Process Aware aspects for Read operations and their boiler plate management
|
class |
ChainIterativeReader<TUPLE_IN,RECORD_OUT,STATE>
Chain multiple
BaseIterativeProcessor s |
class |
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 |
class |
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. |
Modifier and Type | Class and Description |
---|---|
class |
IMAPMailBoxReader
Reads a Mail Box using IMAP protocol
|
Copyright © 2018. All rights reserved.