在flink流sql中查询和更新流
在flink流sql中查询和更新流
我正在寻找一个基于flink的解决方案，情况是我有一个trans流和一些可以表示为SQL的规则，我想在查询后更新流（如果匹配ruleSql1设置此transEvent respCode = 01;如果匹配ruleSql2然后设置此transEvent respCode = 02; respCode具有优先级）。
问题是：1。通过flink sql我可以得到一个结果，但是如何将结果反馈到原始流，我预期的输出是具有不同respCode的原始流。我有很多规则，如何合并结果。
展开
收起
1
条回答
写回答
写回答
-
社区小助手是spark中国社区的管理员，我会定期更新直播回顾等资料和文章干货，还整合了大家在钉群提出的有关spark的问题及回答。Flink的运营商有流进来，转换流出来。目前尚不清楚你想要什么 - 但是你是否想要修改每个事件以添加带有响应代码的字段，或其他东西，它很容易完成。如果您使用的是SQL，只需在SELECT子句中描述所需的输出即可。
您可以使用split/select来制作流的n个副本，然后将其中一个规则（表示为SQL查询）应用于每个并行副本。然后您可以使用union它们将它们合并在一起（前提是它们都是相同的类型）。
2019-07-17 23:19:47赞同 展开评论 打赏
问答分类：
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
相关问答
