You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@bookkeeper.apache.org by hs...@apache.org on 2021/09/08 22:25:41 UTC

[bookkeeper] branch master updated (97818f5 -> c7236ad)

This is an automated email from the ASF dual-hosted git repository.

hsaputra pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/bookkeeper.git.


    from 97818f5  Add metrics and internal command for QueryAutoRecoveryStatus, including underReplicatedSize metrics,read/write latency, internal command for querying recovering ledgersInfo (#2768)
     add c7236ad  [STREAMSTORAGE] support an optional time to live (TTL) on a per table basis

No new revisions were added by this update.

Summary of changes:
 .../src/main/resources/LICENSE-all.bin.txt         |  6 +-
 .../src/main/resources/LICENSE-server.bin.txt      |  4 +-
 dependencies.gradle                                |  6 +-
 pom.xml                                            |  2 +-
 stream/proto/src/main/proto/kv.proto               |  2 +
 stream/proto/src/main/proto/kv_store.proto         |  2 +
 stream/proto/src/main/proto/stream.proto           |  1 +
 .../bookkeeper/statelib/api/StateStoreSpec.java    |  3 +
 .../statelib/impl/kv/RocksdbKVStore.java           | 54 +++++++++++++---
 .../bookkeeper/statelib/impl/mvcc/MVCCRecord.java  |  6 ++
 .../statelib/impl/mvcc/MVCCRecordCoder.java        |  4 ++
 .../statelib/impl/mvcc/MVCCStoreImpl.java          | 13 +++-
 .../stream/storage/impl/kv/TableStoreCache.java    |  4 +-
 .../impl/service/RangeStoreServiceImpl.java        | 71 +++++++++++-----------
 .../storage/impl/store/MVCCStoreFactory.java       |  6 +-
 .../storage/impl/store/MVCCStoreFactoryImpl.java   |  8 ++-
 .../impl/TestStorageContainerStoreImpl.java        |  3 +-
 .../storage/impl/kv/TableStoreCacheTest.java       | 19 +++---
 .../impl/service/RangeStoreServiceImplTest.java    | 30 ++++++---
 .../impl/store/MVCCStoreFactoryImplTest.java       |  2 +-
 .../integration/stream/TableClientSimpleTest.java  | 35 +++++++++++
 21 files changed, 198 insertions(+), 83 deletions(-)