[jira] [Created] (FLINK-21261) Improve digest of physical Expand node

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-21261) Improve digest of physical Expand node

Shang Yuanchun (Jira)
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)