cep

2열

2답변

Kie workbench 6.3.0을 사용하여 규칙을 만듭니다. 스트림 모드에서 규칙을 실행하려고합니다. 나는 kie-wb에서 프로젝트를 만들고 거기에 kie-base를 만들었습니다. 우리는 이것을 위해 kie 서버 런타임을 사용하고 있습니다. <kmodule xmlns="http://jboss.org/kie/6.0.0/kmodule" xmlns:xsi="

0열

2답변

CEP 창을 지우는 방법

inOrg 스트림에 동일한 이벤트 (동일한 제목 있음)를 두 번 입력하는 것을 차단하고 싶습니다. 그래서 "첫 번째 고유"창을 사용했습니다. 그러나 어느 시점에서 이것은 메모리 부족 오류를 줄 것입니다. 1000 개 이상의 이벤트가있는 경우 첫 번째 고유 윈도우를 정리하고 싶습니다. 어떻게해야합니까? 이것은 실행 계획입니다. @Plan:name('Execu

0열

1답변

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

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

0열

1답변

WSO2 CEP에서 event_table에 복잡한 결합 조건

WSO2 CEP 4.1.0을 사용하는 이벤트에 필터링 기능을 구현해야합니다. 내 필터는 PostgreSQL 데이터베이스에 저장됩니다. 이렇게하려면 event_table 구성을 만들고이 event_table 스트림에서 내 이벤트에 가입하십시오. 내 필터는 기본 값을 가질 수 있습니다, 그래서 나는 복잡한 가입 조건이 필요합니다 from my_stream#wi

0열

1답변

Siddhi 락

에서 스트림에 오브젝트를받습니다 나는 예를 들어 다음 정보를 돌려 Siddhi 락 확장이 : 나는 스트림에서이 정보를 저장 원하는 나는 atribute "clientPublicId"를 사용하여 정보를 필터링 할 { "licenseKey": "WxyzChXjhJ-dgjfZfHnL9-bWd4e2vxjD-eIs5hDu0To-VOxL111BAj", "siteU

0열

1답변

siddhi로 시간 관리

2 분 동안 화이트리스트를 저장해야하지만 새 스트림이 도착하면 쿼리를 실행해야합니다 (내 화이트리스트 사용). 두 번째 스트림을 다음 코드와 함께 사용하고 있습니다. 2 분마다 업데이트되는 WHITELIST를 충전해야합니다. define trigger periodicalTriggerStream at every 2 min; from DSB_TEMPORAL

0열

1답변

오래된 이벤트의 저장은 esper에서 성능에 어떤 영향을 줍니까?

오래된 이벤트의 저장이 esper의 성능에 어떻게 영향을 줍니까? 예 : 10 개의 이전 이벤트를 저장할 경우 성능에 어떤 영향을 미치며 100 개의 이전 이벤트를 저장하면 성능이 어떻게 바뀌게됩니까? 어떤 변화가있을 것입니까? 저는 esper에서 메모리 사용량을 알고 싶습니다. 이전 이벤트는 어디에 저장됩니까?이 데이터 창 일치하는 패턴 인식 EPL 패턴

0열

1답변

간단한 이벤트 시퀀스

A, B, C 또는 D 유형의 이벤트가 방출된다고 가정합니다. A 유형의 이벤트 다음에 B 유형의 이벤트가 발생할 때마다이를 감지하고 싶습니다. 즉, Esper의 EPL이 -> 연산자를 제공하는 시퀀스를 감지하려고합니다. A B가 감지 될 때마다, 나는 그것이 내가 EPL의 구문을 사용하여 주위를 연주 된 가장 최근의 A. 과 일치 할 : 그러나, 내가 위

1열

1답변

Apache Flink + CEP - 동일한 이벤트 감지

동일한 속성을 공유하는 이벤트를 감지하고 싶습니다. 나는 간단한 경우 클래스가 있다고 가정 : case class Record(name: String, value: Int) 은 다음 스트림이 가정 : Record("A", 1) Record("B", 2) Record("A", 3) Record("C", 4) 그런 다음 나는 두 번 "A"레코드를

0열

1답변

Esper에서 쿼리 및 사용자 정의 함수를 작성하십시오.

주문이 가능한지 여부를 표시하는 EPL 문을 작성하려고합니다. 두 개의 이벤트, EventA (처리됨) 및 EventB (처리되지 않음)가 있습니다. 스키마 작성 EventA (유형 문자열, percentCompleted 정수); 스키마 작성 EventB (유형 문자열); 문은 요소의 유형 (문자열)을 기반으로 처리 된 모든 요소와 일치해야합니다. 결과에는