Skip to content

Commit

Permalink
KAFKA-14412: Decouple RocksDB access from CF (apache#15105)
Browse files Browse the repository at this point in the history
To support future use-cases that use different strategies for accessing
RocksDB, we need to de-couple the RocksDB access strategy from the
Column Family access strategy.

To do this, we now have two separate accessors:

  * `DBAccessor`: dictates how we access RocksDB. Currently only one
    strategy is supported: `DirectDBAccessor`, which access RocksDB
    directly, via the `RocksDB` class for all operations. In the future, a
    `BatchedDBAccessor` will be added, which enables transactions via
    `WriteBatch`.
  * `ColumnFamilyAccessor`: maps StateStore operations to operations on
    one or more column families. This is a rename of the old
    `RocksDBDBAccessor`.

Reviewers: Lucas Brutschy <[email protected]>
  • Loading branch information
nicktelford authored Jan 4, 2024
1 parent c078e51 commit 5bc3aa4
Show file tree
Hide file tree
Showing 3 changed files with 178 additions and 91 deletions.
2 changes: 1 addition & 1 deletion checkstyle/checkstyle.xml
Original file line number Diff line number Diff line change
Expand Up @@ -131,7 +131,7 @@

<module name="ClassFanOutComplexity">
<!-- default is 20 -->
<property name="max" value="50"/>
<property name="max" value="52"/>
</module>
<module name="CyclomaticComplexity">
<!-- default is 10-->
Expand Down
Loading

0 comments on commit 5bc3aa4

Please sign in to comment.