abort (DataSourceStreamWriter)

Przerywa tę mikrobajtę z powodu błędów zadań.

Ta metoda jest wywoływana na sterowniku, gdy co najmniej jedno zadanie nie powiodło się. Komunikaty zatwierdzenia są zbierane z write() wywołania metody z każdego zadania i przekazywane do tej metody. Implementacja powinna użyć komunikatów zatwierdzenia, aby przerwać mikrobajt w ujściu przesyłania strumieniowego.

Składnia

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

Parametry

Parameter Typ Opis
messages lista składników WriterCommitMessage Lista komunikatów zatwierdzeń. Jeśli zadanie zapisu zakończy się niepowodzeniem, komunikat zatwierdzenia będzie następujący: None.
batchId int Liczba całkowita, która jednoznacznie identyfikuje partię zapisywanych danych. Liczba całkowita zwiększa się o 1, przy każdym przetworzonym mikrobajcie.