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

Packages that use TableSchema

Package	Description
org.apache.paimon
org.apache.paimon.catalog
org.apache.paimon.crosspartition
org.apache.paimon.flink.action.cdc
org.apache.paimon.flink.lookup
org.apache.paimon.flink.sink
org.apache.paimon.flink.sink.cdc
org.apache.paimon.hive
org.apache.paimon.hive.utils
org.apache.paimon.iceberg.metadata
org.apache.paimon.io
org.apache.paimon.jdbc
org.apache.paimon.operation
org.apache.paimon.partition
org.apache.paimon.privilege
org.apache.paimon.schema
org.apache.paimon.stats
org.apache.paimon.table
org.apache.paimon.table.sink
org.apache.paimon.table.source
org.apache.paimon.table.source.snapshot
org.apache.paimon.utils

Uses of TableSchema in org.apache.paimon

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

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 TableSchema in org.apache.paimon.catalog

Methods in org.apache.paimon.catalog that return TableSchema

Modifier and Type	Method and Description
TableSchema	FileSystemCatalog.getDataTableSchema(Identifier identifier)
protected abstract TableSchema	AbstractCatalog.getDataTableSchema(Identifier identifier)

Methods in org.apache.paimon.catalog that return types with arguments of type TableSchema

Modifier and Type	Method and Description
Optional<TableSchema>	AbstractCatalog.tableSchemaInFileSystem(Path tablePath, String branchName)

Methods in org.apache.paimon.catalog with parameters of type TableSchema

Modifier and Type	Method and Description
Optional<MetastoreClient.Factory>	AbstractCatalog.metastoreClientFactory(Identifier identifier, TableSchema schema) Get metastore client factory for the table specified by identifier.

Uses of TableSchema in org.apache.paimon.crosspartition

Methods in org.apache.paimon.crosspartition with parameters of type TableSchema

Modifier and Type	Method and Description
static RowType	IndexBootstrap.bootstrapType(TableSchema schema)

Constructors in org.apache.paimon.crosspartition with parameters of type TableSchema

Constructor and Description
KeyPartPartitionKeyExtractor(TableSchema schema)

Uses of TableSchema in org.apache.paimon.flink.action.cdc

Methods in org.apache.paimon.flink.action.cdc with parameters of type TableSchema

Modifier and Type	Method and Description
static void	CdcActionCommonUtils.assertSchemaCompatible(TableSchema paimonSchema, List<DataField> sourceTableFields)
static boolean	CdcActionCommonUtils.schemaCompatible(TableSchema paimonSchema, List<DataField> sourceTableFields)

Uses of TableSchema in org.apache.paimon.flink.lookup

Methods in org.apache.paimon.flink.lookup with parameters of type TableSchema

Modifier and Type	Method and Description
FileStoreTable	LookupFileStoreTable.copy(TableSchema newTableSchema)

Constructors in org.apache.paimon.flink.lookup with parameters of type TableSchema

Constructor and Description
FixedBucketFromPkExtractor(TableSchema schema)
LookupCompactDiffRead(MergeFileSplitRead mergeRead, TableSchema schema)

Uses of TableSchema in org.apache.paimon.flink.sink

Methods in org.apache.paimon.flink.sink that return types with arguments of type TableSchema

Modifier and Type	Method and Description
protected abstract SerializableFunction<TableSchema,PartitionKeyExtractor<T>>	DynamicBucketSink.extractorFunction()
protected SerializableFunction<TableSchema,PartitionKeyExtractor<InternalRow>>	RowDynamicBucketSink.extractorFunction()

Method parameters in org.apache.paimon.flink.sink with type arguments of type TableSchema

Modifier and Type	Method and Description
protected HashBucketAssignerOperator<T>	DynamicBucketSink.createHashBucketAssignerOperator(String commitUser, Table table, Integer numAssigners, SerializableFunction<TableSchema,PartitionKeyExtractor<T>> extractorFunction, boolean overwrite)

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

Constructor and Description
LocalMergeOperator(TableSchema schema)
RowAssignerChannelComputer(TableSchema schema, Integer numAssigners)
RowDataChannelComputer(TableSchema schema, boolean hasLogSink)
RowDataKeyAndBucketExtractor(TableSchema schema)
RowWithBucketChannelComputer(TableSchema schema)

Constructor parameters in org.apache.paimon.flink.sink with type arguments of type TableSchema

Constructor and Description
HashBucketAssignerOperator(String commitUser, Table table, Integer numAssigners, SerializableFunction<TableSchema,PartitionKeyExtractor<T>> extractorFunction, boolean overwrite)

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

Fields in org.apache.paimon.flink.sink.cdc declared as TableSchema

Modifier and Type	Field and Description
protected TableSchema	CdcFixedBucketChannelComputerBase.schema

Methods in org.apache.paimon.flink.sink.cdc that return types with arguments of type TableSchema

Modifier and Type	Method and Description
protected SerializableFunction<TableSchema,PartitionKeyExtractor<T>>	CdcDynamicBucketSinkBase.extractorFunction()

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

Modifier and Type	Method and Description
protected abstract KeyAndBucketExtractor<T>	CdcDynamicBucketSinkBase.createExtractor(TableSchema schema)
protected KeyAndBucketExtractor<CdcRecord>	CdcDynamicBucketSink.createExtractor(TableSchema schema)

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

Constructor and Description
CdcFixedBucketChannelComputerBase(TableSchema schema)
CdcRecordChannelComputer(TableSchema schema)
CdcRecordKeyAndBucketExtractor(TableSchema schema)
CdcRecordPartitionKeyExtractor(TableSchema schema)

Uses of TableSchema in org.apache.paimon.hive

Methods in org.apache.paimon.hive that return TableSchema

Modifier and Type	Method and Description
TableSchema	HiveCatalog.getDataTableSchema(Identifier identifier)

Methods in org.apache.paimon.hive with parameters of type TableSchema

Modifier and Type	Method and Description
Optional<MetastoreClient.Factory>	HiveCatalog.metastoreClientFactory(Identifier identifier, TableSchema schema)

Constructors in org.apache.paimon.hive with parameters of type TableSchema

Constructor and Description
Factory(Identifier identifier, TableSchema schema, org.apache.hadoop.hive.conf.HiveConf hiveConf, String clientClassName, Options options)

Uses of TableSchema in org.apache.paimon.hive.utils

Methods in org.apache.paimon.hive.utils with parameters of type TableSchema

Modifier and Type	Method and Description
static Optional<Predicate>	HiveUtils.createPredicate(TableSchema tableSchema, org.apache.hadoop.mapred.JobConf jobConf, boolean limitToReadColumnNames)

Uses of TableSchema in org.apache.paimon.iceberg.metadata

Methods in org.apache.paimon.iceberg.metadata with parameters of type TableSchema

Modifier and Type	Method and Description
static IcebergSchema	IcebergSchema.create(TableSchema tableSchema)

Uses of TableSchema in org.apache.paimon.io

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

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)
static FileIndexResult	FileIndexEvaluator.evaluate(FileIO fileIO, TableSchema dataSchema, List<Predicate> dataFilter, DataFilePathFactory dataFilePathFactory, DataFileMeta file)

Uses of TableSchema in org.apache.paimon.jdbc

Methods in org.apache.paimon.jdbc that return TableSchema

Modifier and Type	Method and Description
protected TableSchema	JdbcCatalog.getDataTableSchema(Identifier identifier)

Uses of TableSchema in org.apache.paimon.operation

Methods in org.apache.paimon.operation that return TableSchema

Modifier and Type	Method and Description
protected TableSchema	AbstractFileStoreScan.scanTableSchema(long id) Note: Keep this thread-safe.
TableSchema	MergeFileSplitRead.tableSchema()

Methods in org.apache.paimon.operation with parameters of type TableSchema

