Modifier and Type | Method and Description |
---|---|
Optional<IndexFileMeta> |
CompactDeletionFile.getOrCompute() |
Optional<IndexFileMeta> |
CompactDeletionFile.GeneratedDeletionFile.getOrCompute() |
Optional<IndexFileMeta> |
CompactDeletionFile.LazyCompactDeletionFile.getOrCompute() |
Constructor and Description |
---|
GeneratedDeletionFile(IndexFileMeta deletionFile,
IndexFileHandler fileHandler) |
Modifier and Type | Method and Description |
---|---|
List<IndexFileMeta> |
DeletionVectorsIndexFile.write(Map<String,DeletionVector> input)
Write deletion vectors to a new file, the format of this file can be referenced at: PIP-16.
|
List<IndexFileMeta> |
DeletionVectorIndexFileWriter.write(Map<String,DeletionVector> input)
For unaware-bucket mode, this method will write out multiple index files, else, it will write
out only one index file.
|
List<IndexFileMeta> |
DeletionVectorsMaintainer.writeDeletionVectorsIndex()
Write new deletion vectors index file if any modifications have been made.
|
Modifier and Type | Method and Description |
---|---|
Map<String,DeletionVector> |
DeletionVectorsIndexFile.readAllDeletionVectors(IndexFileMeta fileMeta)
Reads all deletion vectors from a specified file.
|
Modifier and Type | Method and Description |
---|---|
Map<String,DeletionVector> |
DeletionVectorsIndexFile.readAllDeletionVectors(List<IndexFileMeta> indexFiles) |
Modifier and Type | Method and Description |
---|---|
IndexFileMeta |
UnawareAppendDeletionFileMaintainer.getIndexFile(String dataFile) |
Modifier and Type | Method and Description |
---|---|
IndexFileMeta |
IndexFileMetaSerializer.fromRow(InternalRow row) |
IndexFileMeta |
IndexFileHandler.writeHashIndex(int[] ints) |
IndexFileMeta |
IndexFileHandler.writeHashIndex(int size,
IntIterator iterator) |
Modifier and Type | Method and Description |
---|---|
List<IndexFileMeta> |
IndexMaintainer.prepareCommit() |
List<IndexFileMeta> |
HashIndexMaintainer.prepareCommit() |
List<IndexFileMeta> |
IndexFileHandler.scan(long snapshotId,
String indexType,
BinaryRow partition,
int bucket) |
Map<Pair<BinaryRow,Integer>,List<IndexFileMeta>> |
IndexFileHandler.scan(long snapshot,
String indexType,
Set<BinaryRow> partitions) |
Map<Pair<BinaryRow,Integer>,List<IndexFileMeta>> |
IndexFileHandler.scan(Snapshot snapshot,
String indexType,
Set<BinaryRow> partitions) |
Optional<IndexFileMeta> |
IndexFileHandler.scanHashIndex(long snapshotId,
BinaryRow partition,
int bucket) |
List<IndexFileMeta> |
IndexFileHandler.writeDeletionVectorsIndex(Map<String,DeletionVector> deletionVectors) |
Modifier and Type | Method and Description |
---|---|
void |
IndexFileHandler.deleteIndexFile(IndexFileMeta file) |
Path |
IndexFileHandler.filePath(IndexFileMeta file) |
IntIterator |
IndexFileHandler.readHashIndex(IndexFileMeta file) |
List<Integer> |
IndexFileHandler.readHashIndexList(IndexFileMeta file) |
InternalRow |
IndexFileMetaSerializer.toRow(IndexFileMeta record) |
Modifier and Type | Method and Description |
---|---|
Map<String,DeletionVector> |
IndexFileHandler.readAllDeletionVectors(List<IndexFileMeta> fileMetas) |
Modifier and Type | Method and Description |
---|---|
List<IndexFileMeta> |
IndexIncrement.deletedIndexFiles() |
List<IndexFileMeta> |
IndexIncrement.newIndexFiles() |
Constructor and Description |
---|
IndexIncrement(List<IndexFileMeta> newIndexFiles) |
IndexIncrement(List<IndexFileMeta> newIndexFiles,
List<IndexFileMeta> deletedIndexFiles) |
IndexIncrement(List<IndexFileMeta> newIndexFiles,
List<IndexFileMeta> deletedIndexFiles) |
Modifier and Type | Method and Description |
---|---|
IndexFileMeta |
IndexManifestEntry.indexFile() |
Constructor and Description |
---|
IndexManifestEntry(FileKind kind,
BinaryRow partition,
int bucket,
IndexFileMeta indexFile) |
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.