Esper를 시작하는 데 대한 this brilliant article을 기반으로 한 매우 간단한 테스트 GUI를 만들었습니다. 첫 번째 틱 이벤트가 전송 된 후이 쿼리의 유효성이 확인된다는 것은 놀랍습니다. 가격이 이상이면 입니다. select * from StockTick(symbol='AAPL').win:length(2) having avg(price
현재 주문 개체가 있습니다. 우리는 orderId, state 및 price라는 세 개의 필드가 있다고 가정합니다. class Order
{
public int orderId;
public String state;
public int filled;
}
주문이 끝나면 상태 및 충전량이 변경됩니다. Order o .....;
AlgoTrader의 오픈 소스 에디션에서 이동 평균 전략을 사용하여 SimulationStarted 클래스를 실행하려고합니다. 나는 일식에 SimulationStarter를 시작하면 내가 그러나이 명령에 java.exe -cp 대상/클래스와 실행 Exception in thread "main" com.algoTrader.service.SimulationS
10 초마다 패킷을 보내는 데이터 스트림이 있습니다. 장치가 다운되었을 때 마지막 패킷을받은 이벤트를 생성하는 Esper에 대한 쿼리가 필요합니다. 나는 데이터가 30 초를 위해 도착하지 않는 경우 장치가 분실 가정하지만 장치가 스팸 메일을 여기 을 피하기 위해 다시 올 때까지 나는 단지 1마다 5 시간을 통지받을 필요가 나의 기본 쿼리입니다 : selec
Esper 엔진 장기 실행 프로세스를 만들고 싶지만 Esper의 스레딩 모델이나이를 구현하기 위해 구현해야하는 모델에 대해 잘 모릅니다. public class EsperTest {
/**
* @param args the command line arguments
*/
public static void main(String[] args) {
소스가 24 시간 이상 시스템에 이벤트를 보내지 않았을 때를 감지하고 싶습니다. 이 패턴이 인식되면, 소스가 무언가를 보낸 마지막 알 수있는 이벤트 (일 수 있음)를 검색 할 수 있기를 원합니다. 나는이 수표가 24 시간마다하고 싶다. 나는 'ATM'유형 예제를 따라 갔고 다음과 같이 간단하게 만들었다. 패턴 [모든에서 선택 a.value (시간 : 간격
현재 Esper expressions을 배우고 있으며 매우 혼란 스럽습니다. 몇 초 간격으로 숫자를 스트리밍하는 습도 센서를 시뮬레이트하는 간단한 예제가 있습니다. 제 독서를 통해 저는 꽤 복잡한 예를 들었습니다 : select avg(value), 'Humidity' as datasource, from myPackage.myClass(name='Humid
저는 Esper에게 매우 익숙하며 방금 튜토리얼을 읽었으므로 제가 갖고있는 의문이 많습니다. 모든 데이터 소스에서받은 정보의 평균을 계산하는 쿼리를 작성하려고합니다. 내 다음 단계는 평균 계산 한 후 select * from pattern [every e=MyClass.Event]
: select avg(cast(value, float)) from pa
ESPER CEM 및 해상 항공로 작업. 배가 11 미터 이하에서 11 미터 이상으로 변경되면이를 감지하고 싶습니다. select new from pattern [every new=VoyageReport(draught < 11) -> (VoyageReport(mmsi=new.mmsi and draught > 11))]
* 서버 messege은 :http
Esper 프레임 워크에 문제가 있습니다. http://esper.codehaus.org/esper-4.11.0/doc/reference/en-US/html/examples.html#examples-autoid 이 예제의 소스 코드는 여기에서 찾을 수 있습니다 : autoid 디렉토리 \ 예에서 http://esper.codehaus.org/esper/do