将BroadCastConnectedStream连接到AsyncIO [英] Connecting a BroadcastConnectedStream to AsyncIO
本文介绍了将BroadCastConnectedStream连接到AsyncIO的处理方法，对大家解决问题具有一定的参考价值，需要的朋友们下面随着小编来一起学习吧！
问题描述
我需要使AsyncIO丰富的函数根据最新的规则集执行调用。对于像map这样的操作，我能够通过关注这篇博客文章来处理具有丰富功能的BroadCastConnectedStream：https://flink.apache.org/2019/06/26/broadcast-state.html
但是，创建AsyncIO函数需要数据流作为输入，而BroadCastConnectedStream不需要(https://ci.apache.org/projects/flink/flink-docs-stable/api/java/index.html?org/apache/flink/streaming/api/datastream/BroadcastConnectedStream.html)
有没有人对我如何绕过这个限制有什么想法？场景是，我想要一个异步函数，当对外部世界的异步调用出现非暂时性错误时，将传入消息隐藏在状态中，并在Kafka上收到"继续"消息后恢复操作(我认为我可以用广播流来做这件事)
推荐答案
我认为应该可以将BroadCastProcessFunction(不是键控函数)放在异步I/O操作符之前，但您必须联合正在处理的其他流，因为异步I/O只有一个输入。考虑到这有多难看，寻找其他方式来传达继续前进的信号可能更可取。
或者您可能希望查看Stateful Functions，它在这方面具有更大的灵活性。
这篇关于将BroadCastConnectedStream连接到AsyncIO的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！
查看全文
