Jark Wu created FLINK-21261:
-------------------------------
Summary: Improve digest of physical Expand node
Key: FLINK-21261
URL:
https://issues.apache.org/jira/browse/FLINK-21261 Project: Flink
Issue Type: Improvement
Components: Table SQL / Planner
Reporter: Jark Wu
Assignee: Jark Wu
Fix For: 1.13.0
Currently, the digest of {{StreamPhysicalExpand}} only geneartes field names, this loses many useful information, e.g. null fields, expand id, expand times.
{code}
Expand(projects=[a, b, c, $f3, $f4, $e])
{code}
The digest of {{BatchPhysicalExpand}} generates additional projects list, but the first {{projects}} is reduandent information, we can remove it.
{code}
Expand(projects=[a, c, $f2, d, $e, $f2_0], projects=[{a, c, $f2, d, 0 AS $e, $f2 AS $f2_0}, {a, c, null AS $f2, null AS d, 3 AS $e, $f2 AS $f2_0}])
{code}
The proposed digest of expand node would be:
{code}
Expand(projects=[{a, c, $f2, d, 0 AS $e, $f2 AS $f2_0}, {a, c, null AS $f2, null AS d, 3 AS $e, $f2 AS $f2_0}])
{code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)