如何在 Flink-SQL 中将 json 字符串转换为 Array<Row<>>?如何使用 Flink-SQL 将嵌套的 json 数组字符串写入 Elasticsearch?

问题描述 投票:0回答:0

如何使用 sql api 创建数组列并发送 elasticsearch? https://github.com/ververica/flink-cdc-connectors/issues/2147

我需要在elasticsearch中创建一个大的物化视图,其中可能包含一些嵌套信息(因为页面行数必须等于根文档长度),现在我使用flik-sql将子表生成为json数组字符串,现在如何将json字符串转成Array>写入elasticarch?

apache-flink flink-streaming flink-sql
© www.soinside.com 2019 - 2024. All rights reserved.