+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 >
