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

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

Timo Walther created FLINK-7171:
-----------------------------------

             Summary: 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
            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)