2016-06-15 10 views
0

내 사용자 정의 함수에서 반환하는 반환 값을 기반으로 이벤트를 필터링하는 esper epl 식을 작성하려고합니다. 사용자 정의시 한 번에 두 개의 이벤트 개체를 사용해야합니다. 그래서 나는 이와 같은 질의를 작성했다.두 개의 매개 변수를 사용하는 Esper 사용자 정의 함수

select window(*), 'CANDLE NAME' as candleType 
from CandleStickEvent(myFunction(*) = 'true').win:length(2) 

이 기능은 한 번에 하나의 CandleStickEvent 객체 만 전달하지만,이 두 객체를 윈도우에 전달하려고합니다.

이것을 달성하기 위해 다음과 같은 쿼리를 시도했습니다. 그러나 아무것도 작동하지 않았습니다. 이이 오류 메시지를 제공

"select window(*), 'CANDLE NAME' as candleType " 
"from CandleStickEvent(myFunction(window(*)) = 'true').win:length(2) " 

'창'집계 함수는 집계 된 이벤트가 제거 스트림을 제공해야합니다; 그것은 오류를 제공하지 않지만

"select window(*), 'CANDLE NAME' as candleType " 
"from CandleStickEvent.win:length(2) " 
"output when myFunction(*) = 'true'" 

또한 쿼리 다음 'lastever'또는 'n 번째'대신

I 시도를 스트림에 데이터 창을 정의하거나 'firstever을 이용 해주시기 바랍니다 내 기능이 실행되지 않습니다.

아무도 나를이 조건을 충족하는 방법을 찾을 수 있습니다.

감사합니다.

답변

1

SQL에서 having 절은 집계에 대한 필터링에 사용되며 EPL은 SQL 표준을 준수합니다. "... havefunc (창 (*))"시도