flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Timo Walther (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-7171) Remove identity project for time attributes
Date Thu, 13 Jul 2017 10:04:01 GMT
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.

streamUtil.addTable[(Int, String, Long)](
    "MyTable", 'a, 'b, 'c, 'proctime.proctime, 'rowtime.rowtime)


streamUtil.addTable[(Int, String, Long)](
    "MyTable", 'a, 'b, 'c)

Lead to different logical plans even if these attributes are not accessed in {{"SELECT DISTINCT
a, b, c FROM MyTable"}}.

          term("select", "a, b, c")
        term("groupBy", "a, b, c"),
        term("select", "a, b, c")

This message was sent by Atlassian JIRA

View raw message