cep库中的java连续性与状态存储

tquggr8v  于 2021-07-09  发布在  Java
关注(0)|答案(0)|浏览(238)

我们正在评估一个用例,在这个用例中,每秒将有100个事件流进入,我们希望对它们运行一些固定的模式匹配规则集,我使用文档中描述的宽松的连续性规则。例如:“a”、“b1”、“d1”、“b2”、“d2”、“b3”、“c”流上的模式序列“ab+c”的结果将是--{a b1 c}、{a b1 b2 c}、{a b1 b2 b3 c}、{a b2 c}、{a b2 b3 c}、{a b3 c},我为此模式使用within()子句将时间窗口指定为60分钟。
这是否意味着不匹配的事件(即“d1”、“d2”)根本不会以状态存储?cep是否只存储状态中匹配的事件60分钟?
这个问题对于估计用例所需的状态后端大小以及确保应用程序不会因为不断增加的状态而耗尽内存非常重要。

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题