假设我有一个配置流，我想将其广播到流程运算符的所有实例，并且我有另一个无键输入流。我想要这样的ProcessFunction/WindowFunction，它可以接受配置流和输入流，并且可以定期处理缓存的输入。
我知道一种解决方案是使用带有硬编码密钥的KeyedProcessFunction。(也许我错了(但我尽量避免使用它，因为我认为ProcessFunction将节省网络传输，因为输入将均匀分布到不同任务管理器中流程函数的所有实例。
任何帮助都将不胜感激！
试试BroadcastStream：https://ci.apache.org/projects/flink/flink-docs-stable/dev/stream/state/broadcastrongtate.html.它适用于键控或非键控流。文档中的示例演示了它的典型用法：将模式(例如配置流(广播到键控流(可以是非键控流，例如输入流(。