返回用于 SimpleDataSourceStreamReader 读取数据的实例。
Syntax
simpleStreamReader(schema: StructType)
参数
| 参数 | 类型 | 说明 |
|---|---|---|
schema |
结构类型 | 要读取的数据的架构。 |
退货
SimpleDataSourceStreamReader
此数据源的读取器实例。
备注
必须为可读流式处理数据源实现其中 simpleStreamReader() 一个，并且 streamReader() 必须实现该数据源。 Spark 检查是否 streamReader() 首先实现，并创建一个 DataSourceStreamReader 读取数据（如果是）。
simpleStreamReader() 仅在未实现时 streamReader() 调用。