Flink Filter 功能测试

Question

我正在尝试找到像 RichMappFunction 一样测试 RichFilter 函数的方法，就像这里展示的那样：RichMapFunction Testing is present here......通过互联网搜索但什么也没找到...请帮助...

public class Person{
     public String name;
     public Int age;
}

public class OCRKafkaFilter extends RichFilterFunction<Person> {
   
    @Override
    public boolean filter(Person person) {
        return person.age>21;
    }
}

我们如何为有状态运算符的这种丰富的过滤功能编写测试用例......

Answer 1

我希望这个doc 能帮到你。这是example。