我一直在努力与flink功能,以能够解决以下详细的问题;
存在多个异步馈送的数据源。手段;一个消息源每x秒发送一次消息,另一个消息源每y秒发送一次消息。
我想根据这些来源的特定值的最新值应用一些规则;例如;
val(x)>10和val(y)>20
到目前为止我所做的是;过滤这两个不同的源,得到我唯一关心的值,并将它们保存在一个哈希Map中,然后用这个哈希Map给另一个流。
此进程事件对每个哈希Map示例运行规则,然后采取适当的操作。
我一直在努力与flink功能,以能够解决以下详细的问题;
存在多个异步馈送的数据源。手段;一个消息源每x秒发送一次消息,另一个消息源每y秒发送一次消息。
我想根据这些来源的特定值的最新值应用一些规则;例如;
val(x)>10和val(y)>20
到目前为止我所做的是;过滤这两个不同的源,得到我唯一关心的值,并将它们保存在一个哈希Map中,然后用这个哈希Map给另一个流。
此进程事件对每个哈希Map示例运行规则,然后采取适当的操作。
1条答案
按热度按时间5hcedyr01#
如果有两个流,可以将它们连接起来,并将它们提供给coflatmapfunction,该函数随后可以跟踪每个流的最新值,并根据规则对这些值的应用发出结果。