Я хочу, чтобы события таймаута были индивидуально для каждого входящего события в esper. Как это сделать? Если я использую временные или пакетные окна, он будет ожидать, что другие события будут заполняться первым, а затем события будут перенесены в rstream.Время ожидания события Eseper
Используйте именованное окно с сохранением всех и поставьте условие, когда события будут удалены в on-delete.
create window CustomExpiryWindow.win:keepall() as MyEvent
insert into CustomExpiryWindow select * from MyEvent
on <.......> delete from CustomExpiryWindow where <......>
В альтернативе существует API расширения для окон данных, в которых вы можете писать код для сохранения и истечения срока действия событий.