Flink CEP：FollowedBy模式：同一事件多次循环该模式

Question

我是Flink CEP的新手，一直在玩弄这些模式，以便更好地理解它们。我有一个简单的“开始”的例子

Pattern match\u win=模式。开始（“第一”）。其中（new SimpleCondition（）{

    public boolean filter(HitDTO hitDTO) throws Exception {
        boolean result = false;
        if (hitDTO.getHitScore() == 4)
        {
            System.out.println("First:" + hitDTO + ": " + hitDTO.getHitScore());
            result = true;
        }
        return result;
    }
}).followedBy("next").where(new SimpleCondition<HitDTO>(){

    public boolean filter(HitDTO hitDTO) throws Exception
    {
        boolean result = false;

        if (hitDTO.getHitScore() == 6)
        {
            System.out.println("Next:" + hitDTO+ ": " + hitDTO.getHitScore());
            result = true;
        }
        return result;
    }
});

我正在通过4,4,6

并行度设置为1。

StreamExecutionEnvironment env=StreamExecutionEnvironment。getExecutionEnvironment（）。setParallelism（1）；

然而，这是我在模式内打印输出的日志中看到的，其中6在仅传入一次时循环了4次。

第一：com.rs.dto.HitDTO@17619295：4

第一：com。卢比dto。HitDTO@c108f70：4

下一步：com。卢比dto。HitDTO@5d13aab8：6

下一步：com。卢比dto。HitDTO@5d13aab8：6

下一步：com。卢比dto。HitDTO@5d13aab8：6

下一步：com。卢比dto。HitDTO@5d13aab8：6

只是想知道为什么同一个事件循环多次，但结果是正确的。

谢谢你的回答。

Answer 1

尝试将模式与输入序列匹配的过程将涉及对模式的各个组件的多次评估，这是正常的。模式匹配就是这样工作的：模式被编译成一个有限状态机，并且考虑输入可能通过该FSM的所有可能路径，寻找通向终端的路径，匹配状态。如果您在定义模式时不小心，这可能会导致组合爆炸式的努力。