org.apache.paimon.index

Class IndexFileHandler

java.lang.Object

org.apache.paimon.index.IndexFileHandler

public class IndexFileHandler
extends Object

Handle index files.

Constructor Summary

Constructors

Constructor and Description
IndexFileHandler(SnapshotManager snapshotManager, PathFactory pathFactory, IndexManifestFile indexManifestFile, HashIndexFile hashIndex, DeletionVectorsIndexFile deletionVectorsIndex)

Method Summary

Modifier and Type	Method and Description
void	deleteIndexFile(IndexFileMeta file)
void	deleteIndexFile(IndexManifestEntry file)
void	deleteManifest(String indexManifest)
DeletionVectorsIndexFile	deletionVectorsIndex()
boolean	existsIndexFile(IndexManifestEntry file)
boolean	existsManifest(String indexManifest)
Path	filePath(IndexFileMeta file)
Map<String,DeletionVector>	readAllDeletionVectors(List<IndexFileMeta> fileMetas)
IntIterator	readHashIndex(IndexFileMeta file)
List<Integer>	readHashIndexList(IndexFileMeta file)
List<IndexManifestEntry>	readManifest(String indexManifest)
List<IndexManifestEntry>	readManifestWithIOException(String indexManifest)
List<IndexFileMeta>	scan(long snapshotId, String indexType, BinaryRow partition, int bucket)
Map<Pair<BinaryRow,Integer>,List<IndexFileMeta>>	scan(long snapshot, String indexType, Set<BinaryRow> partitions)
Map<Pair<BinaryRow,Integer>,List<IndexFileMeta>>	scan(Snapshot snapshot, String indexType, Set<BinaryRow> partitions)
List<IndexManifestEntry>	scan(String indexType)
Map<String,DeletionFile>	scanDVIndex(Long snapshotId, BinaryRow partition, int bucket)
List<IndexManifestEntry>	scanEntries()
List<IndexManifestEntry>	scanEntries(long snapshotId, String indexType, BinaryRow partition)
List<IndexManifestEntry>	scanEntries(long snapshot, String indexType, Set<BinaryRow> partitions)
List<IndexManifestEntry>	scanEntries(Snapshot snapshot, String indexType, Set<BinaryRow> partitions)
List<IndexManifestEntry>	scanEntries(String indexType, BinaryRow partition)
Optional<IndexFileMeta>	scanHashIndex(long snapshotId, BinaryRow partition, int bucket)
List<IndexFileMeta>	writeDeletionVectorsIndex(Map<String,DeletionVector> deletionVectors)
IndexFileMeta	writeHashIndex(int[] ints)
IndexFileMeta	writeHashIndex(int size, IntIterator iterator)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

IndexFileHandler

public IndexFileHandler(SnapshotManager snapshotManager,
                        PathFactory pathFactory,
                        IndexManifestFile indexManifestFile,
                        HashIndexFile hashIndex,
                        DeletionVectorsIndexFile deletionVectorsIndex)

Method Detail

deletionVectorsIndex

public DeletionVectorsIndexFile deletionVectorsIndex()

scanHashIndex

public Optional<IndexFileMeta> scanHashIndex(long snapshotId,
                                             BinaryRow partition,
                                             int bucket)

scanDVIndex

public Map<String,DeletionFile> scanDVIndex(@Nullable
                                            Long snapshotId,
                                            BinaryRow partition,
                                            int bucket)

scan

public List<IndexManifestEntry> scan(String indexType)

scan

public List<IndexFileMeta> scan(long snapshotId,
                                String indexType,
                                BinaryRow partition,
                                int bucket)

scan

public Map<Pair<BinaryRow,Integer>,List<IndexFileMeta>> scan(long snapshot,
                                                             String indexType,
                                                             Set<BinaryRow> partitions)

scan

public Map<Pair<BinaryRow,Integer>,List<IndexFileMeta>> scan(Snapshot snapshot,
                                                             String indexType,
                                                             Set<BinaryRow> partitions)

scanEntries

public List<IndexManifestEntry> scanEntries()

scanEntries

public List<IndexManifestEntry> scanEntries(String indexType,
                                            BinaryRow partition)

scanEntries

public List<IndexManifestEntry> scanEntries(long snapshotId,
                                            String indexType,
                                            BinaryRow partition)

scanEntries

public List<IndexManifestEntry> scanEntries(long snapshot,
                                            String indexType,
                                            Set<BinaryRow> partitions)

scanEntries

public List<IndexManifestEntry> scanEntries(Snapshot snapshot,
                                            String indexType,
                                            Set<BinaryRow> partitions)

filePath

public Path filePath(IndexFileMeta file)

readHashIndexList

public List<Integer> readHashIndexList(IndexFileMeta file)

readHashIndex

public IntIterator readHashIndex(IndexFileMeta file)

writeHashIndex

public IndexFileMeta writeHashIndex(int[] ints)

writeHashIndex

public IndexFileMeta writeHashIndex(int size,
                                    IntIterator iterator)

existsManifest

public boolean existsManifest(String indexManifest)

readManifest

public List<IndexManifestEntry> readManifest(String indexManifest)

readManifestWithIOException

public List<IndexManifestEntry> readManifestWithIOException(String indexManifest)
                                                     throws IOException

Throws:

IOException

existsIndexFile

public boolean existsIndexFile(IndexManifestEntry file)

deleteIndexFile

public void deleteIndexFile(IndexManifestEntry file)

deleteIndexFile

public void deleteIndexFile(IndexFileMeta file)

deleteManifest

public void deleteManifest(String indexManifest)

readAllDeletionVectors

public Map<String,DeletionVector> readAllDeletionVectors(List<IndexFileMeta> fileMetas)

writeDeletionVectorsIndex

public List<IndexFileMeta> writeDeletionVectorsIndex(Map<String,DeletionVector> deletionVectors)