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

Class RelationAwarePostgresSchema

java.lang.Object

io.debezium.relational.RelationalDatabaseSchema

io.debezium.connector.postgresql.PostgresSchema

org.apache.flink.cdc.connectors.postgres.source.schema.RelationAwarePostgresSchema

All Implemented Interfaces:

io.debezium.schema.DatabaseSchema<io.debezium.relational.TableId>, AutoCloseable

public class RelationAwarePostgresSchema
extends io.debezium.connector.postgresql.PostgresSchema

Extends PostgresSchema to dispatch Relation messages as schema change events via the event queue and expose buildAndRegisterSchema as public.

Field Summary

Fields inherited from class io.debezium.connector.postgresql.PostgresSchema

PUBLIC_SCHEMA_NAME

Fields inherited from interface io.debezium.schema.DatabaseSchema

NO_CAPTURED_DATA_COLLECTIONS_WARNING

Constructor Summary

Constructors

Constructor

Description

RelationAwarePostgresSchema(io.debezium.connector.postgresql.PostgresConnectorConfig config, io.debezium.connector.postgresql.TypeRegistry typeRegistry, io.debezium.connector.postgresql.connection.PostgresDefaultValueConverter defaultValueConverter, io.debezium.schema.TopicSelector<io.debezium.relational.TableId> topicSelector, io.debezium.connector.postgresql.PostgresValueConverter valueConverter)

Method Summary

Modifier and Type	Method	Description
void	applySchemaChangesForTable(int relationId, io.debezium.relational.Table table)
void	buildAndRegisterSchema(io.debezium.relational.Table table)
void	setDispatcher(SchemaDispatcher dispatcher)

Methods inherited from class io.debezium.connector.postgresql.PostgresSchema

getToastableColumnsForTableId, getTypeRegistry, isFilteredOut, parse, refresh, refresh, refreshSchemas, tableFor, tableInformationComplete

Methods inherited from class io.debezium.relational.RelationalDatabaseSchema

assureNonEmptySchema, clearSchemas, close, getTableFilter, isHistorized, refresh, refreshSchema, removeSchema, schemaFor, tableFor, tableIds, tables

Methods inherited from class java.lang.Object

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

Constructor Detail

RelationAwarePostgresSchema

public RelationAwarePostgresSchema(io.debezium.connector.postgresql.PostgresConnectorConfig config,
                                   io.debezium.connector.postgresql.TypeRegistry typeRegistry,
                                   io.debezium.connector.postgresql.connection.PostgresDefaultValueConverter defaultValueConverter,
                                   io.debezium.schema.TopicSelector<io.debezium.relational.TableId> topicSelector,
                                   io.debezium.connector.postgresql.PostgresValueConverter valueConverter)

Method Detail

setDispatcher

public void setDispatcher(SchemaDispatcher dispatcher)

applySchemaChangesForTable

public void applySchemaChangesForTable(int relationId,
                                       io.debezium.relational.Table table)

Overrides:

applySchemaChangesForTable in class io.debezium.connector.postgresql.PostgresSchema

buildAndRegisterSchema

public void buildAndRegisterSchema(io.debezium.relational.Table table)

Overrides:

buildAndRegisterSchema in class io.debezium.relational.RelationalDatabaseSchema