FlinkSQL如何定义JsonObject数据的字段类型

Sun, 06 Dec 2020 20:52:53 -0800 

Hi,
flink version: 1.11.2
api: flink-sql


场景：使用flink sql定义了一张kafka的source表，kafka中数据为json格式的字符串。
其中context是json的一个键，其值为jsonObject，数据示例如下：
{ 
 “id”: 1,
 "context”:  { 
  … 
(这里的数据为jsonObject，具体schema不确定，
由各个业务方自行确定，可能嵌套，也可能不嵌套，完全不可控)
   } 
}
建表语句为：
CREATE TABLE json_source ( 
id bigint,
context <TYPE>
) WITH (
 'connector' = 'kafka’, 
 'format' = 'json’ 
);


问题： 该使用什么数据类型来指定类型<TYPE>呢？从目前的flink sql 的 data type 
里感觉没有很合适的匹配项，不管是ROW，或者MAP都不太合适。


请求指教，万分感谢！

回复