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 . |