| 程序包 | 说明 |
|---|---|
| org.apache.flink.streaming.api.datastream |
| 限定符和类型 | 方法和说明 |
|---|---|
IterativeStream<T> |
DataStream.iterate()
已过时。
This method is deprecated since Flink 1.19. The only known use case of this
Iteration API comes from Flink ML, which already has its own implementation of iteration
and no longer uses this API. If there's any use cases other than Flink ML that needs
iteration support, please reach out to dev@flink.apache.org and we can consider making
the Flink ML iteration implementation a separate common library.
|
IterativeStream<T> |
DataStream.iterate(long maxWaitTimeMillis)
已过时。
This method is deprecated since Flink 1.19. The only known use case of this
Iteration API comes from Flink ML, which already has its own implementation of iteration
and no longer uses this API. If there's any use cases other than Flink ML that needs
iteration support, please reach out to dev@flink.apache.org and we can consider making
the Flink ML iteration implementation a separate common library.
|
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.