Uses of Class
io.debezium.connector.postgresql.connection.PostgresConnection

Packages that use PostgresConnection

Package	Description
io.debezium.connector.postgresql
io.debezium.connector.postgresql.connection
org.apache.flink.cdc.connectors.postgres.source
org.apache.flink.cdc.connectors.postgres.source.fetch
org.apache.flink.cdc.connectors.postgres.source.utils
org.apache.flink.cdc.connectors.postgres.utils

Uses of PostgresConnection in io.debezium.connector.postgresql

Methods in io.debezium.connector.postgresql with parameters of type PostgresConnection

Modifier and Type	Method	Description
static io.debezium.connector.postgresql.connection.ReplicationConnection	PostgresObjectUtils.createReplicationConnection(io.debezium.connector.postgresql.PostgresTaskContext taskContext, PostgresConnection postgresConnection, boolean doSnapshot, io.debezium.connector.postgresql.PostgresConnectorConfig connectorConfig)
static PostgresOffset	Utils.currentOffset(PostgresConnection jdbcConnection)
static RelationAwarePostgresSchema	PostgresObjectUtils.newSchema(PostgresConnection connection, io.debezium.connector.postgresql.PostgresConnectorConfig config, io.debezium.connector.postgresql.TypeRegistry typeRegistry, io.debezium.schema.TopicSelector<io.debezium.relational.TableId> topicSelector, io.debezium.connector.postgresql.PostgresValueConverter valueConverter)	Create a new PostgresSchema and initialize the content of the schema.
static RelationAwarePostgresSchema	PostgresObjectUtils.newSchema(PostgresConnection connection, io.debezium.connector.postgresql.PostgresConnectorConfig config, io.debezium.connector.postgresql.TypeRegistry typeRegistry, io.debezium.schema.TopicSelector<io.debezium.relational.TableId> topicSelector, io.debezium.connector.postgresql.PostgresValueConverter valueConverter, Collection<io.debezium.relational.history.TableChanges.TableChange> tableChanges)
static io.debezium.connector.postgresql.PostgresSchema	Utils.refreshSchema(io.debezium.connector.postgresql.PostgresSchema schema, PostgresConnection pgConnection, boolean printReplicaIdentityInfo)
static void	PostgresObjectUtils.waitForReplicationSlotReady(int retryTimes, PostgresConnection jdbcConnection, String slotName, String pluginName)

Constructors in io.debezium.connector.postgresql with parameters of type PostgresConnection

Constructor

Description

PostgresStreamingChangeEventSource(io.debezium.connector.postgresql.PostgresConnectorConfig connectorConfig, io.debezium.connector.postgresql.spi.Snapshotter snapshotter, PostgresConnection connection, io.debezium.connector.postgresql.PostgresEventDispatcher<io.debezium.relational.TableId> dispatcher, io.debezium.pipeline.ErrorHandler errorHandler, io.debezium.util.Clock clock, io.debezium.connector.postgresql.PostgresSchema schema, io.debezium.connector.postgresql.PostgresTaskContext taskContext, io.debezium.connector.postgresql.connection.ReplicationConnection replicationConnection)

Uses of PostgresConnection in io.debezium.connector.postgresql.connection

Methods in io.debezium.connector.postgresql.connection with parameters of type PostgresConnection

Modifier and Type	Method	Description
static PostgresOffset	PostgresConnectionUtils.committedOffset(PostgresConnection jdbcConnection, String slotName, String pluginName)
io.debezium.connector.postgresql.connection.ReplicationConnection.Builder	PostgresReplicationConnection.ReplicationConnectionBuilder.jdbcMetadataConnection(PostgresConnection jdbcConnection)

Uses of PostgresConnection in org.apache.flink.cdc.connectors.postgres.source

Methods in org.apache.flink.cdc.connectors.postgres.source that return PostgresConnection

Modifier and Type	Method	Description
PostgresConnection	PostgresDialect.openJdbcConnection()

Methods in org.apache.flink.cdc.connectors.postgres.source with parameters of type PostgresConnection

Modifier and Type	Method	Description
PostgresReplicationConnection	PostgresDialect.openPostgresReplicationConnection(PostgresConnection jdbcConnection)

Uses of PostgresConnection in org.apache.flink.cdc.connectors.postgres.source.fetch

Methods in org.apache.flink.cdc.connectors.postgres.source.fetch that return PostgresConnection

Modifier and Type	Method	Description
PostgresConnection	PostgresSourceFetchTaskContext.getConnection()

Constructors in org.apache.flink.cdc.connectors.postgres.source.fetch with parameters of type PostgresConnection

Constructor	Description
PostgresSnapshotSplitReadTask(PostgresSourceConfig sourceConfig, PostgresConnection jdbcConnection, io.debezium.connector.postgresql.PostgresConnectorConfig connectorConfig, io.debezium.connector.postgresql.PostgresSchema databaseSchema, io.debezium.connector.postgresql.PostgresOffsetContext previousOffset, io.debezium.connector.postgresql.PostgresEventDispatcher<io.debezium.relational.TableId> eventDispatcher, io.debezium.pipeline.source.spi.SnapshotProgressListener snapshotProgressListener, SnapshotSplit snapshotSplit)
StreamSplitReadTask(io.debezium.connector.postgresql.PostgresConnectorConfig connectorConfig, io.debezium.connector.postgresql.spi.Snapshotter snapshotter, PostgresConnection connection, io.debezium.connector.postgresql.PostgresEventDispatcher<io.debezium.relational.TableId> eventDispatcher, WatermarkDispatcher watermarkDispatcher, io.debezium.pipeline.ErrorHandler errorHandler, io.debezium.util.Clock clock, io.debezium.connector.postgresql.PostgresSchema schema, io.debezium.connector.postgresql.PostgresTaskContext taskContext, io.debezium.connector.postgresql.connection.ReplicationConnection replicationConnection, StreamSplit streamSplit)

Uses of PostgresConnection in org.apache.flink.cdc.connectors.postgres.source.utils

Constructors in org.apache.flink.cdc.connectors.postgres.source.utils with parameters of type PostgresConnection

Constructor	Description
CustomPostgresSchema(PostgresConnection jdbcConnection, PostgresSourceConfig sourceConfig)

Uses of PostgresConnection in org.apache.flink.cdc.connectors.postgres.utils

Methods in org.apache.flink.cdc.connectors.postgres.utils with parameters of type PostgresConnection

Modifier and Type	Method	Description
static Schema	PostgresSchemaUtils.getTableSchema(io.debezium.relational.TableId tableId, PostgresSourceConfig sourceConfig, PostgresConnection jdbc)
static Schema	PostgresSchemaUtils.getTableSchema(TableId tableId, PostgresSourceConfig sourceConfig, PostgresConnection jdbc)