Thanks Guozhang. +1 On Thu, 22 Feb 2018 at 23:44 Guozhang Wang <wangg...@gmail.com> wrote:
> Thanks Ted, have updated the wiki page. > > On Thu, Feb 22, 2018 at 1:48 PM, Ted Yu <yuzhih...@gmail.com> wrote: > > > +1 > > > > There were some typos: > > CachingWindowedStore -> CachingWindowStore > > RocksDBWindowedStore -> RocksDBWindowStore > > KStreamWindowedAggregate -> KStreamWindowAggregate > > KStreamWindowedReduce -> KStreamWindowReduce > > > > Cheers > > > > On Thu, Feb 22, 2018 at 1:34 PM, Guozhang Wang <wangg...@gmail.com> > wrote: > > > > > Hi all, > > > > > > I have submitted KIP-261 to add a new API for window stores in order to > > > optimize our current windowed aggregation implementations inside > Streams > > > DSL > > > : > > > > > > https://cwiki.apache.org/confluence/display/KAFKA/KIP- > > > 261%3A+Add+Single+Value+Fetch+in+Window+Stores > > > > > > This change would require people who have customized window store > > > implementations to make code changes as part of their upgrade path. > But I > > > think it is worth while given that the fraction of customized window > > store > > > should be very small. > > > > > > > > > Feedback and suggestions are welcome. > > > > > > Thanks, > > > -- Guozhang > > > > > > > > > -- > -- Guozhang >
