Доступ к отдельным событиям в скользящем окне в Сиддхи

Question

Я новичок в Сиддхи и КЭП. Я хочу получить первое и последнее событие в текущем скользящем окне.

Я пробовал:

from WeightStream#window.length(4) as W
select W[1].weight as weight1,  W[last].weight as weightLast
insert into AlertStream;

и

from w = WeightStream#window.length(4)
select w[1].weight as weight1,  w[last].weight as weightLast
insert into AlertStream;

Для окна, содержащего [1, 2, 3, 4], вывод должен быть [1, 4].

Answer 1

Нет способа получить доступ к окнам на основе индекса. Вместо этого для достижения этого требования вы можете использовать подсчет . Ниже приведен пример, который будет работать в скользящем порядке.

from every( e1= WeightStream) -> e2= WeightStream<3> 
select e1.weight as weight1, e2[last].weight as weightLast
insert into AlertStream;