2014-10-18 1 views
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에 대한 이벤트가 있었다면,이 진술에 대해 평가됩니까?

답변

1

Esper는 예제 "symbol = AAPL"에서 필터 식을 확인합니다. 이것들은 일련의 역 색인으로 입력됩니다. Esper가 @audit을 사용하여 성명을 평가하는지 확인할 수 있습니다.

관련 문제