@InterfaceStability.Unstable public interface SupportsWriteInternalRow extends DataSourceWriter
DataSourceWriter
. Data source writers can implement this
interface to write InternalRow
directly and avoid the row conversion at Spark side.
This is an experimental and unstable interface, as InternalRow
is not public and may get
changed in the future Spark versions.Modifier and Type | Method and Description |
---|---|
DataWriterFactory<org.apache.spark.sql.catalyst.InternalRow> |
createInternalRowWriterFactory() |
default DataWriterFactory<Row> |
createWriterFactory()
Creates a writer factory which will be serialized and sent to executors.
|
abort, commit
default DataWriterFactory<Row> createWriterFactory()
DataSourceWriter
createWriterFactory
in interface DataSourceWriter
DataWriterFactory<org.apache.spark.sql.catalyst.InternalRow> createInternalRowWriterFactory()