unsubscribe On Thu, Dec 4, 2025 at 2:29 PM Xiqian Yu (Jira) <[email protected]> wrote:
> Xiqian Yu created FLINK-38779: > --------------------------------- > > Summary: 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 > > > 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) >
