Re: HDHT operator

2016-09-12 Thread Bhupesh Chawda
Hi Naresh, You can also have a look at the managed state which is also a persistent bucketing system supporting asynchronous reads. https://github.com/apache/apex-malhar/tree/master/library/src/main/java/org/apache/apex/malhar/lib/state/managed See

Re: SortedWordCount application error

2016-09-12 Thread Sanal Vasudevan
Hi, I also double checked that the following jersey jars are present in hadoop FS. /user/sanav/datatorrent/apps/application_1473738786558_0001 - jersey-servlet-1.13.jar - jersey-server-1.13.jar - jersey-core-1.9.jar Thanks Sanal On Tue, Sep 13, 2016 at 1:48 PM, Sanal Vasudevan

Re: SortedWordCount application error

2016-09-12 Thread Sanal Vasudevan
Hi, Please find attached the pom.xml file. I added the following to resolve build issue. org.codehaus.jettison jettison 1.3.8 It is a single-node setup. Haddop Version:2.7.2, rb165c4fe8a74265c792ce23f546c64604acf0e41 Yes I have used the apex command to lauch the apa file. Thanks Sanal

Re: HDHT operator

2016-09-12 Thread Thomas Weise
That documentation is not for Malhar. You find the user documentation for Apex here: http://apex.apache.org/docs.html See links on top. So you want to enrich the data after it was emitted from the window? On Mon, Sep 12, 2016 at 6:41 PM, Naresh Guntupalli < naresh.guntupa...@gmail.com>

Re: SortedWordCount application error

2016-09-12 Thread Munagala Ramanath
Looks like this happens if jersey-server is not present (e.g. http://stackoverflow.com/questions/8662919/jersey-no-webapplication-provider-is-present-when-jersey-json-dependency-added ) Have you made any changes to the pom.xml ? If so, can you post it here ? Also, can you tell us a bit more