我一直在努力与flink功能，以能够解决以下详细的问题；
存在多个异步馈送的数据源。手段；一个消息源每x秒发送一次消息，另一个消息源每y秒发送一次消息。
我想根据这些来源的特定值的最新值应用一些规则；例如；
val（x）>10和val（y）>20
到目前为止我所做的是；过滤这两个不同的源，得到我唯一关心的值，并将它们保存在一个哈希Map中，然后用这个哈希Map给另一个流。

此进程事件对每个哈希Map示例运行规则，然后采取适当的操作。