udf测试 flinkc程序测试 参考flink1.20文档 文档很多地方跑不通甚至没有import对应的包,这里全都标注了. 且代码做了修改来确保了成功执行.
Test Dependencies | Apache Flink
Testing | Apache Flink
maven
官网写的 flink-test-util flink-table-test-util 外加 scalatest和scalamock
<dependency>
<groupId>org.scalatest</groupId>
<artifactId>scalatest_${scala.version}</artifactId>
<version>${scala.te