特定の開始オフセットと終了オフセットの間で使用可能なすべてのデータを読み取ります。
このメソッドは、バッチを確定的に再読み取りするために、障害復旧中に呼び出されます。
Databricks Runtime 15.3 で追加されました
構文
readBetweenOffsets(start: dict, end: dict)
パラメーター
| パラメーター | タイプ | 説明 |
|---|---|---|
start |
辞書 | 読み取り開始オフセット。 |
end |
辞書 | 読み取りが停止するオフセット。 |
返品
Iterator[Tuple]
開始オフセットと終了オフセットの間のすべてのレコード。