[FLINK-19268] FLIP-140: Introduce batch-style execution for bounded keyed streams

• Type: New Feature
• Status: Closed
• Priority: Major
• Resolution: Implemented
• Fix Version/s: 1.12.0
• Component/s: API / DataStream
• Assignee: Dawid Wysakowicz
• Reporter: Dawid Wysakowicz
• Created: 17/Sep/20 07:16
• Updated: 14/Jan/21 09:20
• Resolved: 20/Oct/20 07:32

Description

As described in FLIP-140: https://cwiki.apache.org/confluence/display/FLINK/FLIP-140%3A+Introduce+bounded+style+execution+for+keyed+streams we want to introduce a "bounded" style execution for keyed operators with sorting the inputs.

Issue Links

• mentioned in: Page Loading...
• mentioned in: Page Loading...

Sub-Tasks

• Clean up the UnilateralSortMerger: Closed
• Make the PushingAsyncDataInput.DataOutput aware of endOfInput: Closed
• Extract an inteface from AbstractKeyedStateBackend: Closed
• Make InternalTimeServiceManager an interface: Closed
• Implement one input sorting DataInput: Closed
• Implement multi inputs sorting DataInput: Closed
• Implement a state backend that holds a single key at a time: Closed
• Implement a timer service that holds a single key at a time: Closed
• Expose to users the batch-style execution for bounded keyed streams: Closed