flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From oliver <zzh...@foxmail.com>
Subject Re: Flink1.10怎么样定义kafka中消息为json数组对象的情况
Date Fri, 24 Apr 2020 08:55:50 GMT
> 你的需求是需要把这一条消息解析成多个record么?
是的,之前使用Flink 1.8时是通过自定义UDTF结合LATERAL TABLE(My_EXPLODE(__message))
as T(msg),其中__message存放着kafka的整条消息,My_EXPLODE是自定义UDTF负责解析成多个record

flink-sql-connector-kafka插件是否也不支持获取整行消息?,比如以字符串的形式读取[{"a":"1","b":2,"obj":{"c":"3"}}]到__message


> 2020年4月24日 下午4:41,Benchao Li <libenchao@gmail.com> 写道:
> 
> 这个好像还不太能支持。
> 
> 你的需求是需要把这一条消息解析成多个record么?
> 
> Oliver <zzhbwh@foxmail.com> 于2020年4月24日周五 下午4:27写道:
> 
>> hi,all:
>>     网上有非常多的资料显示Flink SQL怎样定义嵌套的json属性以及json中某个属性为json数组的示例,
>>     但是对于整个消息为一个数组(json array)的应该怎么处理?
>>     json示例如下:
>> [
>>    {
>>        "a": "1",
>>        "b": 2
>>    }
>> ]
> 
> 
> 
> -- 
> 
> Benchao Li
> School of Electronics Engineering and Computer Science, Peking University
> Tel:+86-15650713730
> Email: libenchao@gmail.com; libenchao@pku.edu.cn

Mime
View raw message