我已经实现了
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”等警报。
我试过上面的代码它不会打印任何东西。有人能帮忙吗
暂无答案!
目前还没有任何答案,快来回答吧!