Commit ceec1c2
KAFKA-20132: Implement TimestampedKeyValueStoreWithHeaders (1/N) (apache#21444)
This PR extracts the `DualColumnFamilyAccessor` from
`RocksDBTimestampedStore` and generalizes it so it can be used by both
`RocksDBTimestampedStore` and headers-aware stores. It also adds
corresponding unit tests.
Reviewers: TengYao Chi <frankvicky@apache.org>, Matthias J. Sax
<matthias@confluent.io>
---------
Co-authored-by: TengYao Chi <kitingiao@gmail.com>1 parent 9a5f965 commit ceec1c2
3 files changed
Lines changed: 902 additions & 406 deletions
File tree
- streams/src
- main/java/org/apache/kafka/streams/state/internals
- test/java/org/apache/kafka/streams/state/internals
0 commit comments