SQL
-
Flink SQL中有没有行转列的函数东凌?-云小二-阿里云
Flink SQL中有没有行转列的函数东凌 以下为热心网友提供的参考意见 在Flink SQL中，你可以使用内置的聚合函数GROUP_CONCAT来实现行转列的功能。这个函数会将输入数据按照指定的列进行分组，并将每个分组中的其他列的值拼接成一个字符串。例如，假设你有一个包含姓名和科目的表，并希望按姓名分组，同时将每个分组中的科目用逗号连接起来，可以使用如下查…
-
Flink SQL中有没有行转列的函数？-云小二-阿里云
Flink SQL中有没有行转列的函数？ 以下为热心网友提供的参考意见 在Flink SQL中，你可以使用内置的聚合函数GROUP_CONCAT来实现行转列的功能。这个函数会将输入数据按照指定的列进行分组，并将每个分组中的其他列的值拼接成一个字符串。例如，假设你有一个包含姓名和科目的表，并希望按姓名分组，同时将每个分组中的科目用逗号连接起来，可以使用如下查询…
-
请问平台上flink sql UDF这个feature为什么一定要弄成打成jar上传这种方式呢?-云小二-阿里云
请问平台上flink sql UDF这个feature为什么一定要弄成打成jar上传这种方式呢，这样用户体验不会很差么，用户不能直接在playground上写个类写个函数以字符串的方式传给后端嘛？ 以下为热心网友提供的参考意见 Flink SQL的UDF（用户自定义函数）需要以JAR包的形式上传，主要有以下几个原因： 安全性：将代码打包成JAR文件可以增加代…
-
请问一下，flink sql udf 通过字符串这样传进来，大家有没有一个好的实现办法呀？-云小二-阿里云
请问一下，flink sql udf 通过字符串这样传进来，然后用groovy编译成Class，然后通过tableEnv去注册，这样会报错。大家有没有一个好的实现办法呀？外面传个字符串就能注入进tableEnv的udf的 以下为热心网友提供的参考意见 你可以尝试使用Flink的UDFRegistration接口来注册自定义的UDF。首先，你需要创建一个实现U…
- 信息流广告，信息流部分建议宽度830px，只针对默认列表样式，顺序随机
-
Flink sql中的GROUP_CONCAT 函数 得怎么实现？-云小二-阿里云
Flink sql中的GROUP_CONCAT 函数 得怎么实现？ 以下为热心网友提供的参考意见 LISTAGG ，此回答整理自钉群“实时计算Flink产品交流群” 以下为热心网友提供的参考意见 在 Flink SQL 中，可以使用 GROUP_CONCAT 函数将同一组内的多个值连接成一个字符串。要实现这个功能，你需要使用 STRING_AGG 函数，它是…
-
一个Flink SQL Job 能同时订阅多个MySql表的Binlog吗？-云小二-阿里云
一个Flink SQL Job 能同时订阅多个MySql表的Binlog吗？ 以下为热心网友提供的参考意见 可以的，但是会起多个binlog dump链接，因为mysql不支持按表订阅，都是全量订阅后过滤 ，此回答整理自钉群“实时计算Flink产品交流群” 以下为热心网友提供的参考意见 是的，一个Flink SQL Job 可以同时订阅多个MySql表的Bi…
-
大佬们，我刚接触flink，请教个问题，flinksql不支持这样写吗，数据库函数？ -云小二-阿里云
大佬们，我刚接触flink，请教个问题，flinksql不支持这样写吗，数据库函数？ 在数据库是可以执行的，但是在flink校验sql的 时候报错了？ 以下为热心网友提供的参考意见 您好！Flink SQL 支持大部分标准 SQL 功能，并且可以与许多开源数据库系统（如 MySQL 和 PostgreSQL）进行交互。然而，在某些情况下，可能会遇到无法直接翻…
-
请教一下怎么用flinksql 写一个连接带有kerberos 认证的 hive 的catalog？-云小二-阿里云
请教一下怎么用flinksql 写一个连接带有kerberos 认证的 hive 的catalog？ 以下为热心网友提供的参考意见 flink必须写到配置文件里，kerberos配置只能从配置文件读 ，此回答整理自钉群“【③群】Apache Flink China社区” 以下为热心网友提供的参考意见 要使用Flink SQL连接带有Kerberos认证的Hi…
-
有没部署过flink sql gateway的呀？一直报错？-云小二-阿里云
有没部署过flink sql gateway的呀？一直报错 org.apache.thrift.protocol.TProtocolException: Missing version in readMessageBegin, old client? 以下为热心网友提供的参考意见 jdbc:hive2://sql-gateway-ip:10000/defau…
-
如果使用flink sql的left join，右表出现部分关联不上的情况，应该怎么处理好？-云小二-阿里云
请问下，如果使用flink sql的left join，右表出现部分关联不上的情况，应该怎么处理好一点哈？ 以下为热心网友提供的参考意见 在使用Flink SQL的LEFT JOIN时，如果右表出现部分关联不上的情况，可以考虑以下几种处理方式： 使用FULL OUTER JOIN代替LEFT JOIN：FULL OUTER JOIN会返回左表和右表中所有的记…
