Package org.apache.flink.cdc.connectors.sqlserver.source.dialect

Class SqlServerSchema

java.lang.Object

org.apache.flink.cdc.connectors.sqlserver.source.dialect.SqlServerSchema

public class SqlServerSchema
extends Object

A component used to get schema by table path.

Constructor Summary

Constructors

Constructor	Description
SqlServerSchema()

Method Summary

Modifier and Type	Method	Description
io.debezium.relational.history.TableChanges.TableChange	getTableSchema(io.debezium.jdbc.JdbcConnection jdbc, io.debezium.relational.TableId tableId, io.debezium.relational.Tables.TableFilter tableFilters)

Methods inherited from class java.lang.Object

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

Constructor Detail

SqlServerSchema

public SqlServerSchema()

Method Detail

getTableSchema

public io.debezium.relational.history.TableChanges.TableChange getTableSchema(io.debezium.jdbc.JdbcConnection jdbc,
                                                                              io.debezium.relational.TableId tableId,
                                                                              io.debezium.relational.Tables.TableFilter tableFilters)