Re: 如何写 flink udf 的 ut?

Mon, 20 Jun 2022 05:41:38 -0700 

可以参考 HiveUDFTest 里面构造CallContext 的方式[1]

[1] 
https://github.com/apache/flink/blob/master/flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/table/functions/hive/HiveSimpleUDFTest.java#L222

Best regards,
Yuxia

----- 原始邮件 -----
发件人: "forideal" <fszw...@163.com>
收件人: "user-zh" <user-zh@flink.apache.org>
发送时间: 星期一, 2022年 6 月 20日 下午 8:16:52
主题: 如何写 flink udf 的 ut?

你好我的朋友:


       太久没有写 flink 的代码了.今天写了一个 flink 的 udf.可能需要调用一下 open 函数.但是我不知道如何构造那个 
context.有同学能帮忙吗?
       非常感谢!


Best wishes!!!

回复