Hi Inosh, Thanks for the reply. Yes, I enabled the persistence. Stream definition and event sink XML files are attached. BTW how to find relevant spark script?
On Mon, Dec 7, 2015 at 8:48 PM, Inosh Goonewardena <in...@wso2.com> wrote: > Hi Roshan, > > Did you enable the persistence for stream and it attributes properly? > Could you please share the Stream definition, event sink xml and spark > script. > > > On Tuesday, December 8, 2015, Roshan Wijesena <ros...@wso2.com> wrote: > >> Hi DAS team, >> >> I am trying to run the sample [1]. Even though there are no errors on the >> console, I could not see the data partially. See the screen shot. any idea >> why this is happening? >> >> [1] >> https://docs.wso2.com/display/DAS300/Sending+Notifications+Through+Published+Events+Using+Spark >> >> -- >> Roshan Wijesena. >> Senior Software Engineer-WSO2 Inc. >> Mobile: *+94719154640 <%2B94719154640>* >> Email: ros...@wso2.com >> *WSO2, Inc. :** wso2.com <http://wso2.com/>* >> lean.enterprise.middleware. >> > > > -- > Thanks & Regards, > > Inosh Goonewardena > Associate Technical Lead- WSO2 Inc. > Mobile: +94779966317 > > -- Roshan Wijesena. Senior Software Engineer-WSO2 Inc. Mobile: *+94719154640* Email: ros...@wso2.com *WSO2, Inc. :** wso2.com <http://wso2.com/>* lean.enterprise.middleware.
product_stream_1.0.0.json
Description: application/json
<?xml version="1.0" encoding="UTF-8" standalone="yes"?><EventStoreConfiguration><TableSchema><ColumnDefinition><Name>product-name</Name><EnableIndexing>true</EnableIndexing><IsPrimaryKey>true</IsPrimaryKey><EnableScoreParam>false</EnableScoreParam><Type>STRING</Type></ColumnDefinition><ColumnDefinition><Name>quantity</Name><EnableIndexing>true</EnableIndexing><IsPrimaryKey>false</IsPrimaryKey><EnableScoreParam>false</EnableScoreParam><Type>INTEGER</Type></ColumnDefinition></TableSchema><Source><StreamId>product_stream:1.0.0</StreamId></Source><RecordStoreName>EVENT_STORE</RecordStoreName></EventStoreConfiguration>
<?xml version="1.0" encoding="UTF-8"?><streamConfiguration type="csv"><file>footwear.csv</file><streamID>product_stream:1.0.0</streamID><separateChar>,</separateChar><delayBetweenEventsInMilies>1000</delayBetweenEventsInMilies></streamConfiguration>
Nike,7 Adidas,3 Puma,2 Bettans,0
_______________________________________________ Dev mailing list Dev@wso2.org http://wso2.org/cgi-bin/mailman/listinfo/dev
