[FLINK-6253] Distinct rowTime with time range boundaries

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Duplicate
• Component/s: Table SQL / API
• Assignee: Unassigned
• Reporter: radu
• Created: 03/Apr/17 15:09
• Updated: 14/Feb/18 09:27
• Resolved: 14/Feb/18 09:27

Description

Support distinct aggregates with rowtime order and time range boundaries

Q1.4. `SELECT SUM( DISTINCT b) OVER (ORDER BY rowTime() RANGE BETWEEN INTERVAL '1' HOUR PRECEDING AND CURRENT ROW) FROM stream1`

Q1.4. `SELECT COUNT(b), SUM( DISTINCT b) OVER (ORDER BY rowTime() RANGE BETWEEN INTERVAL '1' HOUR PRECEDING AND CURRENT ROW) FROM stream1`