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
