如何使用esper订购活动？

Question

我想用一个值对事件进行排序；所以我找到了eseper，但我想不出解决方案。

我从互联网上找到了一个例子，并试图对其进行定制，但失败了。

以下是我尝试过的代码。

SampleEvent.java

public class SampleEvent {
    private String item = null;
    private int times = 0;

    public SampleEvent(String item, int times) {
            super();
            this.item = item; 
            this.times = times;
    } 

public String getItem() {
            return item;
    } 

public void setItem(String item) {
            this.item = item;
    } 


public int getTimes() {
            return times;
}

public void setTimes(int times) {
            this.times = times;
}

} 

SampleListener.java

import com.espertech.esper.client.EventBean;
import com.espertech.esper.client.UpdateListener; 

public class SampleListener implements UpdateListener {
        public void update(EventBean[] newEvents, EventBean[] oldEvents) {
                EventBean event = null;

                event = newEvents[0];
                System.out.println(event.get("item") + ", time = " + event.get("times"));
        }
} 

SampleEngine.java

package example.esper;

import com.espertech.esper.client.Configuration;
import com.espertech.esper.client.EPAdministrator;
import com.espertech.esper.client.EPRuntime;
import com.espertech.esper.client.EPServiceProvider;
import com.espertech.esper.client.EPServiceProviderManager;
import com.espertech.esper.client.EPStatement;

public class SampleEngine {
        public static void main(String[] args) {
                Configuration config = null;
                EPServiceProvider service = null;
                EPStatement stat = null;
                String epl = null;
                SampleListener listener = null;
                EPRuntime runtime = null;

                config = new Configuration();
                config.addEventType("SampleEvent", SampleEvent.class.getName());
                service = EPServiceProviderManager.getDefaultProvider(config);

                EPAdministrator admin = service.getEPAdministrator();

                EPStatement namedWindowStmt = admin.createEPL("create window orderdEvt.std:unique(item) (item String, times int)");
                epl = "insert into orderdEvt select item, times from SampleEvent GROUP BY times ORDER BY times";
                namedWindowStmt=admin.createEPL(epl);

                listener = new SampleListener();
                namedWindowStmt.addListener(listener);


                runtime = service.getEPRuntime();
                for (int i = 0;i < 20; i++) {
                        try {
                            int j = (int)(Math.random()*100)+1;
                             runtime.sendEvent(new SampleEvent("aaa_" + i, j));

                        } catch (Exception ex) {
                                ex.printStackTrace();
                        }
                }
        }
} 

这些代码是不起作用的。它应该是按时间对事件进行排序。

有没有人知道如何解决这个问题，或者举个例子？

谢谢。

Answer 1

Esper是一个流处理器。在对事件进行排序时，您需要确定正在比较哪些事件(例如，数据窗口是什么，如果有)以及它们在什么条件下输出(每隔5秒，当X发生时，您的条件会导致输出)。当前版本为8.2，接口发生了变化，请使用更新后的示例。它们可以在esper home page上找到。

一个例子是

select * from Event#time(10 seconds) output snapshot every 2 seconds order by value