Flink sql有没有函数支持解析一个json string并转成期望的数据类型呢？
Flink sql有没有函数支持解析一个json string并转成期望的数据类型呢？JSON_QUERY('{"a":[{"c":"c1"},{"c":"c2"}]}', 'lax $.a[*].c')这个内置函数返回的是string: '["c1","c2"]'，而我期望返回的是ARRAY: ["c1","c2"]
Flink CDC中debezium-json消息消费能直接开多并行度不？
Flink CDC中debezium-json消息消费能直接开多并行度不？有没有同学基于这个格式，只保存after的数据呀
flink sql有没有函数支持解析一个json string并转成期望的数据类型呢？
flink sql有没有函数支持解析一个json string并转成期望的数据类型呢？JSON_QUERY('{"a":[{"c":"c1"},{"c":"c2"}]}', 'lax $.a[].c')这个内置函数返回的是string: '["c1","c2"]'，而我期望返回的是ARRAY: ["c1","c2"]所以期望的sql长这样select parse_json( JSON_QU...
Flink 从kafka中消费到数据到map里每条转换json对象太耗时，有什么好的解决办法吗？
Flink 从kafka中消费到数据到map里每条转换json对象太耗时，繁忙100%，导致source反压，这种情况有什么好的解决办法吗？
Flink CDC的json是干哈的?
Flink CDC我自定义的DebeziumDeserializationSchema 里面是把数据和类型组装成了row 类型，在通过把流转为table tEnv.fromChangelogStream(mapStream) 你说的json是干哈的?
Flink使用fastjson 字符串 转json 方法 内存满了 ，有什么更好的方法 处理吗？
Flink使用fastjson 字符串 转json 方法 内存满了 ，有什么更好的方法 处理吗。
实时计算 Flink版sql1.13 怎么把数据以json格式写入kafka？
实时计算 Flink版sql1.13 怎么把数据以json格式写入kafka？
Flink该怎么取对应key的value呢？我用json获取方法不行，其它也没看到适合的函数。
Flink该怎么取对应key的value呢？我用json获取方法不行，其它也没看到适合的函数。
本页面内关键词为智能算法引擎基于机器学习所生成，如有任何问题，可在页面下方点击"联系我们"与我们沟通。
开发与运维
集结各类场景实战经验，助你开发运维畅行无忧
+关注