Skip to content

Commit a2b9a31

Browse files
committed
fix imports
1 parent ede19cb commit a2b9a31

File tree

2 files changed

+662
-673
lines changed

2 files changed

+662
-673
lines changed

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/table/PostgreSQLReadableMetadata.java

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -81,7 +81,8 @@ public Object read(SourceRecord record) {
8181
}),
8282

8383
/**
84-
* It indicates the time that the change was made in the database. If the record is read from
84+
* It indicates the time that the change was made in the database. If the record
85+
* is read from
8586
* snapshot of the table instead of the change stream, the value is always 0.
8687
*/
8788
OP_TS(
@@ -100,7 +101,8 @@ public Object read(SourceRecord record) {
100101
}),
101102

102103
/**
103-
* It indicates the row kind of the changelog. '+I' means INSERT message, '-D' means DELETE
104+
* It indicates the row kind of the changelog. '+I' means INSERT message, '-D'
105+
* means DELETE
104106
* message, '-U' means UPDATE_BEFORE message and '+U' means UPDATE_AFTER message
105107
*/
106108
ROW_KIND(

0 commit comments

Comments
 (0)