dongjinleekr commented on pull request #8117:
URL: https://github.com/apache/kafka/pull/8117#issuecomment-761972030
@vvcephei Here is the update. it now consists of 4 stages:
1. Separating instantiating/serde/metric related operations from
`InMemoryTimeOrderedKeyValueBuffer`.
For `InMemoryTimeOrderedKeyValueBuffer` needs record collector and its
changelog topic to implement `flush` operation, it has had a monolithic
architecture dislike to the other `StateStore`s. And this approach is also
making it difficult to support iterator.
As a laying the groundwork, `TimeOrderedKeyValueBufferBuilder`,
`MeteredTimeOrderedKeyValueBuffer` were separated into independent classes.
`InMemoryTimeOrderedKeyValueBuffer` now concentrates on `Bytes`, `byte[]`
operations without any serdes/metric operations.
2. By changing `InMemoryTimeOrderedKeyValueBuffer#index`'s type into
`NavigatableMap`, it now supports `all`, `range` operations.
3. KtableImpl takes queriableStoreName into account.
4. KtableImpl now makes queriable `TimeOrderedKeyValueBuffer` instance.
Please have a look when you are free.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
