org.apache.paimon.table.sink

Interface InnerTableCommit

All Superinterfaces:

AutoCloseable, BatchTableCommit, StreamTableCommit, TableCommit

All Known Implementing Classes:

TableCommitImpl

public interface InnerTableCommit
extends StreamTableCommit, BatchTableCommit

Inner TableCommit contains overwrite setter.

Method Summary

Modifier and Type	Method and Description
InnerTableCommit	ignoreEmptyCommit(boolean ignoreEmptyCommit) If this is set to true, when there is no new data, no snapshot will be generated.
InnerTableCommit	withMetricRegistry(MetricRegistry registry)
InnerTableCommit	withOverwrite(Map<String,String> staticPartition) Overwrite writing, same as the 'INSERT OVERWRITE T PARTITION (...)' semantics of SQL.

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

commit, filterAndCommit

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

commit, truncateTable

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

abort

Methods inherited from interface java.lang.AutoCloseable

close

Method Detail

withOverwrite

InnerTableCommit withOverwrite(@Nullable
                               Map<String,String> staticPartition)

Overwrite writing, same as the 'INSERT OVERWRITE T PARTITION (...)' semantics of SQL.

ignoreEmptyCommit

InnerTableCommit ignoreEmptyCommit(boolean ignoreEmptyCommit)

If this is set to true, when there is no new data, no snapshot will be generated. By default, empty commit is ignored.

• For Streaming: the default value of 'ignoreEmptyCommit' is false.
• For Batch: the default value of 'ignoreEmptyCommit' is true.

If there are no new files or compact files at the same time, no new commit will be generated regardless of the configuration (No one trigger commit interface).

withMetricRegistry

InnerTableCommit withMetricRegistry(MetricRegistry registry)