| Interface | Description |
|---|---|
| ContinuousInputPartitionReader<T> |
A variation on
InputPartitionReader for use with streaming in continuous processing mode. |
| ContinuousReader |
A mix-in interface for
DataSourceReader. |
| MicroBatchReader |
A mix-in interface for
DataSourceReader. |
| PartitionOffset |
Used for per-partition offsets in continuous processing.
|
| Class | Description |
|---|---|
| Offset |
An abstract representation of progress through a
MicroBatchReader or
ContinuousReader. |