readBetweenOffsets (SimpleDataSourceStreamReader)

指定された開始オフセットと終了オフセットの間にある利用可能なすべてのデータを読み取ります。

このメソッドは、障害復旧時にバッチを確定的に再読み込みするために呼び出されます。

Databricks Runtime 15.3で追加されました

構文

readBetweenOffsets(start: dict, end: dict)

パラメーター

パラメーター	Type	説明
start	辞書	読み取りを開始するオフセット。
end	辞書	読み取りが停止するオフセット値。

戻り値

Iterator[Tuple]

開始オフセットと終了オフセットの間のすべてのレコード。