[FLINK-17735] Add specialized collecting iterator

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.11.0
• Component/s: API / DataStream
• Labels: pull-request-available
• Assignee: Caizhi Weng
• Reporter: Caizhi Weng
• Created: 15/May/20 12:59
• Updated: 16/Oct/20 10:34
• Resolved: 17/May/20 13:48

Description

Add specialized collecting iterator is needed to implement the algorithms in FLINK-14807

As legacy planner does not have data structures like ResettableExternalBuffer in Blink planner, we're not implementing the algorithms in legacy planner. Legacy planner just use the current collect implementation.

Issue Links

• links to: GitHub Pull Request #12073
• links to: GitHub Pull Request #12073