read (SimpleDataSourceStreamReader)
開始オフセットから利用可能なすべてのデータを読み取り、次の読み取り試行の開始オフセットを返します。
Databricks Runtime 15.3で追加されました
構文
read(start: dict)
パラメーター
パラメーター | Type | 説明 |
|---|---|---|
| 辞書 | 読み取りを開始するオフセット。 |
戻り値
Tuple[Iterator[Tuple], dict]
イテレータと辞書のタプル。イテレータには、開始オフセット以降の利用可能なすべてのレコードが含まれます。この辞書は、今回の読み取り試行の終了オフセットと、次の読み取り試行の開始オフセットを表します。