apacheapex中的无序处理

yyhrrdl8  于 2021-05-29  发布在  Hadoop
关注(0)|答案(1)|浏览(414)

apacheapex文档声明处理器中事件的顺序是保留的(基于它们是如何发出的),但这是否意味着没有允许无序处理事件的事件时间概念?
此外,可以根据事件的内容重新确定事件的优先级,例如,当事件包含特殊短语时(例如,安全上下文中的auth)。nifi允许这样做,这在带宽有限的情况下非常有用。

a5g8bdjr

a5g8bdjr1#

apacheapex本机不支持事件时间处理。事件时间可以在操作员级别处理,并带有时间计费(允许延迟/无序到达)。
然而,这是一个路线图项目。你可以向社区表达你对它的支持,这样它就会得到更高的重视。
对事件时间窗口的本机支持https://issues.apache.org/jira/browse/apexcore-414
总体路线图http://apex.incubator.apache.org/roadmap.html
对于第二个场景,可以基于内容在dag中创建单独的路径。

相关问题