[jira] [Assigned] (FLINK-37104) Code simplification and cleaning related to Flink CDC YAML Transform

["Leonard Xu (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/FLINK-37104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Leonard Xu reassigned FLINK-37104:
----------------------------------

    Assignee: yux

> Code simplification and cleaning related to Flink CDC YAML Transform
> --------------------------------------------------------------------
>
>                 Key: FLINK-37104
>                 URL: https://issues.apache.org/jira/browse/FLINK-37104
>             Project: Flink
>          Issue Type: Improvement
>          Components: Flink CDC
>            Reporter: Wenkai Qi
>            Assignee: yux
>            Priority: Minor
>              Labels: pull-request-available
>   Original Estimate: 504h
>  Remaining Estimate: 504h
>
> Code simplification and cleaning related to Flink CDC YAML Transform.
> For example: 
> Task construction stage: Each TransformRule corresponds to one PostTransformer, and one PostTransformer corresponds to one TransformProjection and TransformFilter.
> Task running stage: Each TableId corresponds to one or more projection rule Strings. One TableId plus one projection rule String corresponds to one TransformProjectionProcessor, and one TransformProjectionProcessor corresponds to one TransformProjection.
> In the two stages, the correspondence of TransformProjection is different. TransformRule and the projection rule String have a one-to-one relationship, so in the task construction stage, a TransformRule only corresponds to one TransformProjection; in the task running stage, the projection rule String corresponds to multiple TransformProjections.
> TransformProjection should be split into two classes according to the usage scenarios.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)