commit (DataSourceStreamReader)

Informa al origen de que Spark ha completado el procesamiento de todos los datos para desplazamientos inferiores o iguales a end y solo solicitará desplazamientos mayores que end en el futuro.

Agregado en Databricks Runtime 15.2

Sintaxis

commit(end: dict)

Parámetros

Parámetro Tipo Descripción
end diccionario Desplazamiento más reciente que la consulta de streaming ha procesado para este origen.