내 사용자 정의 함수에서 반환하는 반환 값을 기반으로 이벤트를 필터링하는 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을 이용 해주시기 바랍니다 내 기능이 실행되지 않습니다.
아무도 나를이 조건을 충족하는 방법을 찾을 수 있습니다.
감사합니다.