@Experimental public interface DeltaBatchWrite extends BatchWrite
Modifier and Type | Method and Description |
---|---|
DeltaWriterFactory |
createBatchWriterFactory(PhysicalWriteInfo info)
Creates a writer factory which will be serialized and sent to executors.
|
abort, commit, onDataWriterCommit, useCommitCoordinator
DeltaWriterFactory createBatchWriterFactory(PhysicalWriteInfo info)
BatchWrite
If this method fails (by throwing an exception), the action will fail and no Spark job will be submitted.
createBatchWriterFactory
in interface BatchWrite
info
- Physical information about the input data that will be written to this table.