| 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 | Class and Description |
|---|---|
class |
AppendOnlyWriter
A
RecordWriter implementation that only accepts records which are always insert
operations and don't have any unique keys or sort keys. |
| Modifier and Type | Class and Description |
|---|---|
class |
MergeTreeWriter
A
RecordWriter to write records and generate CompactIncrement. |
| Modifier and Type | Field and Description |
|---|---|
RecordWriter<T> |
AbstractFileStoreWrite.WriterContainer.writer |
| Modifier and Type | Method and Description |
|---|---|
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) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
AbstractFileStoreWrite.notifyNewWriter(RecordWriter<T> writer) |
protected void |
MemoryFileStoreWrite.notifyNewWriter(RecordWriter<T> writer) |
| Constructor and Description |
|---|
WriterContainer(RecordWriter<T> writer,
int totalBuckets,
IndexMaintainer<T> indexMaintainer,
DeletionVectorsMaintainer deletionVectorsMaintainer,
Long baseSnapshotId) |
| Modifier and Type | Class and Description |
|---|---|
class |
PostponeBucketWriter
RecordWriter for bucket = -2 tables. |
| Modifier and Type | Interface and Description |
|---|---|
interface |
BatchRecordWriter
Write
BundleRecords directly. |
Copyright © 2023–2025 The Apache Software Foundation. All rights reserved.