flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Piotr Nowojski (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-9617) Provide alias for whole records in Table API
Date Tue, 19 Jun 2018 15:05:00 GMT
Piotr Nowojski created FLINK-9617:

             Summary: Provide alias for whole records in Table API
                 Key: FLINK-9617
                 URL: https://issues.apache.org/jira/browse/FLINK-9617
             Project: Flink
          Issue Type: Improvement
          Components: Table API &amp; SQL
    Affects Versions: 1.5.0
            Reporter: Piotr Nowojski

In SQL we can provide an alias for whole table to avoid column name collisions between two
tables. For example:
  SUM(o.amount * r.rate) 
  Orders AS o, 
  Rates AS r
WHERE r.currency = o.currency{code}
However that's not possible in table API. In Table API user have to provide aliases for all
of the columns, which can be annoying especially if table consists of tens or even hundred
of columns

For example I would expect some feature like this:
val result = orders.as('o)
  .join(rates(`o.rowtime).as('r), "o.currency = r.currency")
  .select("SUM(o.amount * r.rate) AS amount")
where \{{rates}} is a TableFunction.


This message was sent by Atlassian JIRA

View raw message