网站首页
编程语言
数据库
系统相关
其他分享
编程问答
TestHarness
2024-07-01
53、Flink 测试工具测试用户自定义函数详解
1.测试用户自定义函数a)单元测试无状态、无时间限制的UDF示例:无状态的MapFunction。publicclassIncrementMapFunctionimplementsMapFunction<Long,Long>{@OverridepublicLongmap(Longrecord)throwsException{returnrecord+1;}