集成 test表API?


0

我已经建立了一个非常小和直接的Flink应用程序,它使用Kafka(json)中的事件,将它们反序列化为Java对象,然后创建两个表并使用表API进行一些简单的操作,最后将两个表 join起来,并将结果写回Kafka

test这些代码的最佳实践是什么?如何编写集成 test来验证用表API编写的代码是否产生正确的结果?

(使用Flink 1.8.3)

1 答案


0

我们在KafkaTableITCase中从1.10开始增加了kafkasql join器的集成 test。它创建一个kafka表,并将一些数据写入其中(使用json格式),然后再次读取并应用窗口聚合,最后使用TestingSinkFunction检查窗口结果。您可以在此处查看代码:

https://github.com/apache/flink/blob/release-1.10/flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTableTestBase.java


我来回答

写文章

提问题

面试题