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