flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Benchao Li <libenc...@gmail.com>
Subject Re: Flink SQL中动态嵌套字段如何定义DDL
Date Tue, 31 Mar 2020 06:59:58 GMT
可以尝试把data字段定义为一个map类型。

111 <xinghalo@163.com> 于2020年3月31日周二 下午2:56写道:

> Hi,
> 我们在使用streamsets作为CDC工具,输出到kafka中的内容是嵌套多变的类型,如:
> {database:a, table: b, type:update, data:{a:1,b:2,c:3}}
> {database:a, table: c, type:update, data:{c:1,d:2}}
> 请问这种类型该如何定义DDL?
>
>
> Best,
> Xinghalo
>
>

-- 

Benchao Li
School of Electronics Engineering and Computer Science, Peking University
Tel:+86-15650713730
Email: libenchao@gmail.com; libenchao@pku.edu.cn
Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message