Package | Description |
---|---|
org.apache.paimon.append | |
org.apache.paimon.mergetree | |
org.apache.paimon.operation | |
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(Long snapshotId,
BinaryRow partition,
int bucket,
List<DataFileMeta> restoreFiles,
long restoredMaxSeqNumber,
CommitIncrement restoreIncrement,
ExecutorService compactExecutor,
DeletionVectorsMaintainer deletionVectorsMaintainer) |
protected RecordWriter<InternalRow> |
AppendOnlyFileStoreWrite.createWriter(Long snapshotId,
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,
IndexMaintainer<T> indexMaintainer,
DeletionVectorsMaintainer deletionVectorsMaintainer,
Long baseSnapshotId) |
Modifier and Type | Interface and Description |
---|---|
interface |
BatchRecordWriter
Write
BundleRecords directly. |
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.