У меня есть простая процессная функция, которая принимает строку в качестве входной информации и дает строку в качестве вывода. Как мне проверить это с помощью 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
