THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
Table of Contents |
---|
Status
Current state: Under Discussion Adopted (2.0.0)
Discussion thread: TBD
JIRA:
Jira | ||||||||
---|---|---|---|---|---|---|---|---|
|
...
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
...
- For all implementations of the WindowedStore, including CachingWindowedStoreCachingWindowStore, RocksDBWindowedStoreRocksDBWindowStore, etc, add the implementations of this API for a single value lookup accordingly.
- In KStreamWindowedAggregate and KStreamWindowedReduce, replace the "fetch(K, long start, long to)" with this newly added API.
...