ContinuousReader createContinuousReader(
Optional<StructType> schema,
String checkpointLocation,
DataSourceOptions options)
ContinuousReadSupport Contract — Data Sources with ContinuousReaders
ContinuousReadSupport
is the extension of the DataSourceV2
for data sources with a ContinuousReader for Continuous Stream Processing.
ContinuousReadSupport
defines a single createContinuousReader
method to create a ContinuousReader.
createContinuousReader
is used when:
-
ContinuousExecution
is requested to run a streaming query (and finds ContinuousExecutionRelations in the analyzed logical plan) -
DataStreamReader
is requested to create a streaming query for a ContinuousReadSupport data source
ContinuousReadSupport | Description |
---|---|