Package io.debezium.connector.postgresql

Class Utils

java.lang.Object

io.debezium.connector.postgresql.Utils

public final class Utils
extends Object

A utility class for accessing various Debezium package-private methods.

Constructor Summary

Constructors

Constructor	Description
Utils()

Method Summary

Modifier and Type	Method	Description
static PostgresOffset	currentOffset(PostgresConnection jdbcConnection)
static Lsn	lastKnownLsn(io.debezium.connector.postgresql.PostgresOffsetContext ctx)
static io.debezium.connector.postgresql.PostgresSchema	refreshSchema(io.debezium.connector.postgresql.PostgresSchema schema, PostgresConnection pgConnection, boolean printReplicaIdentityInfo)

Methods inherited from class java.lang.Object

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

Constructor Detail

Utils

public Utils()

Method Detail

lastKnownLsn

public static Lsn lastKnownLsn(io.debezium.connector.postgresql.PostgresOffsetContext ctx)

currentOffset

public static PostgresOffset currentOffset(PostgresConnection jdbcConnection)

refreshSchema

public static io.debezium.connector.postgresql.PostgresSchema refreshSchema(io.debezium.connector.postgresql.PostgresSchema schema,
                                                                            PostgresConnection pgConnection,
                                                                            boolean printReplicaIdentityInfo)
                                                                     throws SQLException

Throws:

SQLException