sql - Flink 中对数据流执行 sql 查找的最有效方法
问题描述
给定来自 Kafka 的数据流,是否有内置方式,或者执行 SQL 查找的最有效方式是什么。
例如,将流对象连接到 sql 表并将其与 Kafka 数据流连接。给定一个可以临时更新的 sql 表,
解决方案
似乎显而易见的答案是使用 Flink 的 SQL API,它在此处记录。
还有一些Flink SQL 培训,其中包括基于 docker 的设置,您可以在其中使用 Flink 的 SQL 客户端对 Kafka 数据流进行交互式 SQL 查询。
推荐阅读
- sql - 如何在 Big Query 中查找和求和路径不同但 ID 相同的 URL?
- c# - 如何创建与默认格式相同的 API 错误响应格式?
- java - 在 JPA/Hibernates 中使用 @GeneratorType 时如何知道生成器类中的字段名称
- python - python multiprocessing - 在复杂的数据结构上使用 Pool.map
- java - jsonb 数组的构建标准
- python - 有没有办法在发推文时使用 Arduino 作为 Twitter 通知
- excel - Excel 空闲超时,并带有一个定时消息框警告在设定的时间内保存和关闭
- javascript - 如何在 Sequelize 中对 paraloid 进行级联删除?
- adobe - 无法从 pdfium 中的 abobe pdf 获取突出显示颜色
- casting - 将浮点数转换为短并返回浮点数