ContinuousReadSupport Contract — Data Sources with ContinuousReaders

ContinuousReadSupport is the abstraction of data sources with a ContinuousReader in Continuous Stream Processing.

ContinuousReadSupport defines a single createContinuousReader method to create a ContinuousReader.

ContinuousReader createContinuousReader(
  Optional<StructType> schema,
  String checkpointLocation,
  DataSourceOptions options)

createContinuousReader is used when:

Table 1. ContinuousReadSupports
ContinuousReadSupport Description

ContinuousMemoryStream

KafkaSourceProvider

RateStreamProvider

TextSocketSourceProvider

results matching ""

    No results matching ""