ContinuousReadSupport¶

ContinuousReadSupport is the <> of the DataSourceV2 for <> with a <> for Continuous Stream Processing.

[[contract]][[createContinuousReader]] ContinuousReadSupport defines a single createContinuousReader method to create a ContinuousReader.

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

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

[[implementations]] .ContinuousReadSupports [cols="30,70",options="header",width="100%"] |=== | ContinuousReadSupport | Description

| ContinuousMemoryStream | [[ContinuousMemoryStream]] Data source provider for memory format

| KafkaSourceProvider | [[KafkaSourceProvider]] Data source provider for kafka format

| RateStreamProvider | [[RateStreamProvider]] Data source provider for rate format

| TextSocketSourceProvider | [[TextSocketSourceProvider]] Data source provider for socket format

|===