Package | Description |
---|---|
io.debezium.connector.postgresql | |
io.debezium.connector.postgresql.connection | |
org.apache.flink.cdc.connectors.postgres.source.offset |
Modifier and Type | Method and Description |
---|---|
static Lsn |
Utils.lastKnownLsn(io.debezium.connector.postgresql.PostgresOffsetContext ctx) |
Modifier and Type | Field and Description |
---|---|
static Lsn |
Lsn.INVALID_LSN
Zero is used indicate an invalid pointer.
|
static Lsn |
Lsn.NO_STOPPING_LSN
The max lsn for the wal file.
|
Modifier and Type | Method and Description |
---|---|
static Lsn |
Lsn.valueOf(org.postgresql.replication.LogSequenceNumber value) |
static Lsn |
Lsn.valueOf(Long value) |
static Lsn |
Lsn.valueOf(String strValue)
Create LSN instance by string represent LSN.
|
Modifier and Type | Method and Description |
---|---|
int |
Lsn.compareTo(Lsn o) |
void |
PostgresReplicationConnection.setEndingPos(Lsn endingPos) |
io.debezium.connector.postgresql.connection.ReplicationStream |
PostgresReplicationConnection.startStreaming(Lsn offset,
io.debezium.connector.postgresql.connection.WalPositionLocator walPosition) |
Modifier and Type | Method and Description |
---|---|
Lsn |
PostgresOffset.getLsn() |
Copyright © 2025 The Apache Software Foundation. All rights reserved.