Interface | Description |
---|---|
DataSourceWriter |
A data source writer that is returned by
WriteSupport.createWriter(String, StructType, SaveMode, DataSourceOptions) /
StreamWriteSupport.createStreamWriter(
String, StructType, OutputMode, DataSourceOptions) . |
DataWriter<T> |
A data writer returned by
DataWriterFactory.createDataWriter(int, int) and is
responsible for writing data for an input RDD partition. |
DataWriterFactory<T> |
A factory of
DataWriter returned by DataSourceWriter.createWriterFactory() ,
which is responsible for creating and initializing the actual data writer at executor side. |
SupportsWriteInternalRow |
A mix-in interface for
DataSourceWriter . |
WriterCommitMessage |
A commit message returned by
DataWriter.commit() and will be sent back to the driver side
as the input parameter of DataSourceWriter.commit(WriterCommitMessage[]) . |