2017-12-12 28 views
0

CallPOPDWH 이벤트가 있다고 가정합니다. 이벤트에는 4 개의 열이 있습니다. 유형 컬럼, 이름 컬럼, 검출 시간 소인 컬럼 및 속성 컬럼. 에스퍼는 다음과 같은 3 개 튜플을 생성합니다Esper - 쿼리 결과의 배열 표현

[Event, CallPOPDWH, 1456938481000, {call_start_date=7355448481000, calling_number=+3859121JMOYL, call_direction=I}] 
[Event, CallPOPDWH, 1456938481000, {call_start_date=5464538486000, calling_number=+3859121JMOYL, call_direction=I}] 
[Event, CallPOPDWH, 1456938481000, {call_start_date=1456345351000, calling_number=+3859121JMOYL, call_direction=I}] 

내가 전화 번호 및 탐지 타임 스탬프가 동일있는 모든 다른 call_start_date 값을 수집하는 쿼리를 실행합니다. 예를 들어

:

[Event, NewEvent, 1456938481000, {call_start_date=[7355448481000, 5464538486000, 1456345351000], calling_number=+3859121JMOYL, call_direction=I}] 

나는 에스퍼의 설명서를 읽고 그것이 당신이 배열로 속성을 선언 할 수있는 newEvent을 대표하는 스키마를 만들 수 있다고하지만, 내가 작업을 발견하지 않았습니다 예.

나는 어떤 종류의 쿼리가 필요한지 알지 못합니다. 패턴 쿼리 나 특정 속성에 대한 하위 쿼리가있는 선택 쿼리가 필요합니까? 어떤 제안이라도 감사하겠습니다.

답변

0
select window(call_start_date).distinctOf() from CallPOPDWH#keepall group by calling_number, detectionTimestamp 

몇 가지 메모

  • 시간 창이나 다른
  • "출력 마지막으로 모든 X의 초"예를 들어 연속 출력이 원하지 않는 추가 될 수있는 모든 값을 기억하기위한 #keepall
+0

대단히 고마워! 내가 원하는 결과와 정확히 일치하는 쿼리를 약간 수정해야하지만 기본 개념을 이해할 수있다! –