Page History

...

This KIP would propose to add a single fetch API to the WindowedStoreWindowStore, and use that in the KStreamWindowedAggregate KStreamWindowAggregate / KStreamWindowedReduce KStreamWindowReduce operators.

ReadOnlyWindowStore interface

...

1. For all implementations of the WindowedStore, including CachingWindowedStoreCachingWindowStore, RocksDBWindowedStoreRocksDBWindowStore, etc, add the implementations of this API for a single value lookup accordingly.
2. In KStreamWindowedAggregate and KStreamWindowedReduce, replace the "fetch(K, long start, long to)" with this newly added API.

...