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-6584) Support multiple consecutive windows in SQL
Date Mon, 15 May 2017 10:27:04 GMT
Timo Walther created FLINK-6584:

             Summary: Support multiple consecutive windows in SQL
                 Key: FLINK-6584
                 URL: https://issues.apache.org/jira/browse/FLINK-6584
             Project: Flink
          Issue Type: New Feature
          Components: Table API & SQL
            Reporter: Timo Walther

Right now, the Table API supports multiple consecutive windows as follows:

val table = stream.toTable(tEnv, 'rowtime.rowtime, 'int, 'double, 'float, 'bigdec, 'string)

val t = table
  .window(Tumble over 2.millis on 'rowtime as 'w)
  .select('w.rowtime as 'rowtime, 'int.count as 'int)
  .window(Tumble over 4.millis on 'rowtime as 'w2)
  .select('w2.rowtime, 'w2.end, 'int.count)

Similar behavior should be supported by the SQL API as well. We need to introduce a new auxiliary
group function, but this should happen in sync with Apache Calcite.

This message was sent by Atlassian JIRA

View raw message