メインコンテンツまでスキップ

コミット(DataSourceStreamReader)

Sparkがend以下のオフセットのすべてのデータの処理を完了し、今後はendより大きいオフセットのみを要求することをソースに通知します。

Databricks Runtime 15.2で追加されました

構文

commit(end: dict)

パラメーター

パラメーター

Type

説明

end

辞書

このソースに対してストリーミングクエリが処理した最新のオフセット。

このページの見出し