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.table
org.apache.paimon.table.system
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(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)

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.table

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

Modifier and Type	Method and Description
SchemaManager	DataTable.schemaManager()
SchemaManager	DelegatedFileStoreTable.schemaManager()

Uses of SchemaManager in org.apache.paimon.table.system

Methods in org.apache.paimon.table.system that return SchemaManager

Modifier and Type	Method and Description
SchemaManager	FileMonitorTable.schemaManager()
SchemaManager	CompactBucketsTable.schemaManager()
SchemaManager	AuditLogTable.schemaManager()
SchemaManager	ReadOptimizedTable.schemaManager()

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)