Skip to main content

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.