【发布时间】:2017-03-23 21:02:15
【问题描述】:
我有一个关于 esper 的非常具体但简短的问题。我在 esper 中获得了事件 POJO,它们都带有 timeStamp 作为属性。我需要做一个 time_batch 窗口,但我必须根据事件的时间戳进行窗口化。时间戳将是一个长值。
我现在在互联网上搜索了几个小时,但找不到任何对我有帮助的东西。
【问题讨论】:
标签: esper
我有一个关于 esper 的非常具体但简短的问题。我在 esper 中获得了事件 POJO,它们都带有 timeStamp 作为属性。我需要做一个 time_batch 窗口,但我必须根据事件的时间戳进行窗口化。时间戳将是一个长值。
我现在在互联网上搜索了几个小时,但找不到任何对我有帮助的东西。
【问题讨论】:
标签: esper
使用外部时间并将时间戳作为时间来源。这在http://espertech.com/esper/release-6.0.1/esper-reference/html_single/index.html#api-controlling-time中有描述
例如。
Configuration config = new Configuration();
config.getEngineDefaults().getThreading().setInternalTimerEnabled(false);
EPServiceProvider epService = EPServiceProviderManager.getDefaultProvider(config);
....
epService.getEPRuntime().sendEvent(new CurrentTimeSpanEvent(event.getTimestamp());
epService.getEPRuntime().sendEvent(event);
【讨论】: