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

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)

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

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

Constructor and Description
FixedBucketFromPkExtractor(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 SerializableFunction<TableSchema,PartitionKeyExtractor<InternalRow>>	RowDynamicBucketSink.extractorFunction()
protected abstract SerializableFunction<TableSchema,PartitionKeyExtractor<T>>	DynamicBucketSink.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)

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

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

Modifier and Type	Method and Description
static IcebergDataFileMeta	IcebergDataFileMeta.create(IcebergDataFileMeta.Content content, String filePath, String fileFormat, BinaryRow partition, long recordCount, long fileSizeInBytes, TableSchema tableSchema, SimpleStats stats)

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

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

Constructor and Description
IcebergSchema(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 boolean	FileIndexSkipper.skip(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.

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(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)
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)
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<int[],int[][]>	PartitionUtils.constructPartitionMapping(TableSchema dataSchema, int[][] projection)

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)

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)
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)