에 의해 마지막 시간 그룹에서 이벤트를 계산하는 방법을 내가 타임 스탬프를 포함하는 객체, class Event{ public long timestamp; }
지금 내가 어떤 분 마지막 시간 그룹의 모든 이벤트를 카운트 할 수 있습니다. 그래서 나는 60 개의 결과를 기대하고있다. 내가 시도해야하지만 스냅 샷 근처 나에게 구문 오류를 줄 쿼리 : sel
자바에서 Esper에 관한 질문이 있습니다. 각 이벤트에 대해 두 요소 (돈, 이름)가있는 이벤트가 있다고 가정 해보십시오. 내가 원하는 것은 돈이 가장 많은 3 가지 이름을 출력하는 것입니다. 이 일을하는 방법이 있습니까? 이벤트 예 : 100, 아드-10, 존 (15), SAM-20 소사 36 니콜라 ---> 난에 출력 싶은 : 아드 니콜라 및 소사 이
일부 데이터 스트림을 처리하기 위해 폭풍우를 사용하고 있습니다. 처음에 나는 내가 에스퍼 볼트에 사용되는 문장을 찾을 수 xml 파일을 읽습니다. 곧 내 토폴로지를 정의하고 클러스터에서 실행합니다. 이제 볼트에서 명령문을 변경하려면 xml을 수정하고 클러스터를 중지 한 다음 처음부터 다시 시작해야합니다. 내 XML을 검사 할 때 클러스터가 진행되는 동안 새
사용자별로 이벤트를 그룹화하고 일괄 처리로 반환하려고합니다 (사용자별로). 예를 들어, 3 명의 사용자가 각각 5 개의 이벤트를 보낸 경우 5 개의 이벤트 중 3 개의 배치를 esper에서 출력하고 싶습니다. 다음 EPL을 사용하여 3 개의 데이터 창이 생성되고 각 창에 5 개의 이벤트가 있음을 검증 할 수 있습니다. 선택 * EVT.std에서 (2) .s
스트리밍 이벤트 처리에 ESPER를 사용하고 있습니다. 다음과 같이 명세서를 작성한 다음 CEP 엔진에 추가합니다. 대량의 데이터 (분당 백만 건의 이벤트)를 처리하는 데 적합한 방법입니까? cepRT.sendEvent()
어떻게 에스퍼 그것을 평가해야 쿼리에 이벤트를지도 않습니다 Configuration cepConfig = new Configurat
에스퍼로 패턴 감지와 관련하여 커뮤니티에 대한 질문이 있습니다. 당신은 데이터의 모음 사이에 다음과 같은 패턴을 감지한다고 가정 : A B의 C 그러나 를, 그것은 실제 데이터에, 당신이있을 것이 가능하다 : A, B, D, E, C. 내 목표는 메모리에 A B를 유지하여 A B C를 감지 할 수있는 규칙을 디자인하고 C가 보자 마자 즉시 경고를 발생시키는
이벤트 처리 시스템을 설계하려고합니다. 규칙 자체는 문제가 아닙니다. 무엇 내를 습지 것은 내가 효율적으로 질문에 대답 할 수 있도록 이벤트 데이터를 저장하는 방법입니다/같은 사실 : 지난 10 분 A 형 이벤트의 수는 N, 분당 B 형의 평균 이벤트를 동일한 경우 지난 M 시간 동안 Z가 이고 다른 메트릭의 현재 평균이 Y ... 인 경우 일부 이벤트가
에 대해 그룹별로 쿼리합니다. 저는 Esper 개발을 처음 접했고 약간의 문제가 있습니다. 는 SQL에서, 내가 에스퍼로 변환하는 후속 쿼리가 : 사용자가 선택 최대 (시간) 탭 그룹을 내가 뭘 원하는 내가 가진 모든 이벤트에 대해 내가 선택하려는 것입니다 모든 사용자의 최대 시간 (시간)을 표시합니다. 저는 Esper에서 다음과 같이 번역했습니다 : 사용
여기서 트리거 이벤트 란 무엇입니까? 이벤트를 가져 오는 데 EsperEngine을 연결하는 방법은 무엇입니까? 어떤 URI를 전달해야합니까? engineURI은 어떻게 생겼습니까? 에스퍼 엔진의 원격 위치입니까? ConfigurationHTTPAdapter adapterConfig = new ConfigurationHTTPAdapter();