esper - ESPER 使用带有 POJO 的 csv 适配器

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();