commit (DataSourceStreamReader)

Сообщает источнику, что Spark завершил обработку всех данных для смещения меньше или равно end и будет запрашивать смещение только больше, чем end в будущем.

Добавлено в Databricks Runtime 15.2

Синтаксис

commit(end: dict)

Параметры

Параметр	Тип	Описание
end	Дикт	Последнее смещение, обработанное потоковым запросом для этого источника.