В документации apache-apex указано, что порядок событий в процессорах сохраняется (в зависимости от того, как они испускаются), но означает ли это, что не существует концепции времени события, позволяющей обрабатывать события не по порядку?
Кроме того, можно ли изменить приоритет событий в зависимости от их содержимого, например. когда они содержат специальные фразы (например, AUTH в контексте безопасности). NiFi позволяет это, что полезно в ситуациях с ограниченной пропускной способностью.
Apache Apex изначально не поддерживает обработку времени события. Время события может обрабатываться на уровне оператора с группировкой по времени (что позволяет прибыть с опозданием или не по порядку).
Однако это пункт дорожной карты. Вы можете выразить свою поддержку этому сообществу, чтобы оно имело более высокий приоритет.
Встроенная поддержка работы с окнами во время событий https://issues.apache.org/jira/browse/APEXCORE-414
Общая дорожная карта http://apex.incubator.apache.org/roadmap.html
Для второго сценария вы можете создать отдельный путь в DAG на основе содержимого.
