我正在尝试使用Apache Flink 1.11创建一个源表,以便可以访问JSON消息中的嵌套属性。我可以获取根属性的值,但不确定如何访问嵌套对象。
文档建议应该使用MAP
类型,但是当我设置它时,出现以下错误:
: java.lang.UnsupportedOperationException: class org.apache.calcite.sql.SqlIdentifier: MAP
这是我的SQL查询语句
CREATE TABLE input(
id VARCHAR,
title VARCHAR,
properties MAP
) WITH (
'connector' = 'kafka-0.11',
'topic' = 'my-topic',
'properties.bootstrap.servers' = 'localhost:9092',
'properties.group.id' = 'python-test',
'format' = 'json'
)
我的 JSON 数据看起来像这样:
{
"id": "message-1",
"title": "Some Title",
"properties": {
"foo": "bar"
}
}