[FLINK-4679] Add TumbleRow row-windows to Table API

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Won't Do
• Affects Version/s: 1.2.0
• Component/s: Table SQL / API
• Assignee: Jark Wu
• Reporter: Fabian Hueske
• Created: 26/Sep/16 13:31
• Updated: 07/May/17 13:56
• Resolved: 07/May/17 13:56

Description

Add TumbleRow row-windows for streaming tables as described in FLIP-11.

TumbleRow row windows are a syntactic shortcut for a special type of SQL OVER windows, i.e., windows of the from

SELECT STREAM rowtime,
  productId,
  units,
  SUM(units) OVER (PARTITION BY FLOOR(rowtime() TO HOUR)) AS unitsSinceTopOfHour
FROM Orders;

i.e., OVER windows which are partitioned by the time attribute.

This issue is about extending the Table API with the TumbleRow shortcut. It should reuse the OVER window translation and runtime code implemented by FLINK-5653, FLINK-5654, FLINK-5655, FLINK-5656, FLINK-5657, and FLINK-5658.

Issue Links

• requires: FLINK-5653 Add processing time OVER ROWS BETWEEN x PRECEDING aggregation to SQL
• requires: FLINK-5654 Add processing time OVER RANGE BETWEEN x PRECEDING aggregation to SQL
• requires: FLINK-5655 Add event time OVER RANGE BETWEEN x PRECEDING aggregation to SQL
• requires: FLINK-5656 Add processing time OVER ROWS BETWEEN UNBOUNDED PRECEDING aggregation to SQL
• requires: FLINK-5658 Add event time OVER ROWS BETWEEN UNBOUNDED PRECEDING aggregation to SQL
• requires: FLINK-5657 Add processing time OVER RANGE BETWEEN UNBOUNDED PRECEDING aggregation to SQL