커밋 메시지 목록을 사용하여 이 마이크로배치를 커밋합니다.
이 메서드는 모든 작업이 성공적으로 실행될 때 드라이버에서 호출됩니다. 커밋 메시지는 각 태스크의 write() 메서드 호출에서 수집되고 이 메서드로 전달됩니다. 구현은 커밋 메시지를 사용하여 스트리밍 싱크에서 마이크로배치를 커밋해야 합니다.
문법
commit(messages: List[Optional[WriterCommitMessage]], batchId: int)
매개 변수
| 매개 변수 | 유형 | 설명 |
|---|---|---|
messages |
WriterCommitMessage 목록 | 커밋 메시지 목록입니다. 쓰기 작업이 실패하면 커밋 메시지가 None됩니다. |
batchId |
int | 기록되는 데이터의 일괄 처리를 고유하게 식별하는 정수입니다. 각 마이크로배치가 처리될 때마다 정수가 1씩 증가합니다. |