Siddhi CQEngine 필터 섹션 내에서 사용

Question

들어오는 이벤트에 userId 속성이 있습니다. CQEngine에서 userId에 따라 매개 변수 값을 읽을 수 있기를 바랍니다. 이것을 FunctionExecutor의 확장으로 구현해야하며 다음과 같이 사용해야합니다.

define stream cseEventStream (userId string, symbol string, price long, volume long); 
@info(name = 'query1') 
from cseEventStream [price < custom:cache(userId)] 
select * 
insert into Output 

또는 더 좋은 방법이 있습니다. 문제는 CQEngine을 처음 사용하기 전에 데이터로 초기화해야한다는 것입니다. FunctionExecutor의 "start"메서드가이 목적으로 사용될 수 있습니까?

Answer 1

FunctionExecutor으로 가서 init() 또는 start() 내에 초기화 논리를 구현할 수 있습니다. 두 함수 모두 함수 호출 당 한 번 호출됩니다. 전화 주문은 init()이며 그 뒤에 start()이옵니다. 그러나 API 문서에 따라 처리 요소에 필요한 리소스를 얻으려면 start()을 사용하는 것이 좋습니다. 획득 된 리소스를 해제하려면 stop()