如何配料ESPER EPL事件

Question

我正在嘗試批處理這樣的通知事件，並且我正在通過一個通知事件獲取一個Notifications事件。誰能幫我？

提前提醒。

相關聲明

INSERT INTO Notification SELECT d.id as id,a.stationId as stationId,d.firebaseToken as firebaseToken, d.position as devicePos,a.location as stationPos,a.levelNumber as levelNumber,a.levelName as levelName FROM AirQualityAlert.win:time(3sec) as a, device.win:time(3sec) as d WHERE d.position.distance(a.location) < 300 

INSERT INTO Notifications SELECT * FROM Notification.std:groupwin(id).win:time_batch(20sec) for grouped_delivery(id) 

Answer 1

該解決方案能夠提供每「身份證」包含與事件列表中的列一行。

create context Batch20Sec start @now end after 20 sec; 
context Batch20Sec select id, window(*) as data 
from Notifications#keepall 
group by id 
output all when terminated; 

我認爲這就是你想要的。