| Class | Description |
|---|---|
| BaseDiskPersistIterSink<T,T1> |
Base class for disk based persisted TSet
|
| CacheGatherSink<T> | |
| CacheIterSink<T> |
An in-memory cached TSet
|
| CacheSingleSink<T> | |
| DiskPersistGatherIterSink<T> | |
| DiskPersistIterIterSink<T> |
A disk based persisted TSet
|
| DiskPersistSingleSink<T> | |
| FileIterSink<T> | |
| FileSink<T> | |
| StoreIterSink<T,T1> |
Base classed used by cache/persist sinks that receive an
Iterator. |
| StreamingCacheSink<T> | |
| StreamingDiskPersistSink<T> |