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

Class Db2Schema

java.lang.Object

org.apache.flink.cdc.connectors.db2.source.dialect.Db2Schema

public class Db2Schema
extends Object

A component used to get schema by table path.

Constructor Summary

Constructors

Constructor	Description
Db2Schema()

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

Db2Schema

public Db2Schema()

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)