Notitie
Voor toegang tot deze pagina is autorisatie vereist. U kunt proberen u aan te melden of de directory te wijzigen.
Voor toegang tot deze pagina is autorisatie vereist. U kunt proberen de mappen te wijzigen.
Deze microbatch doorvoert met een lijst met doorvoerberichten.
Deze methode wordt aangeroepen op het stuurprogramma wanneer alle taken zijn uitgevoerd. De doorvoerberichten worden verzameld vanuit de write() methode-aanroep van elke taak en doorgegeven aan deze methode. De implementatie moet de doorvoerberichten gebruiken om de microbatch in de streaming-sink door te voeren.
Syntaxis
commit(messages: List[Optional[WriterCommitMessage]], batchId: int)
Parameterwaarden
| Kenmerk | Typ | Beschrijving |
|---|---|---|
messages |
lijst met WriterCommitMessage | Een lijst met doorvoerberichten. Als een schrijftaak mislukt, wordt het doorvoerbericht weergegeven None. |
batchId |
int | Een geheel getal dat een batch met gegevens identificeert die wordt geschreven. Het gehele getal neemt toe met 1 terwijl elke microbatch is verwerkt. |