Modifier and Type	Method and Description
static DefaultValueAssigner	DefaultValueAssigner.create(TableSchema schema)

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

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)
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)
MergeFileSplitRead(CoreOptions options, TableSchema schema, RowType keyType, RowType valueType, Comparator<InternalRow> keyComparator, MergeFunctionFactory<KeyValue> mfFactory, KeyValueFileReaderFactory.Builder readerFactoryBuilder)
RawFileSplitRead(FileIO fileIO, SchemaManager schemaManager, TableSchema schema, RowType rowType, FileFormatDiscover formatDiscover, FileStorePathFactory pathFactory, boolean fileIndexReadEnabled)

Uses of TableSchema in org.apache.paimon.partition

Methods in org.apache.paimon.partition with parameters of type TableSchema

Modifier and Type	Method and Description
static Pair<Pair<int[],RowType>,List<DataField>>	PartitionUtils.constructPartitionMapping(TableSchema dataSchema, List<DataField> dataFields)

Uses of TableSchema in org.apache.paimon.privilege

Methods in org.apache.paimon.privilege with parameters of type TableSchema

Modifier and Type	Method and Description
FileStoreTable	PrivilegedFileStoreTable.copy(TableSchema newTableSchema)

Uses of TableSchema in org.apache.paimon.schema

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

Modifier and Type	Method and Description
TableSchema	SchemaManager.commitChanges(List<SchemaChange> changes) Update SchemaChanges.
TableSchema	SchemaManager.commitChanges(SchemaChange... changes) Update SchemaChanges.
TableSchema	TableSchema.copy(Map<String,String> newOptions)
TableSchema	SchemaManager.createTable(Schema schema)
TableSchema	SchemaManager.createTable(Schema schema, boolean ignoreIfExistsSame)
TableSchema	SchemaSerializer.deserialize(org.apache.paimon.shade.jackson2.com.fasterxml.jackson.databind.JsonNode node)
static TableSchema	TableSchema.fromJson(String json)
static TableSchema	SchemaManager.fromPath(FileIO fileIO, Path path)
static TableSchema	TableSchema.fromPath(FileIO fileIO, Path path)
static TableSchema	SchemaMergingUtils.mergeSchemas(TableSchema currentTableSchema, RowType targetType, boolean allowExplicitCast)
TableSchema	SchemaManager.schema(long id) Read schema for schema id.

Methods in org.apache.paimon.schema that return types with arguments of type TableSchema

Modifier and Type	Method and Description
Optional<TableSchema>	SchemaManager.latest()
List<TableSchema>	SchemaManager.listAll()
List<TableSchema>	SchemaManager.listWithRange(Optional<Long> optionalMaxSchemaId, Optional<Long> optionalMinSchemaId)
List<TableSchema>	SchemaManager.schemasWithId(List<Long> schemaIds)

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

Modifier and Type	Method and Description
static Schema	Schema.fromTableSchema(TableSchema tableSchema)
List<DataField>	KeyValueFieldsExtractor.keyFields(TableSchema schema) Extract key fields from table schema.
static TableSchema	SchemaMergingUtils.mergeSchemas(TableSchema currentTableSchema, RowType targetType, boolean allowExplicitCast)
void	SchemaSerializer.serialize(TableSchema tableSchema, org.apache.paimon.shade.jackson2.com.fasterxml.jackson.core.JsonGenerator generator)
static void	SchemaValidation.validateFallbackBranch(SchemaManager schemaManager, TableSchema schema)
static void	SchemaValidation.validateTableSchema(TableSchema schema) Validate the TableSchema and CoreOptions.
List<DataField>	KeyValueFieldsExtractor.valueFields(TableSchema schema) Extract value fields from table schema.

Uses of TableSchema in org.apache.paimon.stats

Methods in org.apache.paimon.stats with parameters of type TableSchema

Modifier and Type	Method and Description
void	Statistics.deserializeFieldsFromString(TableSchema schema)
void	Statistics.serializeFieldsToString(TableSchema schema)

