apache-kafka - KSQL 创建表作为选择
问题描述
CREATE TABLE AS SELECT 只能通过分组来完成,但是如何在 Base 中组织一个表(您需要一个没有聚合/分组的简单表)以便用数据补充另一个流?举个例子:有一个带有字段(产品,city_id)的流 A。我们需要一个带有字段(city_id,city_name)的表(或其他东西),由另一个线程补充。
并且有一个流将补充流 A 与表中的名称连接起来。
如何使用外部目录组织数据丰富?
解决方案
您可以通过LATEST_BY_OFFSET
这种方式使用聚合来构建数据表。
CREATE STREAM source_city_data
WITH (KAFKA_TOPIC='source_city_data', FORMAT='AVRO');
CREATE TABLE city_data AS
SELECT city_id, LATEST_BY_OFFSET(city_name) AS city_name
FROM source_city_data;
推荐阅读
- angular - Angular4获取具有多个参数的查询字符串
- d3.js - 将回归方程添加到散点图中
- python - 如何从现有列表中删除不是素数的数字
- apache-camel - 多个注释@JsonPath 不起作用
- svn - svn合并后的两个文件状态是什么意思?
- bash - 使用 exiftool 进行反向匹配
- ios - Audio Kit iOS 检测短麦克风输入的音高/频率,例如轻敲
- javascript - 使用 ajax 以 json 格式获取的数据被随机推送到数组中
- c++ - C++ shared_ptr 调用拥有对象的解构器
- java - 如何在java中更好地编写开关代码(精确数字的平滑移动)