开发者社区> 问答> 正文

pyflink-udaf

您好:我们项目组计划使用pyflink的udaf对数据进行聚合处理,拜读社区文章得知,对于批处理方式或窗口式聚合,建议使用Vectorized Aggregate Functions。但此case提供的代码不完全,不是完整的case, 自己编写测试程序报错:"org.apache.flink.table.api.ValidationException: Undefined function: weighted_avg" 请问能否提供一个完整的pyflink的udaf对数据进行聚合处理示例,多谢!!!*来自志愿者整理的flink邮件归档

展开
收起
毛毛虫雨 2021-12-08 11:21:59 679 0
1 条回答
写回答
取消 提交回答
  • 你好,事例已经提供了UDF的注册和使用,只剩下数据源的读取和输出没有提供(这有单独的部分来讲)。 关于你的报错,因为你没有提供具体咋使用的,只能猜测你没有按照示例使用DSL的方式,而是使用的字符串的方式,但却没有register函数导致报了这个错*来自志愿者整理的flink邮件归档

    2021-12-08 16:21:51
    赞同 展开评论 打赏
问答地址:
问答排行榜
最热
最新

相关电子书

更多
Python on Flink & Flink on Zeppelin 立即下载
LEARNINGS USING SPARK STREAMING & DATAFRAMES FOR WALMART SEARCH 立即下载
Flink Streaming SQL 2018 立即下载