[
https://issues.apache.org/jira/browse/FLINK-38779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-38779:
-------------------------------
Fix Version/s: cdc-3.6.0
> YAML Pipeline router supports RegEx based routing
> -------------------------------------------------
>
> Key: FLINK-38779
> URL: https://issues.apache.org/jira/browse/FLINK-38779
> Project: Flink
> Issue Type: Improvement
> Components: Flink CDC
> Reporter: Xiqian Yu
> Assignee: Xiqian Yu
> Priority: Major
> Fix For: cdc-3.6.0
>
>
> CDC Pipeline router supports simple table name replacement for now. A route
> rule like this:
> {code:java}
> - { source-table: 'db.\\.*', sink-table: 'new_db.<>', replace-symbol: '<>' }
> {code}
> synchronizes all tables in `db` to `new_db`. More complicated routing rules,
> including re-mapping database and schema name, or capturing parts of
> identifiers, is not possible.
> Current API could be extended to support standard RegEx capturing &
> replacement syntaxes like this:
> {code:java}
> - { source-table: 'db.(\\.*)', sink-table: 'new_db.$1' }
> {code}
> and keep backwards compatiblility.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
