[FLINK-24642] Implements unified iteration to support algorithms in flink-ml

• Type: New Feature
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: ml-2.0.0
• Component/s: Library / Machine Learning
• Assignee: Yun Gao
• Reporter: Yun Gao
• Created: 26/Oct/21 09:22
• Updated: 15/Dec/21 03:14
• Resolved: 16/Nov/21 07:57

Sub-Tasks

• Introduce the flink-ml-iteration module and iteration api: Closed
• Introduce broadcast output to support broadcast events to all the downstream operators: Closed
• Implements the feedback mechanism and the controller operators: Closed
• Add operator wrapper for all-round iterations: Closed
• Add DraftExecutionEnvironment to support wrapping operators during compile time: Closed
• Support unbounded iteration.: Closed
• Support bounded all-round iteration: Closed
• Add operator wrapper for per-round operators: Closed
• Support per-round operators inside the iteration: Closed
• Support checkpoint for jobs using iteration: Closed
• Fix the issues with supporting keyed stream: Closed
• Support IterationBody with mixed per-round and all-round operators: Closed
• Fix the issues in checkpoints with iteration: Closed
• Support IterationListener for per-round operators: Closed
• Make outputs depends on tails for the iteration body: Closed