[jira] [Updated] (FLINK-7171) Remove identity project for time attributes

["Timo Walther (JIRA)" <ji...@apache.org>]

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

Timo Walther updated FLINK-7171:
--------------------------------
    Affects Version/s: 1.3.1

> Remove identity project for time attributes
> -------------------------------------------
>
>                 Key: FLINK-7171
>                 URL: https://issues.apache.org/jira/browse/FLINK-7171
>             Project: Flink
>          Issue Type: Improvement
>          Components: Table API & SQL
>    Affects Versions: 1.3.1
>            Reporter: Timo Walther
>
> If only time attributes are projected away, the translated plan should not contain an additional Calc node.
> Example:
> {code}
> streamUtil.addTable[(Int, String, Long)](
>     "MyTable", 'a, 'b, 'c, 'proctime.proctime, 'rowtime.rowtime)
> {code}
> and 
> {code}
> streamUtil.addTable[(Int, String, Long)](
>     "MyTable", 'a, 'b, 'c)
> {code}
> Lead to different logical plans even if these attributes are not accessed in {{"SELECT DISTINCT a, b, c FROM MyTable"}}.
> {code}
>       unaryNode(
>         "DataStreamGroupAggregate",
>         unaryNode(
>           "DataStreamCalc",
>           streamTableNode(0),
>           term("select", "a, b, c")
>         ),
>         term("groupBy", "a, b, c"),
>         term("select", "a, b, c")
>       )
> {code}



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)