Class | Description |
---|---|
ArrowBasedSinkFunction<T> |
This class is responsible for calling the twister2 arrow file writer class
and add the data to the list in the arrow file writer and commit the data.
|
ArrowBasedSourceFunction | |
CSVBasedSourceFunction | |
ListBasedSourceFunction<T> | |
MapBasedSourceFunction<K,V> | |
TextBasedSourceFunction |