Как проверить функцию обработки обработки? ⇐ JAVA

[Anonymous]

У меня есть простая процессная функция, которая принимает строку в качестве входной информации и дает строку в качестве вывода. Как мне проверить это с помощью JUNIT? Поскольку метод ProcessElement является методом void и не возвращает значения. < /p>

public class SampleProcessFunction extends ProcessFunction{
@Override
public void processElement(String content, Context context, Collector collector) throws Exception {
String output = content + "output";
collector.collect(output);
}
}


Подробнее здесь: https://stackoverflow.com/questions/511 ... ssfunction