pyspark.sql.datasource.DataSource.streamReader

DataSource.streamReader(schema)

Returns a DataSourceStreamReader instance for reading streaming data.

One of simpleStreamReader() and streamReader() must be implemented for readable streaming data source.

Parameters:

schemaStructType

The schema of the data to be read.

Returns:

readerDataSourceStreamReader

A reader instance for this streaming data source.