Compartilhar via

commit (DataSourceStreamReader)

Informa à fonte que o Spark concluiu o processamento de todos os dados para deslocamentos menores ou iguais end e solicitará apenas deslocamentos maiores do que end no futuro.

Adicionado no Databricks Runtime 15.2

Sintaxe

commit(end: dict)

Parâmetros

Parâmetro Tipo Descrição
end dicionário O deslocamento mais recente que a consulta de streaming processou para essa origem.
  • Last updated on