Правила Apache Flink для асинхронных потоков данных

Question

Я боролся с особенностями мерцания, чтобы иметь возможность решить ниже подробную проблему;

1. Существует более одного источника данных, поданного асинхронно.Средства;Один источник сообщений отправляет сообщения каждые X секунд, а другой источник сообщений отправляет сообщения каждые Y секунд.

2. Я хотел бы применить некоторые правила, основанные на последних значениях конкретных значений этих источников;например;

val (x)> 10 и val (y)> 20

Что я сделал до сих пор;Фильтрация этих двух разных источников и получение единственных значений, которые меня волнуют, и сохранение их в хэш-карте и подача другого потока с этой хэш-картой.

Это событие процесса запускает правило для каждого экземпляра хэш-карты и затем предпринимает соответствующие действия.

Answer 1

Если у вас есть два потока, вы можете соединить их и передать их в CoFlatMapFunction , которая затем может отслеживать последние значения из каждого потока и отправлять результаты на основе применения ваших правил кэти значения.