Hi Vishwas,
Apache Flink provides some test harness to test your application code on
multiple levels of the testing pyramid.
You can use them to test your UDF. Please see more examples offered by the
official documentation[1].
Best,
Vino
[1]:
https://ci.apache.org/projects/flink/flink-docs-stab
Hi guys,
I want to test a function like :
private[flink] def filterStream(dataStream:
DataStream[GenericRecord]): DataStream[GenericRecord] = {
dataStream.filter(new FilterFunction[GenericRecord] {
override def filter(value: GenericRecord): Boolean = {
if (value == null || value.get(St
