내가 에스퍼 + 뮬 함께 일하고 있어요 그리고 나는 POJO 및 이벤트를 정의하기 위해 노력하고있는 문자열의 다른 목록에있는 경우, 그러나 Espero I 천국의 설명서를 읽은 후 찾기 내가 정말로 필요로하는 것을 찾지 못했습니다. POJO로 표현 내 사건은,이 같은 속성이 있습니다 List<String> Words;
는 내가 뭘하고 싶은 것은 단어의
사용자 수가 연결된 사용자 수의 이벤트 스트림이 있습니다. expression Disconnected { x => max(x.usersCount) - x.usersCount }
expression DisconnectedPercent { x => Disconnected(x)/max(x.usersCount) * 100 }
select usersCount,
규칙을 만족하는 이벤트의 경우, 리스너에서 관련된 슬라이딩 윈도우 (ID/이름) 세부 정보를 얻는 방법. select * from StockTick.win:time(10) having avg(price) > 20
우리는 (창 1 슬라이딩의 일환으로) StockTick 이벤트 A, B받을 - 예컨대, 우리는 규칙을 가지고있다. 이벤트 B, C가 슬라이딩
입력 어댑터로 CSV 파일이 있는데 매 초마다 CSV 파일에서 이벤트를 보내려고합니다. 예를 들어 A1, A2, A3, B1, B2 및 B3이 있습니다. 나는 A1, A2, A3를 1 초에, B1, B2, B3를 2 초에 보낼 것을 원한다. 이 참조 http://esper.codehaus.org/esperio-4.0.0/doc/reference/en/htm
데이터 처리 시간을 에스퍼에 기록하고 예를 들어 볼링 밴드를 선택합니다. Bollinger Band에서는 Moving Average (MA)라고 부릅니다. MA는 주가 평균을 계산 한 결과로부터 얻은 것입니다. 이 경우 win : length (20)를 설정합니다. 따라서 MA는 데이터 창보기에 존재하는 20 개의 이벤트에서 주가 평균을 계산 한 결과로부터
우리는 여러 다른 시스템에 연결하여 이벤트를 스트림으로 푸시합니다. 또한 각 커넥터는 상태가 변경 될 때 상태 메시지를 보냅니다. 나는 이전에 상태가 전송 된 경우에도 각 커넥터에 대해 보내진 마지막 상태를 보여주는 훌륭한 쿼리를 원합니다. 우리 콩은 다음과 같이 보입니다. public class ConnectorStatus
{
private f
Esper를 사용하여 특정 값을 반환하는 특정 개체 클래스를 검색하고 있습니다. 여기에 내가 지금 설정하고있는 진술이있다. EsperEventConsumer consumer = new EsperEventConsumer();
consumer.setEsperStatement("select * from com.my.package.MyClass as test w
모든 이벤트를 유지하고 StreamInsight에서 원하는대로 이벤트를 추가 또는 삭제하는 방법이 있습니까? Esper에는 keepall()이라는 마녀가 창에 적용될 수있는 방법이 있습니다. 이 메소드는 들어오는 모든 이벤트를 유지하고 창에 이벤트를 삽입하거나 삭제할 때 다른 쿼리를 가질 수 있습니다. StreamInsight에서 Hopping, Snaph
규칙 완료 전에 마지막으로 삽입 된 이벤트를 에스퍼 코어에서 가져 오는 방법이 있습니까? Configuration cepConfig = new Configuration();
cepConfig.getEngineDefaults().getMetricsReporting().
setEnableMetricsReporting(true);
cepCon