pyspark.sql.datasource.DataSource.streamReader#

DataSource.streamReader(schema)[source]#

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.