| Package | Description |
|---|---|
| org.apache.paimon.append | |
| org.apache.paimon.mergetree | |
| org.apache.paimon.operation | |
| org.apache.paimon.postpone | |
| org.apache.paimon.utils |
| Modifier and Type | Method and Description |
|---|---|
CommitIncrement |
AppendOnlyWriter.prepareCommit(boolean waitCompaction) |
| 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,
boolean statsDenseStore) |
| Modifier and Type | Method and Description |
|---|---|
CommitIncrement |
MergeTreeWriter.prepareCommit(boolean waitCompaction) |
| 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) |
| Modifier and Type | Field and Description |
|---|---|
protected CommitIncrement |
FileStoreWrite.State.commitIncrement |
| Modifier and Type | Method and Description |
|---|---|
protected MergeTreeWriter |
KeyValueFileStoreWrite.createWriter(BinaryRow partition,
int bucket,
List<DataFileMeta> restoreFiles,
long restoredMaxSeqNumber,
CommitIncrement restoreIncrement,
ExecutorService compactExecutor,
DeletionVectorsMaintainer dvMaintainer) |
protected abstract RecordWriter<T> |
AbstractFileStoreWrite.createWriter(BinaryRow partition,
int bucket,
List<DataFileMeta> restoreFiles,
long restoredMaxSeqNumber,
CommitIncrement restoreIncrement,
ExecutorService compactExecutor,
DeletionVectorsMaintainer deletionVectorsMaintainer) |
protected RecordWriter<InternalRow> |
AppendOnlyFileStoreWrite.createWriter(BinaryRow partition,
int bucket,
List<DataFileMeta> restoredFiles,
long restoredMaxSeqNumber,
CommitIncrement restoreIncrement,
ExecutorService compactExecutor,
DeletionVectorsMaintainer dvMaintainer) |
| Constructor and Description |
|---|
State(BinaryRow partition,
int bucket,
int totalBuckets,
long baseSnapshotId,
long lastModifiedCommitIdentifier,
Collection<DataFileMeta> dataFiles,
long maxSequenceNumber,
IndexMaintainer<T> indexMaintainer,
DeletionVectorsMaintainer deletionVectorsMaintainer,
CommitIncrement commitIncrement) |
| Modifier and Type | Method and Description |
|---|---|
CommitIncrement |
PostponeBucketWriter.prepareCommit(boolean waitCompaction) |
| Modifier and Type | Method and Description |
|---|---|
protected PostponeBucketWriter |
PostponeBucketFileStoreWrite.createWriter(BinaryRow partition,
int bucket,
List<DataFileMeta> restoreFiles,
long restoredMaxSeqNumber,
CommitIncrement restoreIncrement,
ExecutorService compactExecutor,
DeletionVectorsMaintainer deletionVectorsMaintainer) |
| Modifier and Type | Method and Description |
|---|---|
CommitIncrement |
RecordWriter.prepareCommit(boolean waitCompaction)
Prepare for a commit.
|
Copyright © 2023–2025 The Apache Software Foundation. All rights reserved.