Flink中数据集上的异步I / O等效于什么？对于DataStream，它基本上是AsyncDataStream。
在map函数中进行阻塞调用？
他们有最佳做法吗？
我可以通过实现，RichMapPartitionFunction在输入上提供迭代器，并通过收集器发出结果。
由于DataSet API不需要与检查点机制集成，也不需要遵守记录和时间戳的顺序，因此尽管MapPartitionFunction不提供任何特定于异步的工具，但实现时并不需要太复杂。
本文收集自互联网，转载请注明来源。
如有侵权，请联系[email protected] 删除。
我来说两句