This is an automated email from the ASF dual-hosted git repository.
mmerli pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from 2209d2a PIP-45: Removed old ZK caches implementations (#13075)
add 0497f67 Transparent batching of ZK operations (#13043)
No new revisions were added by this update.
Summary of changes:
conf/broker.conf | 15 ++
conf/standalone.conf | 14 +
.../apache/pulsar/broker/ServiceConfiguration.java | 25 ++
.../org/apache/pulsar/broker/PulsarService.java | 8 +
.../broker/namespace/NamespaceServiceTest.java | 2 +-
.../pulsar/metadata/api/MetadataStoreConfig.java | 24 ++
.../metadata/impl/AbstractMetadataStore.java | 5 +-
.../pulsar/metadata/impl/RocksdbMetadataStore.java | 20 +-
.../pulsar/metadata/impl/ZKMetadataStore.java | 282 +++++++++++++++------
.../batching/AbstractBatchedMetadataStore.java | 162 ++++++++++++
.../pulsar/metadata/impl/batching/MetadataOp.java | 32 ++-
.../pulsar/metadata/impl/batching/OpDelete.java | 23 +-
.../pulsar/metadata/impl/batching/OpGet.java | 23 +-
.../metadata/impl/batching/OpGetChildren.java | 24 +-
.../pulsar/metadata/impl/batching/OpPut.java | 32 ++-
.../apache/pulsar/metadata/MetadataBenchmark.java | 155 +++++++++++
.../pulsar/metadata/MetadataStoreBatchingTest.java | 167 ++++++++++++
.../apache/pulsar/metadata/MetadataStoreTest.java | 2 +-
.../src/test/resources/findbugsExclude.xml | 4 +
.../java/org/apache/zookeeper/MockZooKeeper.java | 156 +++++++-----
20 files changed, 977 insertions(+), 198 deletions(-)
create mode 100644
pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/batching/AbstractBatchedMetadataStore.java
copy
pulsar-client/src/main/java/org/apache/pulsar/client/util/TimedCompletableFuture.java
=>
pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/batching/MetadataOp.java
(62%)
copy
pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerResponse.java
=>
pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/batching/OpDelete.java
(66%)
copy
pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerResponse.java
=>
pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/batching/OpGet.java
(66%)
copy
pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerResponse.java
=>
pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/batching/OpGetChildren.java
(65%)
copy
pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerResponse.java
=>
pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/batching/OpPut.java
(53%)
create mode 100644
pulsar-metadata/src/test/java/org/apache/pulsar/metadata/MetadataBenchmark.java
create mode 100644
pulsar-metadata/src/test/java/org/apache/pulsar/metadata/MetadataStoreBatchingTest.java
