Re: Review Request 53297: Initial version of adding metrics into samza rest.

2016-11-05 Thread Jake Maes
> On Nov. 5, 2016, 6:47 p.m., Jake Maes wrote: > > samza-rest/src/main/java/org/apache/samza/rest/SamzaRestService.java, line > > 75 > > > > > > I don't think the MetricsConfig constructure takes a subset. > >

Re: Review Request 53297: Initial version of adding metrics into samza rest.

2016-11-05 Thread Jake Maes
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/53297/#review155061 ---

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

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