java - Esper 如何将事件与适当的查询相匹配

Question

我正在使用 ESPER 进行流事件处理。我正在创建语句，然后将它们添加到 CEP 引擎，如下所示。这是处理大量(每分钟数百万个事件)数据的正确方法吗？

    Configuration cepConfig = new Configuration();
    cepConfig.addEventType("StockTick", Tick.class.getName());
    EPServiceProvider cep = EPServiceProviderManager.getProvider("myCEPEngine", cepConfig);
    EPRuntime cepRT = cep.getEPRuntime();

    EPAdministrator cepAdm = cep.getEPAdministrator();
    EPStatement cepStatement = cepAdm.createEPL("select * from " +
            "StockTick(symbol='AAPL').win:length(2) " +
            "having avg(price) > 6.0");
    EPStatement cepStatement2 = cepAdm.createEPL("select * from " +
            "StockTick(symbol='AAPL').win:length(2) " +
            "having avg(price) > 7.0");
    CEPListener c = new CEPListener();
    cepStatement.addListener(c);
    cepStatement2.addListener(c);

我使用以下方法添加事件:

cepRT.sendEvent()

ESPER 如何将事件映射到必须对其进行评估的查询？如果我有一个关于 IBM 股票类型的事件，它会根据这些报表进行评估吗？

Answer 1

Esper 查看过滤器表达式，在您的示例中为“symbol=AAPL”。这些被输入到一系列反向索引中。您可以查看 Esper 是否使用 @audit 评估语句。