read （SimpleDataSourceStreamReader）

从开始偏移量读取所有可用数据，并返回下一次读取尝试从中开始的偏移量。

在 Databricks Runtime 15.3 中添加

Syntax

read(start: dict)

参数

退货

Tuple[Iterator[Tuple], dict]

迭代器和听写的元组。 迭代器包含开始偏移后的所有可用记录。 听写是此读取尝试的结束偏移量和下一次读取尝试的开始偏移量。