как определить тренд е с помощью Flink CEP

Question

Я новичок в Flink CEP. Для одного из наших случаев использования нам необходимо реализовать потоковую аналитику для выходного сигнала датчика температуры. если температура продолжает расти в течение 30 минут, необходимо сгенерировать предупреждение для оператора. Я прошел через Pattern API, но не смог найти способ смоделировать это в Pattern? Пожалуйста, предложите возможный способ обнаружения этого паттерна, используя Pattern

Answer 1

У вас есть два возможных варианта, которые вы можете рассмотреть.

Первый - использовать итеративное условие в cep, которое будет проверять, выше ли температура текущего события, чем все ранее принятые события. Пример IterativeCondition в документации здесь . Ключ заключается в том, чтобы вызвать ctx.getEventsForPattern и затем сравнить текущее событие с ранее принятыми.

Второе решение зависит от точного варианта использования, но, возможно, Вы могли бы использовать скользящее windows собрать элементы за 30 минут windows с небольшим слайдом в зависимости от частоты сбора данных. Тогда будет очень легко отсортировать элементы по временным меткам и убедиться, что у вас есть растущий тренд в окне.