org.apache.spark.sql.connector.write

Interface WriterCommitMessage

All Superinterfaces:

java.io.Serializable

@Evolving
public interface WriterCommitMessage
extends java.io.Serializable

A commit message returned by DataWriter.commit() and will be sent back to the driver side as the input parameter of BatchWrite.commit(WriterCommitMessage[]) or StreamingWrite.commit(long, WriterCommitMessage[]).

This is an empty interface, data sources should define their own message class and use it when generating messages at executor side and handling the messages at driver side.

Since:

3.0.0