nesper

1열

1답변

호출 방법은 모두 내가</p> <pre><code>select udf(a,b) from Event.win:length_batch(5) </code></pre> <p>같은 방법을 호출하고 밖으로 다시 크기 5의 창을 인쇄 할 수있는 방법은 이벤트

가 포함되어 있습니다. 다음 이벤트를 보내주십시오. runtime.sendEvent(new Event(1,2)); runtime.sendEvent(new Event(3,4)); runtime.sendEvent(new Event(4,2)); runtime.sendEvent(new Event(6,8)); runtime.sendEvent(new Event

0열

1답변

Nesper 엔진/C# : 내부 현재 시간에 문제가 발생했습니다.

C#에서 Nesper 엔진 (http://www.espertech.com/esper/nesper.php)을 사용하고 있는데 문제가 있습니다. 엔진의 내부 시간을 검색 할 때 어제의 날짜이므로 반환 된 날짜가 잘못되었습니다. 아래 코드는 문제를 재현 한 더미 샘플입니다. 'engineTime'과 'DateTime.UtcNow'가 같아야한다는 점을 생각해 보면

0열

1답변

왜이 컨텍스트가 작동하지 않습니까?

동일한 문에서 아래의 두 상황에서 지정된 시간을 선택하고 싶습니다. 그러나 출력이 없습니다. B가 활성 상태이고 C가 단일 문장에서 중첩 된 컨텍스트를 사용하여 활성 상태 일 때 어떻게 결과를 얻을 수 있습니까? create context A context B start (0, 12, *, *, *) end (0, 18, *, *, *),

0열

1답변

어떻게하면 창에서 max (val) 및 min (val)에 대한 타임 스탬프를 얻을 수 있습니까?

NAMED WINDOW 또는 WINDOW에서 MAX (val) 및 MINval에 대한 타임 스탬프를 얻는 방법은 무엇입니까? 창 : [ t1- 100 t2- 200 t3- 250 t4- 900 ] 윈도우 I가 최대 값과의 최소값과 최대 T1 T4 해제 할 때마다. 내 명명 된 창에서 하위 쿼리를 시도했지만 하위 쿼리의 집계가 허용되지 않습니다.

0열

2답변

표현식에서 에스퍼 스트림의 출력을 강제 실행합니다.

나는 시장 데이터를 가져 오기위한 특별한 쿼리를 얻었습니다. 모양은 다음과 같습니다. select * from L1Quote(Symbol='MSFT') 새로운 견적이 생길 때마다 작동합니다. 몇 가지 초기 설정을하려면 첫 번째 견적/이벤트가 필요합니다. 이것은 이벤트/따옴표가 매 초마다 실행되는 심볼에서는 문제가되지 않지만 일부 심볼에서는 1 분 동안

0열

1답변

창에서 이벤트 속성 집합을 어떻게 유지합니까?

해시 테이블의 값 목록에있는 기본 키와 보조 열로 된 테이블을 만들 수 있습니까? 이 같은 뭔가 : 목록 창 크기 일어난 기본 키에 관련된 모든 속성을 보유 할 create table T (id int primary key, list HashSet) . 편집 : 이것은 내가 얻는 결과입니다. 선두로부터 2 ID 1에서 3 번 도착하면 내가 원하는하지 자

0열

1답변

Nesper와의 고유 한 물체의 시간 측정

NEsper를 사용하여 고유 ID가있는 차량의 시간을 측정하고 싶습니다. 내 문제는 도로에 여러 차가 있다는 것입니다. 이 도로에는 사전 정의 된 단계가 있습니다. 나는이 차가 마지막 단계를받을 때까지 첫 걸음에있는 모든 독특한 자동차의 시간을 멈추기를 원합니다. select ice.* from pattern[ice = IncomingCarEvent ->

0열

1답변

win.length가 EPL Nesper에서 패턴을 사용하는 중에 잘못된 결과를 얻었습니다

Windows 길이에 문제가 있습니다. 내 조건 : 이벤트가 길이 내에서 일어나는 경우에이 1 출력은 트리거 3 이 출력 이벤트가 길이 후에 일어나는 경우에 기각 3 예 : 이벤트 순서 : 1 : 2 : B 3 : C 4 : D 5 : E 6 : 7 : C 8 : D E 10 F 11 : 0 B이벤트 규칙 : Z = A -> B 예상 출력 : Z 이후 인덱

0열

1답변

Esper의 이벤트 그룹화 및 일괄 처리

사용자별로 이벤트를 그룹화하고 일괄 처리로 반환하려고합니다 (사용자별로). 예를 들어, 3 명의 사용자가 각각 5 개의 이벤트를 보낸 경우 5 개의 이벤트 중 3 개의 배치를 esper에서 출력하고 싶습니다. 다음 EPL을 사용하여 3 개의 데이터 창이 생성되고 각 창에 5 개의 이벤트가 있음을 검증 할 수 있습니다. 선택 * EVT.std에서 (2) .s

0열

1답변

주어진 시간 동안 들어오는 이벤트가없는 경우 esper를 트리거하는 방법

kafka의 메시지를 수신 대기하도록 구성된 esperprocesser가 있습니다. 보통 select * from events.win:time(2 min)은 지난 2 분간 모든 이벤트를 트리거합니다. 지난 2 분 동안 카프카에 메시지가없는 경우 알림을 실행하고 싶습니다. select * from events(Ip='1.1.1.1').win:time(2 mi