From 6e3a5f3859a79d2b69a36e5eee2dfc53553210a5 Mon Sep 17 00:00:00 2001 From: minudika Date: Wed, 17 May 2017 01:41:10 +0530 Subject: [PATCH] updating json-mapper sample --- .../artifacts/0008/json-mapper-sample.siddhi | 25 ++++++++----------- 1 file changed, 11 insertions(+), 14 deletions(-) diff --git a/modules/samples/artifacts/0008/json-mapper-sample.siddhi b/modules/samples/artifacts/0008/json-mapper-sample.siddhi index a341ddeb..954e4714 100644 --- a/modules/samples/artifacts/0008/json-mapper-sample.siddhi +++ b/modules/samples/artifacts/0008/json-mapper-sample.siddhi @@ -1,29 +1,26 @@ @Plan:name("SmartHomePlan") -@sink(type='tcp', context='UsageStream', port='9893', +@source(type='tcp', context='SmartHomeData', port='9892', @map(type='passThrough')) -define stream InputStream (houseId int, maxVal float, minVal float, avgVal double); +define stream SmartHomeData (houseId int, maxVal float, minVal float, avgVal double); -@source(type='InMemory', topic='home', @map(type='json', -enclosing.element="portfolio", @attributes(symbol ="stock.company.symbol", price = "stock.price", volume = "stock.volume"))) -define stream InMemorySmartHomeInputData (houseId int, maxVal float, minVal float, avgVal double); -@sink(type='inMemory', topic='home', @map(type='json', @payload("{"portfolio":{ - "StockData": { - "houseId":{{houseIdl}}, +@sink(type='inMemory', topic='home', @map(type='json', @payload("""{"portfolio":{ + "stock": { + "houseId":{{houseId}}, "maxVal": {{maxVal}}, "minVal": {{minVal}}, "avgVal": {{avgVal}} } -}}"))) -@source(type='InMemory', topic='home', @map(type='json', - enclosing.element="portfolio", @attributes(symbol ="stock.symbol", price = "stock.price", volume = "stock.volume"))) +}}"""))) +define stream InMemorySmartHomeInputData (houseId int, maxVal float, minVal float, avgVal double); + +@source(type='inMemory', topic='home', @map(type='json', +enclosing.element="portfolio", @attributes(houseId ="stock.houseId", maxVal = "stock.maxVal", minVal = "stock.minVal", avgVal = "stock.avgVal"))) define stream UsageStream (houseId int, maxVal float, minVal float, avgVal double); -from InputStream +from SmartHomeData select * insert into InMemorySmartHomeInputData; from InMemorySmartHomeInputData#log("Event") -select houseId as houseId, max(value) as maxVal, min(value) as minVal, avg(value) as avgVal -group by houseId insert into UsageStream; \ No newline at end of file