[FLINK-6250] Distinct procTime with Rows boundaries

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

Description

Support proctime with rows boundaries

Q1.1. `SELECT SUM( DISTINCT b) OVER (ORDER BY procTime() ROWS BETWEEN 2 PRECEDING AND CURRENT ROW) FROM stream1`

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

Issue Links

• links to: GitHub Pull Request #3732
• links to: GitHub Pull Request #3771