void stop()BaseStreamingSource Contract — Base of Streaming Readers and Sources
BaseStreamingSource is the abstraction of streaming readers and sources that can be stopped.
The main purpose of BaseStreamingSource is to share a common abstraction between the former Data Source API V1 (Source API) and the modern Data Source API V2 (until Spark Structured Streaming migrates to the Data Source API V2 fully).
| Method | Description |
|---|---|
|
Stops the streaming source or reader (and frees up any resources it may have allocated) Used when:
|
| BaseStreamingSource | Description |
|---|---|
Data source readers in Continuous Stream Processing (based on Data Source API V2) |
|
Base implementation of ContinuousMemoryStream (for Continuous Stream Processing) and MemoryStream (for Micro-Batch Stream Processing) |
|
Data source readers in Micro-Batch Stream Processing (based on Data Source API V2) |
|
Streaming sources for Micro-Batch Stream Processing (based on Data Source API V1) |