В настоящее время я изучаю поведение на основе событий для Apache Spark или Flink соответственно. Для Flink я нашел CEP, который я считаю адекватным для моего варианта использования:
Я (или, скорее, приложение, которое я намереваюсь запустить на кластере Spark) взаимодействует (и) с API для отдельной FS, которая выводит данные. Эти данные содержат сенсорную информацию, которая должна использоваться либо для пометки событий в журнале, либо для запуска дальнейшей аналитики, помимо исходной.
Теперь мне интересно, есть ли что-то вроде CEP для Spark? Я изучил JavaDoc / PyDo c в Spark, но эти триггеры (которые я понимаю как центральную часть поведения, основанного на событиях) касаются только операций над окнами или панелями соответственно.
Если я пропустил какие-либо очевидные указатели пожалуйста, скажите мне об этом, потому что пока обычный поиск inte rnet еще не принес плодов.
Большое спасибо.