Мне нужно присвоить значение определенному атрибуту в потоке, проверив условие.
Как это сделать?
e.g
если человека зовут «Джон», и мне нужно изменить его имя на «Питер» и вставить в другой поток, как мне это сделать?
from myStream [name == 'John']
select *
insert into outStream;
define stream myStream (name string, attribute1 int, attribute2 bool);
from myStream [name == 'John'] --This filter matches any event with name equal to 'John'
select "Peter" as name, attribute1, attribute2 --Replaces the current name with 'Peter'
insert into outStream;
Пример 1
Вход:
{Dilini, 123, true}
Выход:
(выхода не будет, так как имя не удовлетворяет условию в фильтре name=='John')
Пример 2
Вход:
{John, 123, true}
Выход:
{Peter, 123, true}
См. возможности "Query Projection" в Siddhi. Отметьте действие: 'Введение значения по умолчанию'.
