0
스트리밍 이벤트 처리에 ESPER를 사용하고 있습니다. 다음과 같이 명세서를 작성한 다음 CEP 엔진에 추가합니다. 대량의 데이터 (분당 백만 건의 이벤트)를 처리하는 데 적합한 방법입니까?Esper는 적절한 쿼리와 이벤트를 어떻게 일치합니까?
cepRT.sendEvent()
어떻게 에스퍼 그것을 평가해야 쿼리에 이벤트를지도 않습니다
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);
나는 사용하여 이벤트를 추가? 주식형 IBM에 대한 이벤트가 있었다면,이 진술에 대해 평가됩니까?