Вопросы по теме 'flink-cep'
Шаблон тайм-аута Apache Flink CEP не определяется временным окном
Я использую PatternTimeoutFunction для отбрасывания последовательности событий, когда она выходит за пределы определенного временного окна.
Я устанавливаю водяной знак следующим образом
public Watermark checkAndGetNextWatermark(Event...
470 просмотров
schedule
11.06.2022
как сделать подтип () для кортежа в flink cep?
Pattern< Tuple3< String, String, String >, ? > pattern = Pattern.<Tuple3< String, String, String > > begin( "start" )
.next( "3" ).where( new FilterFunction< Tuple3< String, String, String >...
322 просмотров
schedule
03.05.2023
Когда flink может поддерживать сопоставление шаблонов с участием полей предыдущих событий?
Было бы здорово иметь возможность сопоставлять события на основе значений их полей, выходящих за рамки текущей возможности создания шаблонов из событий, соответствующих отдельным критериям. Например, как описано на странице...
340 просмотров
schedule
09.02.2023
Потоковая передача flink создать файл (csv или текст) во временном окне
Я новичок в флинке, у меня есть трансформация, предположим, что это
val supportTask= customSource
.map( line => line.split(","))
.map( line =>...
686 просмотров
schedule
30.12.2022
Обработка сложных событий с сохранением состояния с помощью apache flink
Я хочу определить, происходят ли два события в определенный период времени на основе двух событий с одинаковым идентификатором. Например, DoorEvent выглядит так:
<doorevent>
<door>
<id>1</id>...
364 просмотров
schedule
16.06.2023
Присоединение к более чем 2 потокам во Flink и применение CEP к более чем 2 потокам без присоединения к ним
Вопрос № 1 . Я работаю над ситуацией, когда нам нужно объединить данные от нескольких датчиков [например, 8 датчиков] и объединить их в древовидную форму. Например, объединение [s1, s2, s3 s4] для формирования потока A, а затем [s5, s6, s7 и s8] для...
1098 просмотров
schedule
13.03.2023
определение задержки обнаружения Flink CEP для каждого кортежа
У меня есть простой шаблон, как показано ниже
Pattern<Event,?> pattern = Pattern.<Event>begin("s1")
.where(new SimpleCondition<Event>() {
@Override
public...
153 просмотров
schedule
22.05.2023
Как сообщить о стоимости в реальном времени в Fink?
Я хочу три значения, это aggValueInLastHour aggValueInLastDay aggValueInLastThreeDay .
Я пробовал, как показано ниже.
Но я не хочу ждать, это означает, что я не предпочитаю использовать скользящее окно для агрегирования. (3-дневное...
112 просмотров
schedule
21.02.2022
Apache Flink 1.4.2 akka.actor.ActorNotFound
После обновления до Apache Flink 1.4.2 мы получаем следующие ошибки каждые несколько секунд в одном TaskManager из 3.
2018-06-27 17:33:46.632 [jobmanager-future-thread-2] DEBUG o.a.flink.runtime.rest.handler.legacy.metrics.MetricFetcher - Could...
423 просмотров
schedule
24.04.2024
Apache Flink: как использовать SourceFunction для выполнения задачи с заданным интервалом?
Мне нужно, чтобы моя работа flink извлекала записи из базы данных с заданным интервалом и архивировала их после обработки. Я реализовал SourceFunction для извлечения необходимых записей из базы данных и добавил SourceFunction в качестве источника...
472 просмотров
schedule
20.05.2023
Добавить точку сохранения в Datastream
У меня есть источник kafka, из которого мое приложение flink считывает данные и обрабатывает их, я хочу добавить механизм точки сохранения flink, чтобы возобновить процесс с последнего места, где он был оставлен. Вместо добавления точки сохранения в...
35 просмотров
schedule
24.07.2023
Итеративное условие Flink CEP для одного шаблона в Scala
Проблема, с которой я столкнулся, заключается в том, что я не могу вычислить сумму для одного шаблона CEP в scala. Я хочу определить, когда сумма превышает 6100 для определенного идентификатора клиента. Я предоставляю поток с ключом для CEP.pattern...
185 просмотров
schedule
08.05.2022
Как я могу обновить значение в MapState, не удаляя предыдущее значение?
На этот раз мой вопрос: работая с MapState, безопасно использовать mapstate.put(key, value) для изменения текущего значения ключа в mapState, или мне нужно сделать mapState.remove(key) , а после этого сделать mapstate.put(key, value) снова, или...
227 просмотров
schedule
12.05.2022
Функция процесса Flink не возвращает данные в Sideoutputstream
Я пытаюсь проверить JSONObject с набором правил, если json соответствует набору правил, он вернет соответствующее правило, а JSONObject, если нет, он вернет JSONObject в Sideoutput, все это обрабатывается в ProcessFuntion, я получаю основной вывод,...
266 просмотров
schedule
17.06.2023
Не найдено ExecutorFactory для выполнения приложения в Flink 1.11.1.
прежде всего я прочитал это to-execute">сообщить о той же проблеме и попытался следовать тому же решению, которое работает для него (создайте новый краткий запуск с помощью mvn и перенесите туда код) и не работает восемь раз, когда выходит за рамки...
1993 просмотров
schedule
28.06.2023
Количество контрольных точек увеличивается со временем во Flink
в совокупности с этим вопросом Я до сих пор не понимаю, почему контрольные точки моего Flink количество рабочих мест растет и растет с течением времени, и в настоящее время, в течение примерно 7 дней подряд, эти контрольные точки никогда не выходят...
515 просмотров
schedule
26.05.2022
Как использовать Apache Flink CEP SQL для получения событий из уже согласованного шаблона?
Мое требование - создать триггер на основе двух событий (EVT_A и EVT_B независимо от порядка). Вот ожидание
1. EVT_A arrived. --> No action
2. EVT_B arrived --> Should Trigger
3. EVT_B arrived --> should Trigger since A was received...
126 просмотров
schedule
05.04.2024
