Как выполнить модульное тестирование функции Flink ProcessFunction?

Для модульного тестирования этого метода определите ожидаемое поведение. В этом случае ожидаемым поведением является однократный вызов метода Collector::collect с content + "output" в качестве аргумента. Таким образом, это можно проверить с помощью имитационного сборщика.

Вот пример использования фреймворка Mockito:

...

private final Collector<String> collectorMock = Mockito.mock(Collector.class);
private final Context contextMock = Mockito.mock(Context.class);

private final SampleProcessFunction sampleProcessFunction = new SampleProcessFunction();

@Test
public void testProcessElement_shouldInvokeCollector_whenAnyValuePassed() throws Exception {
    // given
    final String content = "hello ";

    // when
    sampleProcessFunction.processElement(content, contextMock, collectorMock);

    // then
    Mockito.verify(collectorMock).collect(content + "output"); // verifies that collector method was invoked with "hello output" exactly once
}

...

если вы хотите на объекте, вы можете использовать:

    Mockito.atLeastOnce();
    Mockito.doReturn(myCustomObject);