apache apex文档指出,处理器中事件的顺序是保留的(基于它们的发出方式),但这是否意味着没有允许无序处理事件的事件时间概念?
此外,事件是否可以根据其内容重新划分优先级,例如当它们包含特殊短语时(例如,安全上下文中的AUTH)。NiFi允许这样做,这在带宽有限的情况下很有用。
Apache Apex本机不支持事件时间处理。事件时间可以在操作员级别上通过时间分段(允许延迟/无序到达)进行处理。
然而,这是一个路线图项目。你可以向社区表达你对它的支持,这样它就会得到更高的优先级。
对事件时间窗口的本机支持https://issues.apache.org/jira/browse/APEXCORE-414
总体路线图http://apex.incubator.apache.org/roadmap.html
对于第二种情况,可以根据内容在DAG中创建一个单独的路径。