WSO2 CEP에서 몇 가지 계산을 수행하는 사용자 지정 기능이 있습니다. 다음과 같은 쿼리가 있습니다. String cseEventStream = "define stream eventStream (attribute string,attributeValue object);";
String query = "from eventStream#window.time
나는 스트림에 필드의 최대 값을 캡처하는 쿼리가 있습니다 from stream1#window.time(1 min)
select max(value1) as max_value1
insert all events into newstream;
이 창 후 나는에 null 값을 얻기 위해 시작했지만 max_value1. 평균은 동일하지만 모든 이벤트가 1 분 시
쿼리 및 실행 계획을 가지고 있으므로 스냅 샷을 찍어서 수신 측에서 복원하고 다시 실행하기를 원합니다. 수신자에게 어떤 형식으로 보내야합니까? 수신자 측에서 복원하는 방법은 무엇입니까? 다음은 Siddhi 저장소에서 가져온 일부 코드입니다. SiddhiManager siddhiManager = new SiddhiManager();
String qu
나는 time_length_batch에서 마지막 이벤트를 얻으려고하고 있지만이 방법은 손실 WRT입니다. 예를 들어 ... 인벤토리 이벤트가 있으며 사용 가능한 각 제품에서 최신 업데이트를 받고 싶습니다. 다음 쿼리는 주로 필요한 것을 대부분 제공합니다. 제외하고는 지난 이벤트에서 마지막 이벤트가 발생했습니다. 그 창에 대한 마지막 이벤트에만 관심이 있습니
CallPOPDWH 이벤트가 있다고 가정합니다. 이벤트에는 4 개의 열이 있습니다. 유형 컬럼, 이름 컬럼, 검출 시간 소인 컬럼 및 속성 컬럼. 에스퍼는 다음과 같은 3 개 튜플을 생성합니다 [Event, CallPOPDWH, 1456938481000, {call_start_date=7355448481000, calling_number=+3859121JM
Apache JIRA에 문제가 있습니다 : https://issues.apache.org/jira/browse/FLINK-3703. 일치하는 순서 후에 계속해야 매칭 알고리즘이 발견 된 곳은 정의 할 수 있으며, 행동의 세 가지 유형이 있습니다 : from first - (즉 현재 동작입니다) after first 미래 일치하는 모든 이벤트를 유지 계속이
나는이 스트림이 있습니다 define stream locationStream (cell string, device string, power long);
나는 '셀의 모든 장치에 대한 값 10 초 슬라이딩 창으로,이 스트림에 선택합니다 '속성이 가장 큰 속성입니다. Siddhi에서이 결과를 얻으려면 어떤 쿼리를 사용해야합니까? from locationSt
기존 모듈을 삭제하려면 문서 (http://cumulocity.com/guides/reference/real-time-statements/)에 /cep/module/<<moduleId>>에 대한 DELETE 요청을 수행해야한다고 나와 있습니다. 그러나 이것은 "요청 메소드 'DELETE'가 지원되지 않습니다"라는 이유로 응답 상태 500이됩니다. 단일 모듈
Cumulocity에서 일정 기간 경과 후 구성된 보고서를 전자 메일로 자동 전송하려고합니다. 보통 보고서는 수동으로 전송됩니다. 이미 CEP (복잡한 이벤트 처리) 규칙을 사용하여 보고서 내용없이 전자 메일을 자동으로 보냅니다. CEP 규칙에서 구성된 보고서 템플릿에 액세스하려고 시도했습니다. 아무에게도 이것이 가능한지 어떻게 알 수 있습니까?