org.apache.paimon.table.sink

Interface BatchTableWrite

All Superinterfaces:

AutoCloseable, TableWrite

All Known Subinterfaces:

InnerTableWrite

All Known Implementing Classes:

TableWriteImpl

@Public
public interface BatchTableWrite
extends TableWrite

A TableWrite for batch processing. Recommended for one-time committing.

Since:

0.4.0

Method Summary

Modifier and Type	Method and Description
List<CommitMessage>	prepareCommit() Prepare commit for TableCommit.

Methods inherited from interface org.apache.paimon.table.sink.TableWrite

compact, getBucket, getPartition, withInsertOnly, withIOManager, withMemoryPool, withMetricRegistry, write, write, writeBundle

Methods inherited from interface java.lang.AutoCloseable

close

Method Detail

prepareCommit

List<CommitMessage> prepareCommit()
                           throws Exception

Prepare commit for TableCommit. Collect incremental files for this write.

Throws:

Exception

See Also:

BatchTableCommit.commit(java.util.List<org.apache.paimon.table.sink.CommitMessage>)