Package org.apache.flink.cdc.connectors.postgres.source.utils

Class TableDiscoveryUtils

java.lang.Object

org.apache.flink.cdc.connectors.postgres.source.utils.TableDiscoveryUtils

public class TableDiscoveryUtils
extends Object

A utility class for table discovery.

Constructor Summary

Constructors

Constructor	Description
TableDiscoveryUtils()

Method Summary

Modifier and Type	Method	Description
static List<io.debezium.relational.TableId>	listTables(String database, io.debezium.jdbc.JdbcConnection jdbc, RelationalTableFilters tableFilters, boolean includePartitionedTables)

Methods inherited from class java.lang.Object

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

Constructor Detail

TableDiscoveryUtils

public TableDiscoveryUtils()

Method Detail

listTables

public static List<io.debezium.relational.TableId> listTables(String database,
                                                              io.debezium.jdbc.JdbcConnection jdbc,
                                                              RelationalTableFilters tableFilters,
                                                              boolean includePartitionedTables)
                                                       throws SQLException

Throws:

SQLException