Wie testen Sie eine Flink -Prozessfunktion? ⇐ Java

[Anonymous]

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: Select all

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