THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
FLIP-176: Unified Iteration to Support Algorithms has introduced a unified iteration library in the Flinkflink-ml repository. This library addresses all the issues present in the Iteration API of DataStream and could provide solution for all the iteration use-cases. However, maintaining two separate implementations of iteration in both the Flink repository and the Flink-ml repository would introduce unnecessary complexity and make it difficult to maintain the Iteration API.
We propose deprecating the Iteration API of DataStream and removing it completely before Flink 2.0. If other modules require the use of the Iteration API in the future, we can consider extracting all Iteration implementations from the flink-ml repository into an independent module.
Public Interfaces
| Class / Method | Annotation |
|---|---|
| org.apache.flink.streaming.api.datastream.DataStream#iterate() | PublicEvolving |
org.apache.flink.streaming.api.datastream.DataStream#iterate(long maxWaitTimeMillis) | |
| org.apache.flink.streaming.api.datastream.IterativeStream | |
| org.apache.flink.streaming.api.datastream.IterativeStream.ConnectedIterativeStreams | Public |
Proposed Changes
We propose deprecating the classes/methods mentioned above and subsequently removing the documentation about the Iteration of DataStream from the Flink website.
...