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

Uses of PostgresConnection in io.debezium.connector.postgresql

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

Modifier and Type	Method and 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 io.debezium.connector.postgresql.PostgresSchema	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 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 and 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 and Description
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 and Description
PostgresConnection	PostgresDialect.openJdbcConnection()

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

Modifier and Type	Method and 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 and Description
PostgresConnection	PostgresSourceFetchTaskContext.getConnection()

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

Constructor and Description
PostgresSnapshotSplitReadTask(PostgresConnection jdbcConnection, io.debezium.connector.postgresql.PostgresConnectorConfig connectorConfig, io.debezium.connector.postgresql.PostgresSchema databaseSchema, io.debezium.connector.postgresql.PostgresOffsetContext previousOffset, JdbcSourceEventDispatcher dispatcher, 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, JdbcSourceEventDispatcher<io.debezium.connector.postgresql.PostgresPartition> dispatcher, io.debezium.connector.postgresql.PostgresEventDispatcher<io.debezium.relational.TableId> postgresEventDispatcher, 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 and Description
CustomPostgresSchema(PostgresConnection jdbcConnection, PostgresSourceConfig sourceConfig)