求大家帮忙看看我写的这个split函数在sql中有问题么?函数输入一个由分号分割的字符串“1;3;8”,输出一个数组<1,3,8> 报错:Caused by: org.apache.flink.sql.parser.impl.ParseException: Encountered "in mysplit" at line 3, column 53. Was expecting one of: "EXCEPT" ... "FETCH" ... "GROUP" ...
-- 定义一个UDF函数,用于将字符串分割成数组
CREATE TEMPORARY FUNCTION split(str STRING, delim STRING) RETURNS ARRAY
LANGUAGE JAVA
AS '
import java.util.Arrays;
public class SplitUDF {
public static String[] split(String str, String delim) {
return str.split(delim);
}
}
';
-- 使用split函数将字符串分割成数组
SELECT split('hello,world,flink', ',') AS words;
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。