Uses of Class
org.apache.paimon.utils.CommitIncrement

Packages that use CommitIncrement

Package	Description
org.apache.paimon.append
org.apache.paimon.mergetree
org.apache.paimon.operation
org.apache.paimon.utils

Uses of CommitIncrement in org.apache.paimon.append

Methods in org.apache.paimon.append that return CommitIncrement

Modifier and Type	Method and Description
CommitIncrement	AppendOnlyWriter.prepareCommit(boolean waitCompaction)

Constructors in org.apache.paimon.append with parameters of type CommitIncrement

Constructor and Description

AppendOnlyWriter(FileIO fileIO, IOManager ioManager, long schemaId, FileFormat fileFormat, long targetFileSize, RowType writeSchema, long maxSequenceNumber, CompactManager compactManager, IOFunction<List<DataFileMeta>,RecordReaderIterator<InternalRow>> bucketFileRead, boolean forceCompact, DataFilePathFactory pathFactory, CommitIncrement increment, boolean useWriteBuffer, boolean spillable, String fileCompression, CompressOptions spillCompression, SimpleColStatsCollector.Factory[] statsCollectors, MemorySize maxDiskSize, FileIndexOptions fileIndexOptions, boolean asyncFileWrite)

Uses of CommitIncrement in org.apache.paimon.mergetree

Methods in org.apache.paimon.mergetree that return CommitIncrement

Modifier and Type	Method and Description
CommitIncrement	MergeTreeWriter.prepareCommit(boolean waitCompaction)

Constructors in org.apache.paimon.mergetree with parameters of type CommitIncrement

Constructor and Description

MergeTreeWriter(boolean writeBufferSpillable, MemorySize maxDiskSize, int sortMaxFan, CompressOptions sortCompression, IOManager ioManager, CompactManager compactManager, long maxSequenceNumber, Comparator<InternalRow> keyComparator, MergeFunction<KeyValue> mergeFunction, KeyValueFileWriterFactory writerFactory, boolean commitForceCompact, CoreOptions.ChangelogProducer changelogProducer, CommitIncrement increment, FieldsComparator userDefinedSeqComparator)

Uses of CommitIncrement in org.apache.paimon.operation

Fields in org.apache.paimon.operation declared as CommitIncrement

Modifier and Type	Field and Description
protected CommitIncrement	FileStoreWrite.State.commitIncrement

Methods in org.apache.paimon.operation with parameters of type CommitIncrement

Modifier and Type	Method and Description
protected RecordWriter<InternalRow>	AppendOnlyFileStoreWrite.createWriter(Long snapshotId, BinaryRow partition, int bucket, List<DataFileMeta> restoredFiles, long restoredMaxSeqNumber, CommitIncrement restoreIncrement, ExecutorService compactExecutor, DeletionVectorsMaintainer dvMaintainer)
protected MergeTreeWriter	KeyValueFileStoreWrite.createWriter(Long snapshotId, BinaryRow partition, int bucket, List<DataFileMeta> restoreFiles, long restoredMaxSeqNumber, CommitIncrement restoreIncrement, ExecutorService compactExecutor, DeletionVectorsMaintainer dvMaintainer)
protected abstract RecordWriter<T>	AbstractFileStoreWrite.createWriter(Long snapshotId, BinaryRow partition, int bucket, List<DataFileMeta> restoreFiles, long restoredMaxSeqNumber, CommitIncrement restoreIncrement, ExecutorService compactExecutor, DeletionVectorsMaintainer deletionVectorsMaintainer)

Constructors in org.apache.paimon.operation with parameters of type CommitIncrement

Constructor and Description
State(BinaryRow partition, int bucket, long baseSnapshotId, long lastModifiedCommitIdentifier, Collection<DataFileMeta> dataFiles, long maxSequenceNumber, IndexMaintainer<T> indexMaintainer, DeletionVectorsMaintainer deletionVectorsMaintainer, CommitIncrement commitIncrement)

Uses of CommitIncrement in org.apache.paimon.utils

Methods in org.apache.paimon.utils that return CommitIncrement

Modifier and Type	Method and Description
CommitIncrement	RecordWriter.prepareCommit(boolean waitCompaction) Prepare for a commit.