commit (SimpleDataSourceStreamReader)

Informa a fonte que o Spark completou o processamento de todos os dados para deslocamentos menores ou iguais a end e que só irá solicitar deslocamentos maiores que end no futuro.

Adicionado no Databricks Runtime 15.3

Sintaxe

commit(end: dict)

Parâmetros

Parâmetro Tipo Descrição
end dicionário O último deslocamento que a consulta de streaming processou para esta fonte.
  • Last updated on