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

Class CustomPostgresSchema

java.lang.Object

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

public class CustomPostgresSchema
extends Object

A CustomPostgresSchema similar to PostgresSchema with customization.

Constructor Summary

Constructors

Constructor	Description
CustomPostgresSchema(PostgresConnection jdbcConnection, PostgresSourceConfig sourceConfig)

Method Summary

Modifier and Type	Method	Description
io.debezium.relational.history.TableChanges.TableChange	getTableSchema(io.debezium.relational.TableId tableId)
Map<io.debezium.relational.TableId,io.debezium.relational.history.TableChanges.TableChange>	getTableSchema(List<io.debezium.relational.TableId> tableIds)

Methods inherited from class java.lang.Object

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

Constructor Detail

CustomPostgresSchema

public CustomPostgresSchema(PostgresConnection jdbcConnection,
                            PostgresSourceConfig sourceConfig)

Method Detail

getTableSchema

public io.debezium.relational.history.TableChanges.TableChange getTableSchema(io.debezium.relational.TableId tableId)

getTableSchema

public Map<io.debezium.relational.TableId,io.debezium.relational.history.TableChanges.TableChange> getTableSchema(List<io.debezium.relational.TableId> tableIds)