Package org.apache.flink.cdc.connectors.mysql.schema

Class MySqlTableDefinition

java.lang.Object

org.apache.flink.cdc.connectors.mysql.schema.MySqlTableDefinition

public class MySqlTableDefinition
extends Object

used to generate table definition in ddl with "desc table".

Constructor Summary

Constructors

Constructor	Description
MySqlTableDefinition(io.debezium.relational.TableId tableId, List<MySqlFieldDefinition> fieldDefinitions, List<String> primaryKeys)

Method Summary

Modifier and Type	Method	Description
String	toDdl()

Methods inherited from class java.lang.Object

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

Constructor Detail

MySqlTableDefinition

public MySqlTableDefinition(io.debezium.relational.TableId tableId,
                            List<MySqlFieldDefinition> fieldDefinitions,
                            List<String> primaryKeys)

Method Detail

toDdl

public String toDdl()