java - ProcessWindowFunction 上的 Flink 单元测试

Question

如何为有状态流程功能创建单元测试。我有这样的事情:

 private static SingleOutputStreamOperator<Tuple> methodName(KeyedStream<Event, String> stream) {
        return stream.window(TumblingEventTimeWindows.of(Time.minutes(10)))
                .process(new ProcessFunction());
    }

和

ProcessFunction extends ProcessWindowFunction<IN, OUT, KEY, W>

我在 Flink 页面中发现的所有 Harness 测试都是从 KeyedProcessFunction 扩展而来的，这不是我的情况。
谢谢。
亲切的问候!

Answer 1

通常，这些测试工具期望测试运算符(operator)，而不是用户功能。所以在 ProcessWindowFunction 的情况下，您需要首先创建一个合适的窗口操作符来传递给测试工具。
您可以测试一个 ProcessWindowFunction使用 OneInputStreamOperatorTestHarness你用 WindowOperator 实例化缠在你的 ProcessWindowFunction .恐怕这不是特别简单，但我可以为您提供https://github.com/apache/flink/blob/release-1.11/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperatorTest.java#L437举个例子。
Ververica 的 Apache Flink 培训类(class)中涵盖了测试 ( https://training.ververica.com/decks/testing )，其中包含有关如何使用这些测试工具的更多信息。