복잡한 이벤트 처리 - 스트림 처리

Question

저는 Esper가 Storm과 협력하는 방법을 배우려고합니다. Esper (테이블, 배열 등)가 데이터를 저장하는 위치를 찾고 싶기 때문에 Esper의 소스 코드를 살펴보고 있습니다. 예를 들어 esper가 튜플 스트림을 받고 이벤트 유형이 선언되면 Esper (소스 코드)가이 데이터를 저장하는 방법 쿼리가 실행될 때 데이터 결과가 어떻게 저장 되는가?이 모든 것이 Esper의 소스에서 발생하는 곳을 찾고 싶습니다. 어떤 도움이라도 대환영입니다.

Answer 1

Esper의 데이터 구조는 EPL 문을 반영합니다.

이 저장 아무것도 :이 카운트 당을 저장

select avg(field) from MyEvent 

:이 수와 총을 저장

select count(*) from MyEvent 

이는 긴 형태의 수를 저장

select * from MyEvent 

그룹 필드 :

select count(*) from MyEvent group by groupfield 

이는 지난 5 개 이벤트를 저장합니다

select * from MyEvent.win:length(5) 

패턴이 자신의 데이터 구조를 가지고, 각각의 데이터 창 등을 일치-인식합니다 .. 인덱스 조인 등은 또한 데이터 구조이기 때문. 단일 코드 위치가 없지만 많은 데이터 구조가 있지만 여러 가지 특수한 구조가없는 것 같습니다.