simpleStreamReader

Returns a SimpleDataSourceStreamReader instance for reading data.

Syntax

simpleStreamReader(schema: StructType)

Parameters

Parameter	Type	Description
schema	StructType	The schema of the data to be read.

Returns

SimpleDataSourceStreamReader

A reader instance for this data source.

Notes

One of simpleStreamReader() and streamReader() must be implemented for a readable streaming data source. Spark checks whether streamReader() is implemented first and creates a DataSourceStreamReader to read data if so. simpleStreamReader() is only invoked when streamReader() is not implemented.