PySparkリファレンスクラスデータソースストリームリーダーcommitこのページの見出しコミット(DataSourceStreamReader) Sparkがend以下のオフセットのすべてのデータの処理を完了し、今後はendより大きいオフセットのみを要求することをソースに通知します。 Databricks Runtime 15.2で追加されました 構文 commit(end: dict) パラメーター パラメーターType説明end辞書このソースに対してストリーミングクエリが処理した最新のオフセット。