如何对flink事件应用条件?

3duebb1j  于 2021-06-21  发布在  Flink
关注(0)|答案(0)|浏览(235)

我已经实现了
flink kafka-自定义类数据总是空的。
我浏览了上面的链接,实现了相同的,但是如何在事件上应用条件。

Pattern<Person, ?> eventspattern = Pattern.<Person> begin("first")
                    .subtype(Person.class).where(new SimpleCondition<Person>() {

                        public boolean filter(Person value) {
                            if (value.getid() == 1) {
                                return true;
                            }
                            return false;
                        }
}).within(Time.seconds(10));

如何实现上述条件下的“find person id”等警报。
我试过上面的代码它不会打印任何东西。有人能帮忙吗

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题