Как применить условия к событиям Flink? - PullRequest
0 голосов
/ 25 февраля 2019

Я реализовал это

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));

Как мне реализовать предупреждения типа «найти человека» для вышеуказанного условия.

Я пробовал с приведенным выше кодом, он ничего не печатает.Может кто-нибудь, пожалуйста, помогите по этому запросу

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...