Spark が end 以下のオフセットのすべてのデータの処理を完了し、将来 end より大きいオフセットのみを要求することをソースに通知します。
Databricks Runtime 15.3 で追加されました
構文
commit(end: dict)
パラメーター
| パラメーター | タイプ | 説明 |
|---|---|---|
end |
辞書 | ストリーミング クエリがこのソースに対して処理した最新のオフセット。 |
このブラウザーはサポートされなくなりました。
Microsoft Edge にアップグレードすると、最新の機能、セキュリティ更新プログラム、およびテクニカル サポートを利用できます。
Spark が end 以下のオフセットのすべてのデータの処理を完了し、将来 end より大きいオフセットのみを要求することをソースに通知します。
Databricks Runtime 15.3 で追加されました
commit(end: dict)
| パラメーター | タイプ | 説明 |
|---|---|---|
end |
辞書 | ストリーミング クエリがこのソースに対して処理した最新のオフセット。 |