org.apache.paimon.flink.action.cdc.schema

Class JdbcSchemasInfo

java.lang.Object

org.apache.paimon.flink.action.cdc.schema.JdbcSchemasInfo

public class JdbcSchemasInfo
extends Object

Utility class to manage JDBC tables and their schemas.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	JdbcSchemasInfo.JdbcSchemaInfo JDBC table schemas.

Constructor Summary

Constructors

Constructor and Description
JdbcSchemasInfo()

Method Summary

Modifier and Type	Method and Description
void	addSchema(Identifier identifier, Schema schema)
void	addSchema(Identifier identifier, String schemaName, Schema schema)
JdbcTableInfo	mergeAll()
List<Identifier>	nonPkTables()
List<JdbcSchemasInfo.JdbcSchemaInfo>	pkTables()
List<JdbcTableInfo>	toMySqlTableInfos(boolean mergeShards)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

JdbcSchemasInfo

public JdbcSchemasInfo()

Method Detail

addSchema

public void addSchema(Identifier identifier,
                      Schema schema)

addSchema

public void addSchema(Identifier identifier,
                      String schemaName,
                      Schema schema)

pkTables

public List<JdbcSchemasInfo.JdbcSchemaInfo> pkTables()

nonPkTables

public List<Identifier> nonPkTables()

mergeAll

public JdbcTableInfo mergeAll()

toMySqlTableInfos

public List<JdbcTableInfo> toMySqlTableInfos(boolean mergeShards)