ESPER使用csv適配器與POJO

Question

我需要esper使用csv文件作爲輸入與csv適配器一些幫助。我需要使用POJO類和超過1個csv文件。

如果有一個例子包含上面的監聽器，我會很感激。

感謝

Answer 1

使用Java對象的事件，簡直就是爲Java類註冊事件類型名稱，並提供相同的名稱到CSV適配器。

Configuration configuration = new Configuration(); 

    configuration.addEventType("Event1", Event1.class); 
    configuration.addEventType("Event2", Event2.class); 
    configuration.addEventType("Event3", Event3.class); 


    epService = EPServiceProviderManager.getDefaultProvider(configuration); 

    EPStatement stmt = epService.getEPAdministrator().createEPL(
     "select * from Event1, Event2,Event3"); 

    (new CSVInputAdapter(epService, new AdapterInputSource(filename1), "Event1")).start(); 
    (new CSVInputAdapter(epService, new AdapterInputSource(filename2), "Event2")).start(); 
    (new CSVInputAdapter(epService, new AdapterInputSource(filename3), "Event3")).start();