Apache Apex 中的乱序处理

Out of order processing in Apache Apex

apache-apex documentation 指出处理器中事件的顺序被保留(基于它们的发出方式),但这是否意味着没有允许乱序处理的事件时间概念事件?

此外,是否可以根据事件的内容重新确定事件的优先级,例如当它们包含特殊短语时(例如安全上下文中的 AUTH)。 NiFi 允许这样做,这在带宽有限的情况下很有用。

Apache Apex 本身不支持事件时间处理。可以使用时间分桶在操作员级别处理事件时间(允许延迟/乱序到达)。

但是,它是一个路线图项目。您可以在社区中表达您对它的支持,以便它获得更高的优先级。

对事件时间窗口的原生支持 https://issues.apache.org/jira/browse/APEXCORE-414

总体路线图 http://apex.incubator.apache.org/roadmap.html

对于第二种情况,您可以根据内容在DAG中创建单独的路径。