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: {code} val table = stream.toTable(tEnv, 'rowtime.rowtime, 'int, 'double, 'float, 'bigdec, 'string) val t = table .window(Tumble over 2.millis on 'rowtime as 'w) .groupBy('w) .select('w.rowtime as 'rowtime, 'int.count as 'int) .window(Tumble over 4.millis on 'rowtime as 'w2) .groupBy('w2) .select('w2.rowtime, 'w2.end, 'int.count) {code} 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 (v6.3.15#6346)