AI 助理
备案控制台
开发者社区 大数据与机器学习 实时计算 Flink 正文

想请问一下咱们flink udf怎么上传和注册的？

请教一下咱们flink udf怎么上传和注册的，我把自定义jar包放到lib下，然后创建:CREATE TEMPORARY SYSTEM FUNCTION arraysort AS 'com.streaming.flink.udsf.ArraySortFunction';在使用这个函数的时候，不知道为什么没有数据返回，select name,arraysort(dfsds,'desc') ddd from (values ('222',ARRAY['wefrwe','wef','wef']),('222',ARRAY['wef','wef21','wef22'])) as nametable(name,dfsds) 也不报错fe1275dc28d7d8f853244d3c4ba41d0f.png

展开
收起
圆葱猪肉包 2023-03-08 11:30:36 503 分享 版权

版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

1 条回答
写回答
取消 提交回答
  • co63oc_
    GitHub https://github.com/co63oc/cloud

    上传注册udf https://help.aliyun.com/document_detail/176059.html image.png

    2023-03-10 12:13:02
    赞同 展开评论
问答分类：
Java 流计算 实时计算 Flink版
问答标签：
实时计算 Flink版注册 实时计算 Flink版udf 实时计算 Flink版udf注册
问答地址：
开发者社区 > 大数据与机器学习 > 实时计算 Flink > 问答
相关问答
实时计算 Flink版
Flink更新UDF时会不会影响已使用该UDF的上线作业
74
1
0
Flink udf使用有什么限制
62
1
0
函数计算udf的java代码中可以引用flink内置函数吗
90
1
0
Flink单个项目下为什么最多允许上传200个UDF或JAR
87
0
0
对于Flink CDC，动态表可以注册source吗？我理解动态表不是flink的吗？
76
0
0
Flink JIRA 这个怎么样才能注册成功？
96
1
0
Flink UDF上传jar过大会导致不能正常使用吗
74
1
0
Flink UDF和UDAF以及UDTF的区别
138
1
0
实时计算Flink版Blink跨账号读取datahub无法注册存储
93
1
0
Flink catalog可以注册adb但不能获取到表结构
53
1
0
大数据与机器学习

实时计算 Flink

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务，基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎，提高作业开发运维效率。

我要提问
收录在圈子:
阿里云实时计算Flink
199212
+ 订阅
实时计算 Flink 版（Alibaba Cloud Realtime Compute for Apache Flink，Powered by Ververica）是阿里云基于 Apache Flink 构建的企业级、高性能实时大数据处理系统，由 Apache Flink 创始团队官方出品，拥有全球统一商业化品牌，完全兼容开源 Flink API，提供丰富的企业级增值功能。

相关文章

  • 50道java基础面试题
  • 【Spring】原理：Bean的作用域与生命周期
  • 50道java集合面试题
  • flyway报错Caused by: java.lang.NoSuchMethodError: org.flywaydb.core.api.configuration.FluentConfigurat
  • 鸿蒙应用开发从入门到实战（一）：鸿蒙应用开发概述

    • 热门讨论

    热门文章

  • Flink CDC任务从savepoint/checkpoints状态中恢复作业错误问题
  • 请问如何用flink sql客户端用yarn application模式提交任务呢？
  • flink的1cu是指1cpu还是1cpu+4g存储？
  • 请问下大家有没有遇到过这个错:Caused by: java.lang.ClassNotFoundE
  • Flink-CDC 文档网站地址是什么？
  • 在斗鱼，实时计算发展的历程如何？
  • FlinkCDC MySQL 中 scan.startup.mode 用的是什么模式啊？
  • 我们在使用阿里云flinksql 往clickhouse写数据的时候发现会丢数据或重复数据，怎么办？
  • 在Flink CDC中ogg可以做实时同步吗？
  • flink cdc paimon设置了file.format为parquet但生成的文件依然是orc
    • 展开全部
  • 流计算精品翻译: The Dataflow Model
  • Flink SQL 功能解密系列 —— 流式 TopN 挑战与实现
  • Flink Checkpoint 问题排查实用指南
  • Flink SQL 功能解密系列 —— 流计算“撤回(Retraction)”案例分析
  • Apache Flink 漫谈系列(04) - State
  • Flink SQL 功能解密系列 —— 数据去重的技巧和思考
  • Apache Flink 漫谈系列(15) - DataStream Connectors之Kafka
  • 基于实时计算（Flink）与高斯模型构建实时异常检测系统
  • Apache Flink 零基础入门（三）：DataStream API 编程
  • 计算广告与流处理技术综述
    • 展开全部
    还有其他疑问?
    咨询AI助理