Package | Description |
---|---|
org.apache.paimon.table | |
org.apache.paimon.table.sink |
Modifier and Type | Method and Description |
---|---|
InnerTableCommit |
InnerTable.newCommit(String commitUser) |
default InnerTableCommit |
ReadonlyTable.newCommit(String commitUser) |
Modifier and Type | Class and Description |
---|---|
class |
TableCommitImpl
An abstraction layer above
FileStoreCommit to provide snapshot commit and expiration. |
Modifier and Type | Method and Description |
---|---|
InnerTableCommit |
InnerTableCommit.ignoreEmptyCommit(boolean ignoreEmptyCommit)
If this is set to true, when there is no new data, no snapshot will be generated.
|
InnerTableCommit |
TableCommitImpl.withMetricRegistry(MetricRegistry registry) |
InnerTableCommit |
InnerTableCommit.withMetricRegistry(MetricRegistry registry) |
InnerTableCommit |
InnerTableCommit.withOverwrite(Map<String,String> staticPartition)
Overwrite writing, same as the 'INSERT OVERWRITE T PARTITION (...)' semantics of SQL.
|
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.