在Flink SQL中构建一个JSON_Object值



我有一个Flink表,我想为它编写一个选择查询,该查询将返回基于某些字段的JSON对象。

这是我想做的查询(基于方解石语法:https://calcite.apache.org/docs/reference.html#constructor-功能(:

SELECT 
myIdField,
aFloatField,
JSON_OBJECT('aFieldName':aFloatField)
FROM myTable

但是当我尝试将这个查询与Flink一起使用时,我会得到以下错误:

org.apache.flink.table.api.ValidationException: SQL validation failed. No match found for function signature JSON_OBJECT(<null>, , )

这样做的好方法是什么?我在Flink文档中找不到任何关于这方面的信息。

Flink 1.15:支持JSON_OBJECT

https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/functions/systemfunctions/#json-功能

相关内容

  • 没有找到相关文章

最新更新