Uses of Class
org.apache.paimon.schema.SchemaManager

Packages that use SchemaManager

Package	Description
org.apache.paimon
org.apache.paimon.flink.sink.cdc
org.apache.paimon.io
org.apache.paimon.manifest
org.apache.paimon.operation
org.apache.paimon.schema
org.apache.paimon.stats
org.apache.paimon.utils

Uses of SchemaManager in org.apache.paimon

Constructors in org.apache.paimon with parameters of type SchemaManager

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)

Uses of SchemaManager in org.apache.paimon.flink.sink.cdc

Methods in org.apache.paimon.flink.sink.cdc with parameters of type SchemaManager

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)

Constructors in org.apache.paimon.flink.sink.cdc with parameters of type SchemaManager

Constructor and Description
UpdatedDataFieldsProcessFunction(SchemaManager schemaManager, Identifier identifier, Catalog.Loader catalogLoader)

Uses of SchemaManager in org.apache.paimon.io

Methods in org.apache.paimon.io with parameters of type SchemaManager

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)

Uses of SchemaManager in org.apache.paimon.manifest

Constructors in org.apache.paimon.manifest with parameters of type SchemaManager

Constructor and Description
Factory(FileIO fileIO, SchemaManager schemaManager, RowType partitionType, FileFormat fileFormat, String compression, FileStorePathFactory pathFactory, long suggestedFileSize, SegmentsCache<Path> cache)

Uses of SchemaManager in org.apache.paimon.operation

Constructors in org.apache.paimon.operation with parameters of type SchemaManager

Constructor and Description
AbstractFileStoreScan(RowType partitionType, ScanBucketFilter bucketKeyFilter, SnapshotManager snapshotManager, SchemaManager schemaManager, TableSchema schema, ManifestFile.Factory manifestFileFactory, ManifestList.Factory manifestListFactory, int numOfBuckets, boolean checkNumOfBuckets, Integer scanManifestParallelism)
AppendOnlyFileStoreScan(RowType partitionType, ScanBucketFilter bucketFilter, SnapshotManager snapshotManager, SchemaManager schemaManager, TableSchema schema, ManifestFile.Factory manifestFileFactory, ManifestList.Factory manifestListFactory, int numOfBuckets, boolean checkNumOfBuckets, Integer scanManifestParallelism, boolean fileIndexReadEnabled)
FileStoreCommitImpl(FileIO fileIO, SchemaManager schemaManager, 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(RowType partitionType, ScanBucketFilter bucketFilter, SnapshotManager snapshotManager, SchemaManager schemaManager, TableSchema schema, KeyValueFieldsExtractor keyValueFieldsExtractor, ManifestFile.Factory manifestFileFactory, ManifestList.Factory manifestListFactory, int numOfBuckets, boolean checkNumOfBuckets, Integer scanManifestParallelism, boolean deletionVectorsEnabled, CoreOptions.MergeEngine mergeEngine, CoreOptions.ChangelogProducer changelogProducer)
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)

Uses of SchemaManager in org.apache.paimon.schema

Methods in org.apache.paimon.schema that return SchemaManager

Modifier and Type	Method and Description
SchemaManager	SchemaManager.copyWithBranch(String branchName)
SchemaManager	SchemaManager.withLock(Lock lock)

Methods in org.apache.paimon.schema with parameters of type SchemaManager

Modifier and Type	Method and Description
static void	SchemaValidation.validateFallbackBranch(SchemaManager schemaManager, TableSchema schema)

Uses of SchemaManager in org.apache.paimon.stats

Constructors in org.apache.paimon.stats with parameters of type SchemaManager

Constructor and Description
StatsFileHandler(SnapshotManager snapshotManager, SchemaManager schemaManager, StatsFile statsFile)

Uses of SchemaManager in org.apache.paimon.utils

Constructors in org.apache.paimon.utils with parameters of type SchemaManager

Constructor and Description
BranchManager(FileIO fileIO, Path path, SnapshotManager snapshotManager, TagManager tagManager, SchemaManager schemaManager)