异步数据流上的 Apache Flink 规则

Question

我一直在努力使用 flink 功能来解决以下详细问题；

1. 异步馈送的数据源不止一个。方法; 一个消息源每隔 X 秒发送一次消息，另一个消息源每隔 Y 秒发送一次消息。

2. 我想根据这些来源特定值的最新值应用一些规则； 例如;

val(x) > 10 和 val(y) > 20

1. 到目前为止，我所做的是； 过滤这两个不同的来源，得到我唯一关心的值，并将它们保存在哈希映射中，并用这个哈希映射提供另一个流。

4. 此流程事件对每个哈希映射实例运行规则，然后采取适当的措施。

Answer 1

如果您有两个流，您可以将它们连接起来并将它们输入CoFlatMapFunction，然后它可以跟踪每个流的最新值，并根据您对这些值的规则应用发出结果。