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)
