Arvid Heise created FLINK-37969:
-----------------------------------

             Summary: Allow Transformation subgraphs to be merged during 
translation
                 Key: FLINK-37969
                 URL: https://issues.apache.org/jira/browse/FLINK-37969
             Project: Flink
          Issue Type: Improvement
          Components: API / Core
    Affects Versions: 2.1.0
            Reporter: Arvid Heise
            Assignee: Arvid Heise


Transformations are immutable by design and thus planner or DataStream API need 
to generate a subgraph in one pass. However, there are some use cases where we 
would attach some small subgraph to a larger subgraph before translation into a 
StreamGraph. For example, system views in SQL may actually refer to specific 
parts of the query where we would like to add a subgraph to a side-output.

This ticket is about providing a mechanism to later rewire transformations 
during translation without losing the immutability of transformations.



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

Reply via email to