THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
- When a topology is initialized, we will register a (or multiple)
CachingKeyValueStore
(s) in StreamThread'sProcessorContext
. - After which, during processing, if it is necessary for finer granularity of stream time tracking, we will get a store from the ProcessorContext (which exists perhaps under the name "stream-time-table").
- We will the get the cache-backed store to update and keep track of timeuse that store as a field which can be easily accessed for stream time updates and queries.
- Suppressors and any other processors involving the calculation of grace periods would probably require a store should the user choose it. (whether each processor has an independent store or a shared one is still up for discussion.
...