siddhi

0열

1답변

다음과 같은 siddhi 하위 쿼리를 달성하려고하고 있지만 올바른 구문을 가져올 수 없으므로 그러한 샘플이 아직 나에게 충돌하지 않았습니다. select employee_id, (select count(*) from employees) from employees 또는 뭔가 select employee_id, count(employee_id), (sel

0열

1답변

"모든"진술에 대한 부정? WSO2 CEP/Siddhi

"every"문을 부정하는 간단한 방법이 있습니까? 들어오는 구매 주문 및 요청을 확인하는 제어 도구를 구현하려고합니다. 각 구매 주문 (PO)에 대해 이전에 요청 (REQ)을 작성해야합니다. 다음 코드는 (긍정) 일치하는 PO/REQ 쌍을 감지하지만 해당 REQ (제외 어)가없는 모든 PO가 필요합니다. from every a1 = PO -> b1 = R

0열

1답변

데이터 분석 스트림 처리 (스톰) 및 복잡한 이벤트 처리

복잡한 이벤트 처리와 결합 된 스트림 처리에 대한 연구를하고 있습니다. 오픈 소스 소프트웨어를 사용하여 Apache Storm에서 작업하고 싶습니다. Esper와 같은 CEP 엔진을 발견했습니다. , Siddhi, Sase +하지만 Apache-Storm에서 특별히 작업 할 무언가를 찾고 있습니다. Storm에서 완벽하게 조정할 수있는 CEP 엔진이 있습니

0열

1답변

WSO2 DAS- Siddhi를 사용하여 얼마나 많은 DAS가 메모리에 데이터를 보관할 수 있습니까?

WSO2 DAS를 처음 사용했습니다. 이 문서에 따르면 DAS가 데이터를 빠르게 분석 할 수 있다고합니다. 나는 예제를 만들려고 노력하고 있습니다. 내 시나리오는 아래와 같습니다. @Import('in_test_stream:1.0.0') define stream inStream (a string, b string); *---> receive data*

0열

1답변

Siddhi 락 : 그룹 별 멀티 결과 Siddhi 락 3.1.0, 이처럼 내 siddhiql

을 window.cron 사용 : 나는 실제로 내가 집계를받을 키 key 그룹에 대한 결과 집계를 얻을 것으로 예상 define stream demo(key string, v1 int, v2 int, v3 int); from demo#window.cron(0/5 * * * * ?) select key,sum(v1) as v1,sum(v2) as v2,s

0열

1답변

WSO2 CEP - 여러 실행 계획을위한 단일 이벤트 테이블

지난 며칠 동안 WSO2 CEP를 탐색 해 왔습니다. 단일 조회 테이블을 여러 실행 계획에서 사용할 수있는 시나리오를 고려 중입니다. 내가 아는 한, 모든 데이터를 저장하는 유일한 방법은 이벤트 테이블입니다. 내 질문은 : 내가 한 번 이벤트 테이블을로드 (하나 개의 실행 계획이 될 수있다) 및 기타 실행 계획과 해당 테이블을 공유 할 수 있습니까? Q1

2열

1답변

wso2로 널 (NULL) 값 처리 CEP

하나의 컬럼이 널이 아닌 추가 조건을 사용하여 이벤트 테이블 (RDBMS)을 갱신하려고합니다. 테이블 이름은 MSISDNProfileDB이며 Oracle 데이터베이스에 있습니다. from incomingStream#window.length(1) select correlation_MSISDN as MSISDN, INTERACTION_DT as I

0열

1답변

Siddhi 쿼리에 대해 긍정적 인 응답을 트리거 한 실제 이벤트 개체 검색

Siddhi에서 쿼리에 긍정적 인 응답을 유발 한 실제 이벤트를 검색 할 수 있습니까? 예를 들어 조건을 만족시키는 이벤트 A가있는 경우 쿼리 투영을 통해 ExecuteRuntime 콜백에서 (Siddhi 핵심 이벤트로) 사용하려는 이벤트 A의 사용 가능한 특성을 만들 수 있습니다. 그러나 쿼리를 만족하는 실제 이벤트 개체를 검색하고 싶습니다. 그 속성의

0열

1답변

Siddhi CQEngine 필터 섹션 내에서 사용

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

0열

1답변

Siddhi 락은 내가 이런 간단한 쿼리를 집계 쿼리

에서 어떤 응답을하지 않습니다. runtime.addCallback("aQuery", new QueryCallback() { @Override public void receive(long timeStamp, Event[] inEvents, Event[] removeEvents) { EventPrinter.print(time