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)