A few questions/comments. 1. What's streamTime passed to punctuate()? Is that just the current time? 2. Is punctuate() only called if schedule() is called? 3. The way the KeyValueStore is created seems a bit weird. Since this is part of the internal state managed by KafkaProcessorContext, it seems there should be an api to create the KeyValueStore from KafkaProcessorContext, instead of passing context to the constructor of KeyValueStore?
Thanks, Jun On Thu, Jul 23, 2015 at 5:59 PM, Guozhang Wang <wangg...@gmail.com> wrote: > Hi all, > > I just posted KIP-28: Add a transform client for data processing > < > https://cwiki.apache.org/confluence/display/KAFKA/KIP-28+-+Add+a+transform+client+for+data+processing > > > . > > The wiki page does not yet have the full design / implementation details, > and this email is to kick-off the conversation on whether we should add > this new client with the described motivations, and if yes what features / > functionalities should be included. > > Looking forward to your feedback! > > -- Guozhang >
