Del via


streamReader

Returns a DataSourceStreamReader instance for reading streaming data.

Added in Databricks Runtime 15.2

Syntax

streamReader(schema: StructType)

Parameters

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

Returns

DataSourceStreamReader

A reader instance for this streaming data source.

Notes

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