This is an automated email from the ASF dual-hosted git repository.
dockerzhang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-inlong.git.
from 8064fa3 [INLONG-3029][TubeMQ] Adjust the implementation classes under
the impl.bdbimpl package (#3030)
add a78a9a9 [INLONG-2844][TubeMQ] Implement the ZooKeeper-based metadata
Mapper class (#3034)
No new revisions were added by this update.
Summary of changes:
.../inlong/tubemq/corebase/TokenConstants.java | 1 +
.../zkimpl/TZKNodeKeys.java} | 16 +--
.../impl/zkimpl/ZKBrokerConfigMapperImpl.java | 127 ++++++++++++++++++++
.../impl/zkimpl/ZKClusterConfigMapperImpl.java | 128 +++++++++++++++++++++
.../impl/zkimpl/ZKConsumeCtrlMapperImpl.java | 123 ++++++++++++++++++++
.../impl/zkimpl/ZKGroupResCtrlMapperImpl.java | 126 ++++++++++++++++++++
.../impl/zkimpl/ZKTopicCtrlMapperImpl.java | 122 ++++++++++++++++++++
.../impl/zkimpl/ZKTopicDeployMapperImpl.java | 123 ++++++++++++++++++++
8 files changed, 759 insertions(+), 7 deletions(-)
copy
inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/metamanage/metastore/{dao/mapper/AbstractMapper.java
=> impl/zkimpl/TZKNodeKeys.java} (59%)
create mode 100644
inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/metamanage/metastore/impl/zkimpl/ZKBrokerConfigMapperImpl.java
create mode 100644
inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/metamanage/metastore/impl/zkimpl/ZKClusterConfigMapperImpl.java
create mode 100644
inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/metamanage/metastore/impl/zkimpl/ZKConsumeCtrlMapperImpl.java
create mode 100644
inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/metamanage/metastore/impl/zkimpl/ZKGroupResCtrlMapperImpl.java
create mode 100644
inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/metamanage/metastore/impl/zkimpl/ZKTopicCtrlMapperImpl.java
create mode 100644
inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/metamanage/metastore/impl/zkimpl/ZKTopicDeployMapperImpl.java
