Modifier and Type | Method and Description |
---|---|
IndexFileHandler |
FileStore.newIndexFileHandler() |
Constructor and Description |
---|
GeneratedDeletionFile(IndexFileMeta deletionFile,
IndexFileHandler fileHandler) |
Modifier and Type | Method and Description |
---|---|
IndexFileHandler |
DeletionVectorsMaintainer.indexFileHandler() |
Modifier and Type | Method and Description |
---|---|
static DeletionVectorsMaintainer.Factory |
DeletionVectorsMaintainer.factory(IndexFileHandler handler) |
Constructor and Description |
---|
Factory(IndexFileHandler handler) |
Modifier and Type | Method and Description |
---|---|
static BucketedAppendDeletionFileMaintainer |
AppendDeletionFileMaintainer.forBucketedAppend(IndexFileHandler indexFileHandler,
Long snapshotId,
BinaryRow partition,
int bucket) |
static UnawareAppendDeletionFileMaintainer |
AppendDeletionFileMaintainer.forUnawareAppend(IndexFileHandler indexFileHandler,
Long snapshotId,
BinaryRow partition) |
Modifier and Type | Method and Description |
---|---|
static PartitionIndex |
PartitionIndex.loadIndex(IndexFileHandler indexFileHandler,
BinaryRow partition,
long targetBucketRowNumber,
java.util.function.IntPredicate loadFilter,
java.util.function.IntPredicate bucketFilter) |
Constructor and Description |
---|
Factory(IndexFileHandler handler) |
HashBucketAssigner(SnapshotManager snapshotManager,
String commitUser,
IndexFileHandler indexFileHandler,
int numChannels,
int numAssigners,
int assignId,
long targetBucketRowNumber) |
Modifier and Type | Field and Description |
---|---|
protected IndexFileHandler |
FileDeletionBase.indexFileHandler |
Constructor and Description |
---|
ChangelogDeletion(FileIO fileIO,
FileStorePathFactory pathFactory,
ManifestFile manifestFile,
ManifestList manifestList,
IndexFileHandler indexFileHandler,
StatsFileHandler statsFileHandler,
boolean cleanEmptyDirectories,
int deleteFileThreadNum) |
FileDeletionBase(FileIO fileIO,
FileStorePathFactory pathFactory,
ManifestFile manifestFile,
ManifestList manifestList,
IndexFileHandler indexFileHandler,
StatsFileHandler statsFileHandler,
boolean cleanEmptyDirectories,
int deleteFileThreadNum) |
SnapshotDeletion(FileIO fileIO,
FileStorePathFactory pathFactory,
ManifestFile manifestFile,
ManifestList manifestList,
IndexFileHandler indexFileHandler,
StatsFileHandler statsFileHandler,
boolean produceChangelog,
boolean cleanEmptyDirectories,
int deleteFileThreadNum) |
TagDeletion(FileIO fileIO,
FileStorePathFactory pathFactory,
ManifestFile manifestFile,
ManifestList manifestList,
IndexFileHandler indexFileHandler,
StatsFileHandler statsFileHandler,
boolean cleanEmptyDirectories,
int deleteFileThreadNum) |
Modifier and Type | Method and Description |
---|---|
IndexFileHandler |
PrivilegedFileStore.newIndexFileHandler() |
Constructor and Description |
---|
SnapshotReaderImpl(FileStoreScan scan,
TableSchema tableSchema,
CoreOptions options,
SnapshotManager snapshotManager,
SplitGenerator splitGenerator,
java.util.function.BiConsumer<FileStoreScan,Predicate> nonPartitionFilterConsumer,
DefaultValueAssigner defaultValueAssigner,
FileStorePathFactory pathFactory,
String tableName,
IndexFileHandler indexFileHandler) |
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.