我完全不喜欢Apache·Flink。只是想把我的手弄脏。我有下面的场景。
事件的数据流
事件的数据流
规则的数据流
基于ruleid组合这两个数据流
现在我有一个tuple3的数据流 <ruleId, Rule, Event> . 这些规则是我想在事件上运行的sql查询。
我正在学习动态表和flinksql的概念。我不知道如何进一步处理。有人能帮我解决这个问题吗？
我完全不喜欢Apache·Flink。只是想把我的手弄脏。我有下面的场景。
事件的数据流
事件的数据流
规则的数据流
基于ruleid组合这两个数据流
现在我有一个tuple3的数据流 <ruleId, Rule, Event> . 这些规则是我想在事件上运行的sql查询。
我正在学习动态表和flinksql的概念。我不知道如何进一步处理。有人能帮我解决这个问题吗？
1条答案
按热度按时间voj3qocg1#
flink可以对数据流执行sql查询。sql被转换成流处理作业并执行。您可以使用flinksql连接两个事件流（flink1.4.0支持窗口化流连接）。
您不能轻易地使用flinksql来评估您的规则，因为每个规则都将转换为一个独立的流作业。因此规则消息将由一个作业处理并触发另一个作业的执行。