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