返回用于 DataSourceStreamReader 读取流数据的实例。
在 Databricks Runtime 15.2 中添加
Syntax
streamReader(schema: StructType)
参数
| 参数 | 类型 | 说明 |
|---|---|---|
schema |
结构类型 | 要读取的数据的架构。 |
退货
DataSourceStreamReader
此流式处理数据源的读取器实例。
备注
必须为可读流式处理数据源实现其中 simpleStreamReader() 一个，并且 streamReader() 必须实现该数据源。