Re: [DISCUSSION] KIP-300: Add Windowed KTable API in StreamsBuilder

2018-10-19 Thread Matthias J. Sax
e side effect is that we bring `ChangeLoggingWindowBytesStore` >> public for unit test purpose. >> >> No need to mention this, because this class in in package "internals" >> and not part of public API. >> >> >> >> >> -Ma

Re: [DISCUSSION] KIP-300: Add Windowed KTable API in StreamsBuilder

2018-06-17 Thread Guozhang Wang
n the API format. Any feedback would be > appreciated, thank you! > > > > > > Boyang > > > > > > From: Liquan Pei > > Sent: Tuesday, May 22, 2018 4:29 AM > > To: dev@kafka.apache.org > > Subject: Re: [DISCUSSION] KIP-

Re: [DISCUSSION] KIP-300: Add Windowed KTable API in StreamsBuilder

2018-06-10 Thread Matthias J. Sax
I format. Any feedback would be appreciated, > thank you! > > > Boyang > > > From: Liquan Pei > Sent: Tuesday, May 22, 2018 4:29 AM > To: dev@kafka.apache.org > Subject: Re: [DISCUSSION] KIP-300: Add Windowed KTable API in StreamsBui

Re: [DISCUSSION] KIP-300: Add Windowed KTable API in StreamsBuilder

2018-05-24 Thread Boyang Chen
@kafka.apache.org Subject: Re: [DISCUSSION] KIP-300: Add Windowed KTable API in StreamsBuilder This KIP makes sharing a WindowedKTable among Kafka Stream jobs very easy. It would be nice to get this into trunk soon. Best, Liquan On Mon, May 21, 2018 at 12:25 PM, Boyang Chen wrote: > Hey all, > >

Re: [DISCUSSION] KIP-300: Add Windowed KTable API in StreamsBuilder

2018-05-21 Thread Liquan Pei
This KIP makes sharing a WindowedKTable among Kafka Stream jobs very easy. It would be nice to get this into trunk soon. Best, Liquan On Mon, May 21, 2018 at 12:25 PM, Boyang Chen wrote: > Hey all, > > > I would like to start a discussion thread on KIP 300, which introduces a > new API called w

[DISCUSSION] KIP-300: Add Windowed KTable API in StreamsBuilder

2018-05-21 Thread Boyang Chen
Hey all, I would like to start a discussion thread on KIP 300, which introduces a new API called windowedTable() in StreamsBuilder: https://cwiki.apache.org/confluence/display/KAFKA/KIP-300%3A+Add+Windowed+KTable+API+in+StreamsBuilder The pull request I'm working on is here: https://github.c