[FLINK-6584] Support multiple consecutive windows in SQL

• Type: New Feature
• Status: Closed
• Priority: Blocker
• Resolution: Implemented
• Fix Version/s: 1.4.0
• Component/s: Table SQL / API
• Assignee: Timo Walther
• Reporter: Timo Walther
• Created: 15/May/17 10:27
• Updated: 25/Oct/17 20:13
• Resolved: 25/Oct/17 20:13

Description

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)
  .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)

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.

Issue Links

• is blocked by: FLINK-7024 Add supported for selecting window proctime/rowtime on row-based Tumble/Slide window
• is related to: FLINK-6429 Bump up Calcite version to 1.13
• links to: GitHub Pull Request #4199