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

Class PostgresOffsetUtils

java.lang.Object

org.apache.flink.cdc.connectors.postgres.source.offset.PostgresOffsetUtils

public class PostgresOffsetUtils
extends Object

Utils for handling PostgresOffset.

Constructor Summary

Constructors

Constructor	Description
PostgresOffsetUtils()

Method Summary

Modifier and Type	Method	Description
static io.debezium.connector.postgresql.PostgresOffsetContext	getPostgresOffsetContext(io.debezium.connector.postgresql.PostgresOffsetContext.Loader loader, Offset offset)

Methods inherited from class java.lang.Object

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

Constructor Detail

PostgresOffsetUtils

public PostgresOffsetUtils()

Method Detail

getPostgresOffsetContext

public static io.debezium.connector.postgresql.PostgresOffsetContext getPostgresOffsetContext(io.debezium.connector.postgresql.PostgresOffsetContext.Loader loader,
                                                                                              Offset offset)