Apach Flink CEP“至少”条件

Question

我正在尝试创建一个与“至少”事件匹配的CEP模式。修改示例代码：

middle.oneOrMore().where(new IterativeCondition<SubEvent>() {
    @Override
    public boolean filter(SubEvent value, Context<SubEvent> ctx) throws Exception {
        if (!value.getName().startsWith("foo")) {
            return false;
        }

        double sum = value.getPrice();
        for (Event event : ctx.getEventsForPattern("middle")) {
            sum += event.getPrice();
        }
        return Double.compare(sum, 5.0) < 0;
    }
});

成

middle.oneOrMore().where(new IterativeCondition<SubEvent>() {
    @Override
    public boolean filter(SubEvent value, Context<SubEvent> ctx) throws Exception {
        if (!value.getName().startsWith("foo")) {
            return false;
        }

        long count = 0;
        for (Event event : ctx.getEventsForPattern("start")) {
            count = count + 1; 
        }
        return count >= MIN_COUNT;
    }
});

不解决我的问题，因为条件将不断失败，永远无法贡献计数。

我在中找到https://ci.apache.org/projects/flink/flink-docs-release-1.3/dev/libs/cep.html确实有

// expecting 4 occurrences
 start.times(4);

 // expecting 0 or 4 occurrences
 start.times(4).optional();

 // expecting 1 or more occurrences
 start.oneOrMore();

 // expecting 0 or more occurrences
 start.oneOrMore().optional();

有start.at存在吗？

Answer 1

您可以使用。时间（5）后跟相同的模式，但带有量词。一个或多个（）。可选（）。时间只需要5次，而零或更多时间将为您提供“至少…”。

Answer 2

检查此链接以查找解决方案。它会检查模式是否发生5次。您可以按次修改（number_of_times）

[https://stackoverflow.com/questions/45033109/flink-complex-event-processing/45048866]