flink SQL函数的相关内容

Flink SQL 是否存在类似MySQL的group_concat函数

不知Flink SQL中是否存在类似MySQL的group_concat函数的功能: 例如：数据： +------+-------+ | Id | Name | +------+-------+ | 10 | Larry | | 11 | Mike | | 12 | John | | 10 | E...

flink sql 中是否可以使用 mysql 的存储过程和函数？

需求是这样，mysql中使用 binary(16) 存储 uuid，读取到 flink中需要转换成文本串的uuid，sql是这样 select bin_to_uuid(id, true) as text_uuid from usertable 我尝试使用，报错说 bin_to_uuid 找不到*来自...

如何在 PolarDB-X 中优化慢 SQL

2 课时 |

113 人已学 |

加入学习

SQL完全自学手册

61 课时 |

3601 人已学 |

加入学习

SQL Server on Linux入门教程

14 课时 |

4329 人已学 |

加入学习

flink sql 函数FIRST_VALUE调用报错

HOP window 上使用的 UDAF 需要实现 merge 方法，因为 HOP window 在触发计算时会将多个 pane 进行合并，故也需要调用 UDAF 的 merge 方法将多个 accumulator 合并成一个。而 first_value 和 last_value 不支持 merge...

Flink SQL是否支持Count Window函数？

今天遇到一个业务场景用到count window，查了下Flink官网目前Flink SQL只支持time window，问一下官方是否打算sql支持count window呢？如果没有计划的话，自己要如何实现？是否可以像flink 1.13引入的cumulate window写一个自定义窗口函数...

flink-table_2.11_1.72.jar，没有官网中提供的sql函数,怎么处理?

项目中引用flink-table_2.11_1.72.jar，没有官网中提供的sql函数,怎么处理?https://help.aliyun.com/knowledge_list/62717.html?spm=a2c4g.11186623.6.759.2a10488bRkMqGV

Flink sql 支持在流式数据上使用LAG和LEAD函数吗

如何在流式数据源上使用分析函数LAG和EAD函数： kafka输入数据如： {"t":"2020-04-01T05:00:00Z", "id":"1", "speed":1.0} {"t":"2020-04-01T05:05:00Z", "id":"1", "speed":2.0} {"t":"20...