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