1
일치하는 속성 (사용자)을 기반으로하는 시간 창에서 여러 이벤트를 일괄 처리하려고합니다. 예를 들어 다음 이벤트가 1 초 만에 에스퍼를 통과한다고 가정 해 보겠습니다.공유 속성을 기반으로 Esper에서 이벤트를 일괄 처리하는 방법
사용자 | 파일
A | a1.sys
A | a2.inf
A | a3.sys
B | b1.sys
B | b2.sys
A | a4.sys
B | |출력 1
:b3.inf 나는 배치로 사용자와 출력하여 이벤트 다음과 같은 이벤트 2 개 그룹을 원한다 a1.sys
A | a2.inf
A | a3.sys
A | a4.sys
출력 2
B | b1.sys
B | b2.sys
B | b3.inf
중요한 점은 이러한 그룹은 이벤트별로 하나의 출력이 아니라 모음으로 출력되어야한다는 것입니다. 이러한 쿼리를 형성하는 방법
SELECT * FROM pattern[every a -> b -> c]
난 그냥 문이 안 열려 알아낼 : 나는 (이벤트가, B와 C는 컬렉션으로 반환됩니다) 아래 쿼리에서 얻을 것이라고 응답의 형식을 모방 할 필요가있다. 나는 다음을 시도했지만 함께 일괄 처리를하지 않는다.
select * from ActivityEvent().std:groupwin(User).win:time_batch(5)