이벤트가 오리온 이이 양자 로그 인에 의해 전송 될 때마다 내 양성자 인스턴스가 java.lang.NullPointerException이 실패합니다 proton_1 | 01-Jul-2016 09:46:03.117 INFO [http-nio-8080-exec-1] com.ibm.hrl.proton.webapp.providers.EventXmlNgsiMessa
FlinkCEP를 사용하여 패턴에 대해서만 '게으른'일치를 원합니다. 어떻게해야합니까? 예 : 나는 ACABCABCB 입력 스트림을 가지고 있으며, A matchesB 다음에 C와 일치하여 3 개의 일치 만 얻고 6 개의 일치는 얻지 못합니다. 내 문제를 설명하기 위해 다음 예제를 만들었습니다. val env = StreamExecutionEnvironme
다음 형식으로 시뮬레이션에서 데이터를 수신합니다 : 당분간 Street 7에서 Street으로가는 두 대의 자동차가 있음을 볼 수 있듯이 11 (움직임을 모니터링하기 위해 센서가 배치 된 수많은 구역을 가로 질러). 이제 자동차 # 1과 자동차 # 2의 최신 시간차가 3 초 이하일 때 신호를 멈추고 싶습니다. 어떻게 에스페셜 쿼리 언어로 그렇게 할 수 있습
를 사용하고 계십니까? 이미 도착한 이벤트를 기반으로 시간 창이 작동하고 있음을 이해했습니다. 은 GROUP BY 절과 window.timeBatch (2 분)를 사용하는 동안 내가 여러 결과를 얻고, 예를 들어 말. 주어진 2 분 동안 나는 주기적으로 50 개의 입력 이벤트를 통과시켰다. 예상 된 동작은 함께 모아서 하나의 결과로 주어진 모든 이벤트입니다
나는 queshion을 가지고있다. 쿼리를 만들고 "str : contains"함수를 두 가지 이벤트와 함께 사용할 수 있습니까? 예를 들어 교체 : from DSBStream[(str:contains(correlation_phr_incident_detail, '0.0.0.0')==FALSE)]
select *
insert into DSBFiltered
경로 C : \ wso2 \ wso2das-3.0.1 \ repository \ components에는 artifacts.xml 파일이 있습니다. 이 파일의 기능은 무엇입니까? 예를 들면? Siddhi 락을 확장 제가 사용 새 libreries를 추가하기위한 나는이 파일을 수정할 수 있습니다 jaxrs-api-3.0.2.Final.jar
resteasy-
내 사용자 정의 함수에서 반환하는 반환 값을 기반으로 이벤트를 필터링하는 esper epl 식을 작성하려고합니다. 사용자 정의시 한 번에 두 개의 이벤트 개체를 사용해야합니다. 그래서 나는 이와 같은 질의를 작성했다. select window(*), 'CANDLE NAME' as candleType
from CandleStickEvent(myFunctio