| Class | Description |
|---|---|
| CollectionSource<T> | |
| DataPartitionSourceFunc<T> | |
| DiskPartitionBackedSource<T> | |
| DiskPartitionBackedSourceWrapper<T> |
Wraps the data partition created by underlying
DiskPartitionBackedSource. |
| FileSource<T> | |
| HadoopConfSerializeWrapper |
Hadoop configuration is no serializable, so we created this
wrapper to serialize it manually
|
| HadoopSource<K,V,F extends <any>> |
A Hadoop source for reading the values.
|
| HadoopSourceWithMap<K,V,F extends <any>,I> |
A Hadoop source for reading the values.
|