@Public public interface StreamTableWrite extends TableWrite
TableWrite
for stream processing. You can use this class to commit multiple times.StreamWriteBuilder
Modifier and Type | Method and Description |
---|---|
List<CommitMessage> |
prepareCommit(boolean waitCompaction,
long commitIdentifier)
Prepare commit for
TableCommit . |
compact, getBucket, getPartition, withInsertOnly, withIOManager, withMemoryPool, withMetricRegistry, write, write, writeBundle
close
List<CommitMessage> prepareCommit(boolean waitCompaction, long commitIdentifier) throws Exception
TableCommit
. Collect incremental files for this write.waitCompaction
- whether to wait for the end of the background compaction.commitIdentifier
- Committed transaction ID, can start from 0. If there are multiple
commits, please increment this ID.Exception
StreamTableCommit.commit(long, java.util.List<org.apache.paimon.table.sink.CommitMessage>)
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.