Package | Description |
---|---|
org.apache.paimon.deletionvectors | |
org.apache.paimon.deletionvectors.append | |
org.apache.paimon.index | |
org.apache.paimon.operation | |
org.apache.paimon.table.source |
Modifier and Type | Method and Description |
---|---|
static DeletionVector |
DeletionVector.read(FileIO fileIO,
DeletionFile deletionFile) |
DeletionVector |
DeletionVectorsIndexFile.readDeletionVector(DeletionFile deletionFile) |
Modifier and Type | Method and Description |
---|---|
static DeletionVector.Factory |
DeletionVector.factory(FileIO fileIO,
List<DataFileMeta> files,
List<DeletionFile> deletionFiles) |
Map<String,DeletionVector> |
DeletionVectorsIndexFile.readDeletionVector(Map<String,DeletionFile> dataFileToDeletionFiles)
Reads deletion vectors from a list of DeletionFile which belong to a same index file.
|
Modifier and Type | Method and Description |
---|---|
DeletionFile |
UnawareAppendDeletionFileMaintainer.getDeletionFile(String dataFile) |
DeletionFile |
UnawareAppendDeletionFileMaintainer.notifyRemovedDeletionVector(String dataFile) |
Modifier and Type | Method and Description |
---|---|
Map<String,DeletionFile> |
IndexFileHandler.scanDVIndex(Long snapshotId,
BinaryRow partition,
int bucket) |
Modifier and Type | Method and Description |
---|---|
RecordReader<KeyValue> |
MergeFileSplitRead.createMergeReader(BinaryRow partition,
int bucket,
List<DataFileMeta> files,
List<DeletionFile> deletionFiles,
boolean keepDelete) |
RecordReader<KeyValue> |
MergeFileSplitRead.createNoMergeReader(BinaryRow partition,
int bucket,
List<DataFileMeta> files,
List<DeletionFile> deletionFiles,
boolean onlyFilterKey) |
Modifier and Type | Method and Description |
---|---|
static DeletionFile |
DeletionFile.deserialize(DataInputView in) |
Modifier and Type | Method and Description |
---|---|
Optional<List<DeletionFile>> |
DataSplit.beforeDeletionFiles() |
Optional<DeletionFile> |
DeletionFile.Factory.create(String fileName) |
Optional<List<DeletionFile>> |
DataSplit.deletionFiles() |
default Optional<List<DeletionFile>> |
Split.deletionFiles()
Return the deletion file of the data file, indicating which row in the data file was deleted.
|
static List<DeletionFile> |
DeletionFile.deserializeList(DataInputView in) |
Modifier and Type | Method and Description |
---|---|
static void |
DeletionFile.serialize(DataOutputView out,
DeletionFile file) |
Modifier and Type | Method and Description |
---|---|
static DeletionFile.Factory |
DeletionFile.factory(List<DataFileMeta> files,
List<DeletionFile> deletionFiles) |
static void |
DeletionFile.serializeList(DataOutputView out,
List<DeletionFile> files) |
DataSplit.Builder |
DataSplit.Builder.withBeforeDeletionFiles(List<DeletionFile> beforeDeletionFiles) |
DataSplit.Builder |
DataSplit.Builder.withDataDeletionFiles(List<DeletionFile> dataDeletionFiles) |
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.