Я реализовал это
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));
Как мне реализовать предупреждения типа «найти человека» для вышеуказанного условия.
Я пробовал с приведенным выше кодом, он ничего не печатает.Может кто-нибудь, пожалуйста, помогите по этому запросу