abortar (DataSourceStreamWriter)

Interrompe este microlote devido a falhas nas tarefas.

Este método é invocado no driver quando uma ou mais tarefas falham. As mensagens de commit são coletadas da chamada do método write() de cada tarefa e passadas para este método. A implementação deve usar as mensagens commit para abortar o microbatch no receptor de transmissão.

Sintaxe

abort(messages: List[Optional[WriterCommitMessage]], batchId: int)

Parâmetros

Parâmetro	Tipo	Descrição
messages	lista de WriterCommitMessage	Uma lista de mensagens de commit. Se uma tarefa de escrita falhar, a mensagem commit será None.
batchId	int	Um número inteiro que identifica de forma única um lote de dados que está sendo gravado. O número inteiro aumenta em 1 a cada microlote processado.