Uses of Class
io.debezium.connector.postgresql.connection.Lsn
-
Packages that use Lsn Package Description io.debezium.connector.postgresql io.debezium.connector.postgresql.connection org.apache.flink.cdc.connectors.postgres.source.offset -
-
Uses of Lsn in io.debezium.connector.postgresql
Methods in io.debezium.connector.postgresql that return Lsn Modifier and Type Method Description static LsnUtils. lastKnownLsn(io.debezium.connector.postgresql.PostgresOffsetContext ctx) -
Uses of Lsn in io.debezium.connector.postgresql.connection
Fields in io.debezium.connector.postgresql.connection declared as Lsn Modifier and Type Field Description static LsnLsn. INVALID_LSNZero is used indicate an invalid pointer.static LsnLsn. NO_STOPPING_LSNThe max lsn for the wal file.Methods in io.debezium.connector.postgresql.connection that return Lsn Modifier and Type Method Description static LsnLsn. valueOf(Long value)static LsnLsn. valueOf(String strValue)Create LSN instance by string represent LSN.static LsnLsn. valueOf(org.postgresql.replication.LogSequenceNumber value)Methods in io.debezium.connector.postgresql.connection with parameters of type Lsn Modifier and Type Method Description intLsn. compareTo(Lsn o)voidPostgresReplicationConnection. setEndingPos(Lsn endingPos)io.debezium.connector.postgresql.connection.ReplicationStreamPostgresReplicationConnection. startStreaming(Lsn offset, io.debezium.connector.postgresql.connection.WalPositionLocator walPosition) -
Uses of Lsn in org.apache.flink.cdc.connectors.postgres.source.offset
Methods in org.apache.flink.cdc.connectors.postgres.source.offset that return Lsn Modifier and Type Method Description LsnPostgresOffset. getLsn()
-