Uses of TableSchema in org.apache.paimon.table

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

Modifier and Type	Method and Description
TableSchema	FileStoreTable.schema()
TableSchema	DelegatedFileStoreTable.schema()

Methods in org.apache.paimon.table with parameters of type TableSchema

Modifier and Type	Method and Description
FileStoreTable	FileStoreTable.copy(TableSchema newTableSchema)
FileStoreTable	FallbackReadFileStoreTable.copy(TableSchema newTableSchema)
static FileStoreTable	FileStoreTableFactory.create(FileIO fileIO, Path tablePath, TableSchema tableSchema)
static FileStoreTable	FileStoreTableFactory.create(FileIO fileIO, Path tablePath, TableSchema tableSchema, CatalogEnvironment catalogEnvironment)
static FileStoreTable	FileStoreTableFactory.create(FileIO fileIO, Path tablePath, TableSchema tableSchema, Options dynamicOptions, CatalogEnvironment catalogEnvironment)
static MergeFunctionFactory<KeyValue>	PrimaryKeyTableUtils.createMergeFunctionFactory(TableSchema tableSchema, KeyValueFieldsExtractor extractor)
static FileStoreTable	FileStoreTableFactory.createWithoutFallbackBranch(FileIO fileIO, Path tablePath, TableSchema tableSchema, Options dynamicOptions, CatalogEnvironment catalogEnvironment)
List<DataField>	PrimaryKeyTableUtils.PrimaryKeyFieldsExtractor.keyFields(TableSchema schema)
List<DataField>	PrimaryKeyTableUtils.PrimaryKeyFieldsExtractor.valueFields(TableSchema schema)

Uses of TableSchema in org.apache.paimon.table.sink

Methods in org.apache.paimon.table.sink with parameters of type TableSchema

Modifier and Type	Method and Description
static RowKindGenerator	RowKindGenerator.create(TableSchema schema, CoreOptions options)

Constructors in org.apache.paimon.table.sink with parameters of type TableSchema

Constructor and Description
DynamicBucketRowKeyExtractor(TableSchema schema)
FixedBucketRowKeyExtractor(TableSchema schema)
FixedBucketWriteSelector(TableSchema schema)
RowKeyExtractor(TableSchema schema)
RowPartitionKeyExtractor(TableSchema schema)
UnawareBucketRowKeyExtractor(TableSchema schema)

Uses of TableSchema in org.apache.paimon.table.source

Constructors in org.apache.paimon.table.source with parameters of type TableSchema

Constructor and Description
AbstractDataTableRead(TableSchema schema)
KeyValueTableRead(java.util.function.Supplier<MergeFileSplitRead> mergeReadSupplier, java.util.function.Supplier<RawFileSplitRead> batchRawReadSupplier, TableSchema schema)

Uses of TableSchema in org.apache.paimon.table.source.snapshot

Constructors in org.apache.paimon.table.source.snapshot with parameters of type TableSchema

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)

Uses of TableSchema in org.apache.paimon.utils

Methods in org.apache.paimon.utils that return TableSchema

Modifier and Type	Method and Description
TableSchema	BulkFormatMapping.getDataSchema()

Methods in org.apache.paimon.utils with parameters of type TableSchema

Modifier and Type	Method and Description
BulkFormatMapping	BulkFormatMapping.BulkFormatMappingBuilder.build(String formatIdentifier, TableSchema tableSchema, TableSchema dataSchema)

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

Constructor and Description
BulkFormatMapping(int[] indexMapping, CastFieldGetter[] castMapping, Pair<int[],RowType> partitionPair, FormatReaderFactory bulkFormat, TableSchema dataSchema, List<Predicate> dataFilters)

Constructor parameters in org.apache.paimon.utils with type arguments of type TableSchema

Constructor and Description
BulkFormatMappingBuilder(FileFormatDiscover formatDiscover, List<DataField> readTableFields, java.util.function.Function<TableSchema,List<DataField>> fieldsExtractor, List<Predicate> filters)