| Interface | Description |
|---|---|
| ContinuousPartitionReader<T> |
A variation on
PartitionReader for use with continuous streaming processing. |
| ContinuousPartitionReaderFactory |
A variation on
PartitionReaderFactory that returns ContinuousPartitionReader
instead of PartitionReader. |
| ContinuousStream |
A
SparkDataStream for streaming queries with continuous mode. |
| MicroBatchStream |
A
SparkDataStream for streaming queries with micro-batch mode. |
| PartitionOffset |
Used for per-partition offsets in continuous processing.
|
| SparkDataStream |
The base interface representing a readable data stream in a Spark streaming query.
|
| Class | Description |
|---|---|
| Offset |
An abstract representation of progress through a
MicroBatchStream or
ContinuousStream. |