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