uicosp commented on code in PR #3776:
URL: https://github.com/apache/flink-cdc/pull/3776#discussion_r3056123547
##########
docs/content/docs/connectors/flink-sources/mysql-cdc.md:
##########
@@ -460,6 +460,13 @@ Only valid for cdc 1.x version. During a snapshot
operation, the connector will
For example updating an already updated value in snapshot, or deleting
an already deleted entry in snapshot. These replayed change log events should
be handled specially.
</td>
</tr>
+ <tr>
+ <td>scan.snapshot.filter</td>
+ <td>optional</td>
+ <td style="word-wrap: break-word;">(none)</td>
+ <td>String</td>
+ <td>When reading a table snapshot, the rows of captured tables will be
filtered using the specified filter expression (AKA a SQL WHERE clause). By
default, no filter is applied, meaning the entire table will be synchronized.
e.g. `id > 100`.</td>
+ </tr>
Review Comment:
Added usage examples in commit cc477d5:
- docs/connectors/pipeline-connectors/mysql.md — Added "Snapshot
Filters" section with a YAML pipeline example demonstrating the
scan.snapshot.filters list syntax.
- docs/connectors/flink-sources/mysql-cdc.md — Added "Snapshot
Filter" section with both SQL DDL and DataStream API examples
showing the scan.snapshot.filter option usage.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
