Hi all,
Thanks Tishan for the explanation.
I have used step 1 and 2 with "join with window.length(1) of each stream"
and Im getting the results as expected.
Best Regards,
Ramindu.
On Sun, Oct 28, 2018 at 11:18 AM Sriskandarajah Suhothayan
wrote:
>
>
> On Wed, Oct 17, 2018 at 11:59 PM Tishan
On Wed, Oct 17, 2018 at 11:59 PM Tishan Dahanayakage
wrote:
> Hi Ramindu,
>
> Each time a join happens s.amount is populated as 100 and it is a current
> event. When that current event reach the sum attribute aggregator it will
> keep on adding. In other words sum(s.amount) represent the sum of
Hi Ramindu,
Each time a join happens s.amount is populated as 100 and it is a current
event. When that current event reach the sum attribute aggregator it will
keep on adding. In other words sum(s.amount) represent the sum of amounts
that joined with consumptions stream not sum of amount came
Hi all,
In tutorial[1] which we are using for our labkit as well has the siddhi app
as follows.
@App:name('MaterialThresholdAlertApp')
@source(type = 'http', @map(type = 'json'))
define stream MaterialConsumptionStream(name string, user string,
amount double);
@source(type = 'http', @map(type
