Я пытаюсь обогатить свой входной поток дополнительным атрибутом, который заполняется через приемник ответа "http-response".
Я пробовал использовать "join" с атрибутом window и с ключевым словом "every", чтобы объединить два потока и вставить полученный объединенный поток в другой поток, чтобы обогатить его.
Атрибуты окна (window.time (1 секунда) или window.length (1)) и ключевое слово «каждое» хорошо работают, когда входящие события приходят с регулярным интервалом в 1 секунду или более.
Когда (скажем, 10 или 100) событий отправляются одновременно (в течение секунды). Тогда результат слияния не ожидаемый.
Тот, у кого есть атрибут "окно" (присоединиться)
**
from EventInputStreamOne#window.time(1 sec) as i
join EventInputStreamTwo as s
on i.variable2 == s.variable2
select i.variable1 as variable1, i.variable2 as variable2, s.variable2 as variable2
insert into EventOutputStream;
**
Тот, у которого есть ключевое слово "каждый"
**
from every e1=EventInputStream,e2=EventResponseStream
select e1.variable1 as variable1, e1.variable2 as variable2, e2.variable3 as variable3
insert into EventOutputStream;
**
Есть ли лучший способ объединить два потока, чтобы обновить третий поток?
