adding sample for json-mapper

modules/samples/artifacts/0008/README.txt

@@ -0,0 +1,5 @@
+1. Copy {WSO2DASHome}/samples/0008/json-mapper-sample.siddhi file to {WSO2DASHome}/deployment/siddhi-files
+
+2. Start the worker using ./{WSO2DASHome}/bin/worker.sh
+
+3. Navigate to {WSO2DASHome}/samples/sample-clients/tcp-client and run ant command without arguments

modules/samples/artifacts/0008/json-mapper-sample.siddhi

@@ -0,0 +1,29 @@
+@Plan:name("SmartHomePlan")
+
+@sink(type='tcp', context='UsageStream', port='9893',
+@map(type='passThrough'))
+define stream InputStream (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}},
+ "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 UsageStream (houseId int, maxVal float, minVal float, avgVal double);
+
+from InputStream
+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;