Package | Description |
---|---|
org.apache.flink.table.store.connector.sink | |
org.apache.flink.table.store.table | |
org.apache.flink.table.store.table.sink |
Constructor and Description |
---|
StoreCommitter(TableCommit commit) |
Modifier and Type | Method and Description |
---|---|
TableCommit |
SupportsWrite.newCommit(String commitUser) |
TableCommit |
AbstractFileStoreTable.newCommit(String commitUser) |
Modifier and Type | Method and Description |
---|---|
TableCommit |
TableCommit.withCreateEmptyCommit(boolean createEmptyCommit) |
TableCommit |
TableCommit.withLock(Lock lock) |
TableCommit |
TableCommit.withOverwritePartition(Map<String,String> overwritePartition) |
TableCommit |
TableCommit.withOverwritePartitions(List<Map<String,String>> overwritePartitions) |
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.