[FLINK-6251] Distinct procTime with time range boundaries

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

Description

Support proctime distinct aggregates with time boundaries
Q1.2. `SELECT SUM( DISTINCT b) OVER (ORDER BY procTime() RANGE BETWEEN INTERVAL '1' HOUR PRECEDING AND CURRENT ROW) FROM stream1`

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