[FLINK-12087] Introduce over window operators to blink batch

• Type: New Feature
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.9.0
• Component/s: Table SQL / Runtime
• Labels: pull-request-available
• Assignee: Jingsong Lee
• Reporter: Jingsong Lee
• Created: 03/Apr/19 02:50
• Updated: 10/Apr/19 12:39
• Resolved: 10/Apr/19 12:39

Description

Introduce NonBufferOverWindowOperator: Some over windows do not need to buffer data, such as rank, rows between unbounded preceding and 0, etc. We introduce NonBufferOverWindowOperator to reduce the overhead of data copy in buffer.

Introduce BufferDataOverWindowOperator and OverWindowFrame: 1. Minimize duplicate computation in various OverWindowFrame implementations. 2. An OverWindowOperator can compute multiple window frames.

Issue Links

• is a child of: FLINK-11490 Add an initial Blink SQL batch runtime
• links to: GitHub Pull Request #8102