Я не могу помочь вам использовать реальный движок (Apama), но я могу привести один пример использования Esper.
@Name("Sending the http request")
@Resilient
insert into
SendRequest
select
'post' as method,
'https://tenant.cumulocity.com/inventory/managedObjects' as url,
'Basic .....' as authorization,
'application/json' as contentType,
toJSON(m) as body
from anyEventStream m;
toJSON, если функция, которая принимает поток событий и возвращает, эквивалентна в json.
Вы можете найти больше информации здесь . Эта информация скрыта от фактических документов и думает, что это потому, что они хотят подтолкнуть разработчиков к использованию APAMA вместо ESPER.
Надеюсь, это поможет.