Programmiererforum

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

Ich habe eine einfache Prozessfunktion, die die Zeichenfolge als Eingabe aufnimmt und eine Zeichenfolge als Ausgabe angibt. Wie testet ich dies mit jungit? Da die Prozesselementmethode eine Hohlraummethode ist und keinen Wert zurückgibt. < /p>

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