Class and Description |
---|
BaseIterativeProcessor
Support generic Process Aware aspects for Read operations and their boiler plate management
|
RealTimeLineReader
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
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
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 and Description |
---|
BaseIterativeProcessor
Support generic Process Aware aspects for Read operations and their boiler plate management
|
Class and Description |
---|
RealTimeLineReader
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.
|
Class and Description |
---|
AbstractReader
Support generic Process Aware aspects for Read operations and their boiler plate management
|
BaseIterativeProcessor
Support generic Process Aware aspects for Read operations and their boiler plate management
|
OneLoadReader
Reads some Data Source and returns a List
|
RealTimeLineReader
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
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
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 and Description |
---|
AbstractReader
Support generic Process Aware aspects for Read operations and their boiler plate management
|
BaseIterativeProcessor
Support generic Process Aware aspects for Read operations and their boiler plate management
|
RealTimeLineReader
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
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
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 and Description |
---|
AbstractReader
Support generic Process Aware aspects for Read operations and their boiler plate management
|
Class and Description |
---|
OneLoadReader
Reads some Data Source and returns a List
|
Class and Description |
---|
OneLoadReader
Reads some Data Source and returns a List
|
RealTimeLineReader
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
A
RealTimeLineReader that is aware of other aspects of the resource it is reading in addition to just the line its reading |
Class and Description |
---|
AbstractReader
Support generic Process Aware aspects for Read operations and their boiler plate management
|
Copyright © 2018. All rights reserved.