首页 > 解决方案 > Flink 中对数据流执行 sql 查找的最有效方法

问题描述

给定来自 Kafka 的数据流,是否有内置方式,或者执行 SQL 查找的最有效方式是什么。

例如,将流对象连接到 sql 表并将其与 Kafka 数据流连接。给定一个可以临时更新的 sql 表,

标签: sqlapache-flink

解决方案


似乎显而易见的答案是使用 Flink 的 SQL API,它在此处记录

还有一些Flink SQL 培训,其中包括基于 docker 的设置,您可以在其中使用 Flink 的 SQL 客户端对 Kafka 数据流进行交互式 SQL 查询。


推荐阅读