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

Class JdbcSchemasInfo.JdbcSchemaInfo

java.lang.Object

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

Enclosing class:

JdbcSchemasInfo

public static class JdbcSchemasInfo.JdbcSchemaInfo
extends Object

JDBC table schemas.

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
Identifier	identifier()
boolean	isPkTable()
Schema	schema()
String	schemaName()

Methods inherited from class java.lang.Object

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

Constructor Detail

JdbcSchemaInfo

public JdbcSchemaInfo(Identifier identifier,
                      String schemaName,
                      boolean isPkTable,
                      Schema schema)

Method Detail

identifier

public Identifier identifier()

schemaName

public String schemaName()

isPkTable

public boolean isPkTable()

schema

public Schema schema()