| Class | Description |
|---|---|
| DataFileReplicatedReadSource |
This class partition the datapoints using the LocalCompleteTextInputPartitioner to partition
the complete file as a one partition.
|
| DataFileSink<T> |
This class receives the message from the DataFileSource and writes the output into the DataObject
|
| DataFileSplittedReadSource<T> |
This class is responsible for partition the datapoints which is based on the task parallelism
value.
|
| DataObjectCSVSource | |
| DataObjectSink<T> |
This class receives the message from the DataObjectSource and writes the output into the
DataObject.
|
| DataObjectSource<T> |
This class is responsible for partition the datapoints which is based on the task parallelism
value.
|