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

Packages that use Schema

Package	Description
org.apache.paimon.catalog
org.apache.paimon.flink
org.apache.paimon.flink.action.cdc
org.apache.paimon.flink.action.cdc.format
org.apache.paimon.flink.action.cdc.mongodb
org.apache.paimon.flink.action.cdc.mysql
org.apache.paimon.flink.action.cdc.postgres
org.apache.paimon.flink.action.cdc.schema
org.apache.paimon.flink.sink.cdc
org.apache.paimon.hive
org.apache.paimon.hive.migrate
org.apache.paimon.jdbc
org.apache.paimon.privilege
org.apache.paimon.schema

Uses of Schema in org.apache.paimon.catalog

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

Modifier and Type	Method and Description
void	Catalog.createTable(Identifier identifier, Schema schema, boolean ignoreIfExists) Create a new table.
void	AbstractCatalog.createTable(Identifier identifier, Schema schema, boolean ignoreIfExists)
void	DelegateCatalog.createTable(Identifier identifier, Schema schema, boolean ignoreIfExists)
void	FileSystemCatalog.createTableImpl(Identifier identifier, Schema schema)
protected abstract void	AbstractCatalog.createTableImpl(Identifier identifier, Schema schema)

Uses of Schema in org.apache.paimon.flink

Methods in org.apache.paimon.flink that return Schema

Modifier and Type	Method and Description
protected Schema	FlinkCatalog.buildPaimonSchema(Identifier identifier, org.apache.flink.table.catalog.CatalogTable catalogTable, Map<String,String> options)
static Schema	FlinkCatalog.fromCatalogTable(org.apache.flink.table.catalog.CatalogTable table)

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

Methods in org.apache.paimon.flink.action.cdc that return Schema

Modifier and Type	Method and Description
protected Schema	SyncTableActionBase.buildPaimonSchema(Schema retrievedSchema)
protected Schema	MessageQueueSyncTableActionBase.buildPaimonSchema(Schema retrievedSchema)
static Schema	CdcActionCommonUtils.buildPaimonSchema(String tableName, List<String> specifiedPartitionKeys, List<String> specifiedPrimaryKeys, List<ComputedColumn> computedColumns, Map<String,String> tableConfig, Schema sourceSchema, CdcMetadataConverter[] metadataConverters, boolean caseSensitive, boolean strictlyCheckSpecified, boolean requirePrimaryKeys)
static Schema	MessageQueueSchemaUtils.getSchema(MessageQueueSchemaUtils.ConsumerWrapper consumer, DataFormat dataFormat, TypeMapping typeMapping) Retrieves the Kafka schema for a given topic.
protected abstract Schema	SyncTableActionBase.retrieveSchema()
protected Schema	MessageQueueSyncTableActionBase.retrieveSchema()

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

Modifier and Type	Method and Description
protected Schema	SyncTableActionBase.buildPaimonSchema(Schema retrievedSchema)
protected Schema	MessageQueueSyncTableActionBase.buildPaimonSchema(Schema retrievedSchema)
static Schema	CdcActionCommonUtils.buildPaimonSchema(String tableName, List<String> specifiedPartitionKeys, List<String> specifiedPrimaryKeys, List<ComputedColumn> computedColumns, Map<String,String> tableConfig, Schema sourceSchema, CdcMetadataConverter[] metadataConverters, boolean caseSensitive, boolean strictlyCheckSpecified, boolean requirePrimaryKeys)

Uses of Schema in org.apache.paimon.flink.action.cdc.format

Methods in org.apache.paimon.flink.action.cdc.format that return Schema

Modifier and Type	Method and Description
Schema	AbstractRecordParser.buildSchema(CdcSourceRecord record)

Uses of Schema in org.apache.paimon.flink.action.cdc.mongodb

Methods in org.apache.paimon.flink.action.cdc.mongodb that return Schema

Modifier and Type	Method and Description
static Schema	MongodbSchemaUtils.getMongodbSchema(org.apache.flink.configuration.Configuration mongodbConfig) The schema can be created in one of the two modes: SPECIFIED: In this mode, the schema is created based on the explicit column names provided in the configuration.
protected Schema	MongoDBSyncTableAction.retrieveSchema()

Uses of Schema in org.apache.paimon.flink.action.cdc.mysql

Methods in org.apache.paimon.flink.action.cdc.mysql that return Schema

