Constructor and Description |
---|
AppendOnlyFileStore(FileIO fileIO,
SchemaManager schemaManager,
TableSchema schema,
CoreOptions options,
RowType partitionType,
RowType bucketKeyType,
RowType rowType,
String tableName,
CatalogEnvironment catalogEnvironment) |
KeyValueFileStore(FileIO fileIO,
SchemaManager schemaManager,
TableSchema schema,
boolean crossPartitionUpdate,
CoreOptions options,
RowType partitionType,
RowType bucketKeyType,
RowType keyType,
RowType valueType,
KeyValueFieldsExtractor keyValueFieldsExtractor,
MergeFunctionFactory<KeyValue> mfFactory,
String tableName,
CatalogEnvironment catalogEnvironment) |
Modifier and Type | Method and Description |
---|---|
protected void |
UpdatedDataFieldsProcessFunctionBase.applySchemaChange(SchemaManager schemaManager,
SchemaChange schemaChange,
Identifier identifier) |
protected List<SchemaChange> |
UpdatedDataFieldsProcessFunctionBase.extractSchemaChanges(SchemaManager schemaManager,
List<DataField> updatedDataFields) |
Constructor and Description |
---|
UpdatedDataFieldsProcessFunction(SchemaManager schemaManager,
Identifier identifier,
Catalog.Loader catalogLoader) |
Modifier and Type | Method and Description |
---|---|
static KeyValueFileReaderFactory.Builder |
KeyValueFileReaderFactory.builder(FileIO fileIO,
SchemaManager schemaManager,
TableSchema schema,
RowType keyType,
RowType valueType,
FileFormatDiscover formatDiscover,
FileStorePathFactory pathFactory,
KeyValueFieldsExtractor extractor,
CoreOptions options) |
Constructor and Description |
---|
Factory(FileIO fileIO,
SchemaManager schemaManager,
RowType partitionType,
FileFormat fileFormat,
String compression,
FileStorePathFactory pathFactory,
long suggestedFileSize,
SegmentsCache<Path> cache) |
Constructor and Description |
---|
AbstractFileStoreScan(ManifestsReader manifestsReader,
SnapshotManager snapshotManager,
SchemaManager schemaManager,
TableSchema schema,
ManifestFile.Factory manifestFileFactory,
Integer parallelism) |
AppendOnlyFileStoreScan(ManifestsReader manifestsReader,
BucketSelectConverter bucketSelectConverter,
SnapshotManager snapshotManager,
SchemaManager schemaManager,
TableSchema schema,
ManifestFile.Factory manifestFileFactory,
Integer scanManifestParallelism,
boolean fileIndexReadEnabled) |
FileStoreCommitImpl(FileIO fileIO,
SchemaManager schemaManager,
String tableName,
String commitUser,
RowType partitionType,
String partitionDefaultName,
FileStorePathFactory pathFactory,
SnapshotManager snapshotManager,
ManifestFile.Factory manifestFileFactory,
ManifestList.Factory manifestListFactory,
IndexManifestFile.Factory indexManifestFileFactory,
FileStoreScan scan,
int numBucket,
MemorySize manifestTargetSize,
MemorySize manifestFullCompactionSize,
int manifestMergeMinCount,
boolean dynamicPartitionOverwrite,
Comparator<InternalRow> keyComparator,
String branchName,
StatsFileHandler statsFileHandler,
BucketMode bucketMode,
Integer manifestReadParallelism,
List<CommitCallback> commitCallbacks,
int commitMaxRetries) |
KeyValueFileStoreScan(ManifestsReader manifestsReader,
BucketSelectConverter bucketSelectConverter,
SnapshotManager snapshotManager,
SchemaManager schemaManager,
TableSchema schema,
KeyValueFieldsExtractor keyValueFieldsExtractor,
ManifestFile.Factory manifestFileFactory,
Integer scanManifestParallelism,
boolean deletionVectorsEnabled,
CoreOptions.MergeEngine mergeEngine,
CoreOptions.ChangelogProducer changelogProducer,
boolean fileIndexReadEnabled) |
KeyValueFileStoreWrite(FileIO fileIO,
SchemaManager schemaManager,
TableSchema schema,
String commitUser,
RowType partitionType,
RowType keyType,
RowType valueType,
java.util.function.Supplier<Comparator<InternalRow>> keyComparatorSupplier,
java.util.function.Supplier<FieldsComparator> udsComparatorSupplier,
java.util.function.Supplier<RecordEqualiser> logDedupEqualSupplier,
MergeFunctionFactory<KeyValue> mfFactory,
FileStorePathFactory pathFactory,
Map<String,FileStorePathFactory> format2PathFactory,
SnapshotManager snapshotManager,
FileStoreScan scan,
IndexMaintainer.Factory<KeyValue> indexFactory,
DeletionVectorsMaintainer.Factory deletionVectorsMaintainerFactory,
CoreOptions options,
KeyValueFieldsExtractor extractor,
String tableName) |
RawFileSplitRead(FileIO fileIO,
SchemaManager schemaManager,
TableSchema schema,
RowType rowType,
FileFormatDiscover formatDiscover,
FileStorePathFactory pathFactory,
boolean fileIndexReadEnabled) |
Modifier and Type | Method and Description |
---|---|
SchemaManager |
SchemaManager.copyWithBranch(String branchName) |
SchemaManager |
SchemaManager.withLock(Lock lock) |
Modifier and Type | Method and Description |
---|---|
static void |
SchemaValidation.validateFallbackBranch(SchemaManager schemaManager,
TableSchema schema) |
Constructor and Description |
---|
StatsFileHandler(SnapshotManager snapshotManager,
SchemaManager schemaManager,
StatsFile statsFile) |
Constructor and Description |
---|
BranchManager(FileIO fileIO,
Path path,
SnapshotManager snapshotManager,
TagManager tagManager,
SchemaManager schemaManager) |
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.