问答 2023-08-24 来自:开发者社区

Flink SQL sum() over() 函数要3条以上数据才会触发计算吗?

环境说明:flink 1.15 on yarn 模式,消费kafka的数据 sql 如下:select vin,forwardtime,fault_name,fault_value, SUM(1) OVER(PARTITION BY vin,fault_name ORDER BY forwardtime) as rn_sum from temp_vhr_mo...

问答 2023-08-14 来自:开发者社区

flink sql的这个函数怎么用啊?compositeType这个取什么值啊?我用字段名不行!

flink sql的这个函数怎么用啊?compositeType这个取什么值啊?我用字段名不行

问答 2023-08-01 来自:开发者社区

flink sql为啥没有split函数,还是改其他名了?

flink sql为啥没有split函数,还是改其他名了?

问答 2023-06-18 来自:开发者社区

老哥你好,我想问一下,Flink CDC中sql如何获取上一列的数据再做差值?我用的lag()函数但

老哥你好,我想问一下,Flink CDC中sql如何获取上一列的数据再做差值?我用的lag()函数但是会报错?是的,用cdc-mysql获取的数据源

问答 2023-04-23 来自:开发者社区

flink sql没有array_agg函数有办法解决吗?

flink sql没有array_agg函数有办法解决吗?

问答 2023-04-19 来自:开发者社区

有人知道flink sql支持JSON_VALUE函数吗?或者将字符串转成json的函数,官网内置函

有人知道flink sql支持JSON_VALUE函数吗?或者将字符串转成json的函数,官网内置函数好像没找到

问答 2023-04-19 来自:开发者社区

请问flink中我写的这样一个sql split函数,返回array类型,这是有什么错么?

请问我写的这样一个sql split函数,返回array类型,这是有什么错么?

问答 2023-03-27 来自:开发者社区

有没有哪位在flink sql中使用 过string转json_array的函数?

有没有哪位在flink sql中使用 过string转json_array的函数?我现在的场景是从kafka中接入数据写入数据库中,kafka中的数据结构为:{"uuid":"xxxx","body_data":"[{"fild1":123,"fild2":234}]"},由于body_data是json字符串,shcema为ARRAY>>,现在需要将array拆开每个ROW为1行放入...

问答 2023-02-27 来自:开发者社区

大家 在写 flink sql 时候 lead 函数是怎么 替代的 ?

大家 在写 flink sql 时候 lead 函数是怎么 替代的 ,流中不是不可以使用lead 函数

问答 2023-01-08 来自:开发者社区

flink cdc DataStream 如何实现 sql 的 DATE_FORMAT 函数?

flink cdc DataStream 如何实现 sql 的 DATE_FORMAT 函数?

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

数据库

分享数据库前沿,解构实战干货,推动数据库技术变革

+关注