apache-kafka - 如何转换来自 KSQL 的响应 - UDF 返回 JSON 数组到列
问题描述
我有一个名为 getCityStats(string city, double distance) 的自定义 UDF,它接受 2 个参数并返回一个 JSON 字符串数组(对象),如下所示
{"zipCode":"90921","mode":3.54} {"zipCode":"91029","mode":7.23} {"zipCode":"96928","mode":4.56} {"zipCode":"90921","mode":6.54} {"zipCode":"91029","mode":4.43} {"zipCode":"96928","mode":3.96}
我想在 KSQL 表创建查询中将它们处理为
create table city_stats
as
select
zipCode,
avg(mode) as mode
from
(select
getCityStats(city,distance) as (zipCode,mode)
from
city_data_stream
) t
group by zipCode;
换句话说,KSQL 是否可以处理元组类型,其中可以处理 Json 字符串数组以在表创建查询中返回如上所示?
解决方案
推荐阅读
- reactjs - 使用 React 实现 shufflejs 的问题
- django - django 导入 AUTH_USER_MODEL
- r - 闪亮和 CSV 文件
- ios - Firebase 动态链接在全新安装后不起作用 (iOS)
- amazon-web-services - 尝试在 CloudFormation 上创建堆栈时,状态仅从 CREATE_IN_PROGRESS 更改为 ROLLBACK_COMPLETE
- angularjs - 状态更改后angularjs ng-model不绑定
- maven - 如何正确配置我的连接面?
- python - 使用 Pytube 从 YouTube 下载播放列表
- excel - 分组形状
- node.js - constant_score 查询不支持在代码中查询