File tree Expand file tree Collapse file tree 2 files changed +15
-1
lines changed
content.zh/docs/connectors/table/formats
content/docs/connectors/table/formats Expand file tree Collapse file tree 2 files changed +15
-1
lines changed Original file line number Diff line number Diff line change @@ -178,6 +178,12 @@ metadata fields for its value format.
178178 <td>The timestamp at which the connector processed the event. Corresponds to the <code>ts</code>
179179 field in the Canal record.</td>
180180 </tr>
181+ <tr>
182+ <td><code>event-timestamp</code></td>
183+ <td><code>TIMESTAMP(3) WITH LOCAL TIME ZONE NULL</code></td>
184+ <td>The timestamp when the corresponding change was executed in MySQL server. Corresponds to the <code>es</code>
185+ field in the Canal record.</td>
186+ </tr>
181187 </tbody>
182188</table >
183189
Original file line number Diff line number Diff line change @@ -181,6 +181,12 @@ metadata fields for its value format.
181181 <td>The timestamp at which the connector processed the event. Corresponds to the <code>ts</code>
182182 field in the Canal record.</td>
183183 </tr>
184+ <tr>
185+ <td><code>event-timestamp</code></td>
186+ <td><code>TIMESTAMP(3) WITH LOCAL TIME ZONE NULL</code></td>
187+ <td>The timestamp when the corresponding change was executed in MySQL server. Corresponds to the <code>es</code>
188+ field in the Canal record.</td>
189+ </tr>
184190 </tbody>
185191</table >
186192
@@ -193,9 +199,11 @@ CREATE TABLE KafkaTable (
193199 origin_sql_type MAP< STRING, INT > METADATA FROM ' value.sql-type' VIRTUAL,
194200 origin_pk_names ARRAY< STRING> METADATA FROM ' value.pk-names' VIRTUAL,
195201 origin_ts TIMESTAMP (3 ) METADATA FROM ' value.ingestion-timestamp' VIRTUAL,
202+ origin_es TIMESTAMP (3 ) METADATA FROM ' value.event-timestamp' VIRTUAL,
196203 user_id BIGINT ,
197204 item_id BIGINT ,
198- behavior STRING
205+ behavior STRING,
206+ WATERMARK FOR origin_es AS origin_es - INTERVAL ' 5' SECOND
199207) WITH (
200208 ' connector' = ' kafka' ,
201209 ' topic' = ' user_behavior' ,
You can’t perform that action at this time.
0 commit comments