如何弗林克CEP使用“每”模式操作

在艾斯波CEP引擎事件模式，有Every运营商这表明当由每个关键字合格的子表达式的计算结果为真或假的图案子表达式应该重新启动。如何弗林克CEP使用“每”模式操作

According to this document，我们可以像不同的方式使用every操作：

A -> B 
    every (A -> B) 
    every A -> B 
    A -> every B 
    every A -> every B

我想知道这些模式在弗林克CEP的可能呢？我想在Flink中使用every A -> B，但不知道如何。

和上面的图案弗林克此默认CEP图案表示的是哪一个？（使用Flink v1.1.4）

Pattern<Event, ?> pattern = Pattern.begin("start").where(evt -> evt.getId() == 42) 
    .followedBy("end").where(evt -> evt.getName().equals("end"));

在此先感谢。

来源

2017-01-09 Sina Nourian

弗林克提供了一些documentation至于如何利用一切它说，如果你指定子类型，然后它会被称为每次迭代

start.subtype(SubEvent.class).where(new SimpleCondition<SubEvent>() { 
    @Override 
    public boolean filter(SubEvent value) { 
     return ... // some condition 
    } 
});

但在我看来，这不是你在找什么。但是，您可以通过使用您将能够使用神功查询语言弗林克

看看重量轻 Siddhi- Flink CEP library

来源

2017-10-29 12:04:22

如何弗林克CEP使用“每”模式操作

回答

相关问题