Modifier and Type	Method and Description
protected Schema	MySqlSyncTableAction.retrieveSchema()

Uses of Schema in org.apache.paimon.flink.action.cdc.postgres

Methods in org.apache.paimon.flink.action.cdc.postgres that return Schema

Modifier and Type	Method and Description
protected Schema	PostgresSyncTableAction.retrieveSchema()

Uses of Schema in org.apache.paimon.flink.action.cdc.schema

Methods in org.apache.paimon.flink.action.cdc.schema that return Schema

Modifier and Type	Method and Description
static Schema	JdbcSchemaUtils.buildSchema(DatabaseMetaData metaData, String databaseName, String schemaName, String tableName, String tableComment, TypeMapping typeMapping, JdbcToPaimonTypeVisitor jdbcToPaimonTypeVisitor)
static Schema	JdbcSchemaUtils.buildSchema(DatabaseMetaData metaData, String databaseName, String tableName, String tableComment, TypeMapping typeMapping, JdbcToPaimonTypeVisitor jdbcToPaimonTypeVisitor)
static Schema	JdbcSchemaUtils.mergeSchema(String currentTable, Schema current, String otherTable, Schema other)
Schema	AllMergedJdbcTableInfo.schema()
Schema	UnmergedJdbcTableInfo.schema()
Schema	JdbcTableInfo.schema()
Schema	JdbcSchemasInfo.JdbcSchemaInfo.schema()
Schema	ShardsMergedJdbcTableInfo.schema()

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

Modifier and Type	Method and Description
void	JdbcSchemasInfo.addSchema(Identifier identifier, Schema schema)
void	JdbcSchemasInfo.addSchema(Identifier identifier, String schemaName, Schema schema)
void	AllMergedJdbcTableInfo.init(Identifier identifier, Schema schema)
void	ShardsMergedJdbcTableInfo.init(Identifier identifier, Schema schema)
AllMergedJdbcTableInfo	AllMergedJdbcTableInfo.merge(Identifier otherTableId, Schema other)
ShardsMergedJdbcTableInfo	ShardsMergedJdbcTableInfo.merge(Identifier otherTableId, Schema other)
static Schema	JdbcSchemaUtils.mergeSchema(String currentTable, Schema current, String otherTable, Schema other)

Constructors in org.apache.paimon.flink.action.cdc.schema with parameters of type Schema

Constructor and Description
JdbcSchemaInfo(Identifier identifier, String schemaName, boolean isPkTable, Schema schema)
UnmergedJdbcTableInfo(Identifier identifier, Schema schema)

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

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

Modifier and Type	Method and Description
Optional<Schema>	NewTableSchemaBuilder.build(RichCdcMultiplexRecord record)
default Optional<Schema>	EventParser.parseNewTable() Parse newly added table schema from event.
Optional<Schema>	RichCdcMultiplexRecordEventParser.parseNewTable()

Uses of Schema in org.apache.paimon.hive

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

Modifier and Type	Method and Description
protected void	HiveCatalog.createTableImpl(Identifier identifier, Schema schema)

Uses of Schema in org.apache.paimon.hive.migrate

Methods in org.apache.paimon.hive.migrate that return Schema

Modifier and Type	Method and Description
Schema	HiveMigrator.from(List<org.apache.hadoop.hive.metastore.api.FieldSchema> fields, List<org.apache.hadoop.hive.metastore.api.FieldSchema> partitionFields, Map<String,String> hiveTableOptions)

Uses of Schema in org.apache.paimon.jdbc

Methods in org.apache.paimon.jdbc with parameters of type Schema

Modifier and Type	Method and Description
protected void	JdbcCatalog.createTableImpl(Identifier identifier, Schema schema)

Uses of Schema in org.apache.paimon.privilege

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

Modifier and Type	Method and Description
void	PrivilegedCatalog.createTable(Identifier identifier, Schema schema, boolean ignoreIfExists)

Uses of Schema in org.apache.paimon.schema

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

Modifier and Type	Method and Description
Schema	Schema.Builder.build() Returns an instance of an unresolved Schema.
static Schema	Schema.fromTableSchema(TableSchema tableSchema)

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

Modifier and Type	Method and Description
TableSchema	SchemaManager.createTable(Schema schema)
TableSchema	SchemaManager.createTable(Schema schema, boolean ignoreIfExistsSame)