Re: Using json serde with KeyValueStore

2016-11-08 Thread Jagadish Venkatraman
Good to know! Thanks, Jagadish On Tue, Nov 8, 2016 at 12:01 AM, Raj raj wrote: > Thanks! > > It is working as expected. > > raj > Thanks and Regards, > > Raj > > > On Sat, Nov 5, 2016 at 11:24 PM, Jagadish Venkatraman > wrote: > > You can write a small test job and verify this! I believe the s

Re: Using json serde with KeyValueStore

2016-11-08 Thread Raj raj
Thanks! It is working as expected. raj Thanks and Regards, Raj On Sat, Nov 5, 2016 at 11:24 PM, Jagadish Venkatraman wrote: > You can write a small test job and verify this! I believe the serde should > probably be able to serialize it correctly. > > You can define the KeyValueStore to be typ

Re: Using json serde with KeyValueStore

2016-11-05 Thread Jagadish Venkatraman
You can write a small test job and verify this! I believe the serde should probably be able to serialize it correctly. You can define the KeyValueStore to be typed as . - You can put the LHM directly into the store. - When you do a get on the store, you should probably be able re-cast it back to

Using json serde with KeyValueStore

2016-11-05 Thread Raj raj
Hi, I am starting out with Samza and my test program is able to read a message from Kafka. My next task is to write the message to KeyValue store. The message is formatted as Json in Kafka and I am using json serde as my msg serde. The incoming message is available to me as a LinkedHashMap when I