apache-kafka - 如何转换来自 KSQL 的响应 - UDF 返回 JSON 数组到列

Question

我有一个名为 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 字符串数组以在表创建查询中返回如上所示？

Answer 1

不，KSQL 目前不支持您建议的语法。虽然 KSQL 可以处理数组，但它不支持任何类型的分解功能，因此您只能引用数组中的特定索引点。

如果合适，请随意查看并投票支持这些问题：#527、#1830，或者如果它们没有涵盖您想要做的事情，请提出您自己的问题。