java - 数据流上的 Flink sql 查询（Apache Flink Java）

Question

我对 Apache flink 完全是菜鸟。只是想弄脏我的手。我有以下情况。

1. 事件数据流
2. 事件数据流
3. 规则的数据流
4. 根据 ruleID 组合这两个数据流

现在我有一个 tuple3 的数据流，看起来像<ruleId, Rule, Event>. 这些规则是我想在事件上运行的 SQL 查询。

我正在研究动态表和 Flink SQL 的概念。我不确定如何进一步处理。有人可以帮我解决这个问题吗？

Answer 1

Flink 可以对数据流执行 SQL 查询。SQL 被翻译成流处理作业并被执行。您也许可以使用 Flink SQL 来连接两个事件流（Flink 1.4.0 支持窗口流连接）。

你不能轻易地使用 Flink SQL 来评估你的规则，因为每个规则都会转化为一个独立的流式作业。因此，一条规则消息将由一个作业处理并触发另一个作业的执行。