You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@inlong.apache.org by do...@apache.org on 2022/03/10 02:02:32 UTC
[incubator-inlong] branch master updated (3e8aa0a -> 8064fa3)
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 3e8aa0a [INLONG-3027][Agent] Upgrade snappy version #3028
add 8064fa3 [INLONG-3029][TubeMQ] Adjust the implementation classes under the impl.bdbimpl package (#3030)
No new revisions were added by this update.
Summary of changes:
.../qltystats/DefaultBrokerRcvQltyStatsTest.java | 2 +-
.../offset/offsetstorage/ZkOffsetStorage.java | 39 +-
.../tubemq/server/common/zookeeper/ZKUtil.java | 23 +
.../metastore/BdbMetaStoreServiceImpl.java | 67 +--
.../metastore/dao/mapper/AbstractMapper.java | 3 +-
.../metastore/dao/mapper/BrokerConfigMapper.java | 62 ++-
.../metastore/dao/mapper/ClusterConfigMapper.java | 34 +-
...nsumeCtrlMapper.java => ConsumeCtrlMapper.java} | 9 +-
.../metastore/dao/mapper/GroupResCtrlMapper.java | 8 +-
.../metastore/dao/mapper/TopicCtrlMapper.java | 46 +-
.../metastore/dao/mapper/TopicDeployMapper.java | 36 +-
...perImpl.java => AbsBrokerConfigMapperImpl.java} | 233 +++-------
.../metastore/impl/AbsClusterConfigMapperImpl.java | 129 ++++++
...pperImpl.java => AbsConsumeCtrlMapperImpl.java} | 226 ++++-----
.../metastore/impl/AbsGroupResCtrlMapperImpl.java | 166 +++++++
.../metastore/impl/AbsTopicCtrlMapperImpl.java | 183 ++++++++
...pperImpl.java => AbsTopicDeployMapperImpl.java} | 335 ++++++--------
.../impl/bdbimpl/BdbBrokerConfigMapperImpl.java | 328 +------------
.../impl/bdbimpl/BdbClusterConfigMapperImpl.java | 130 +-----
.../impl/bdbimpl/BdbConsumeCtrlMapperImpl.java | 115 +++++
.../impl/bdbimpl/BdbGroupResCtrlMapperImpl.java | 157 +------
.../impl/bdbimpl/BdbTopicCtrlMapperImpl.java | 160 +------
.../impl/bdbimpl/BdbTopicDeployMapperImpl.java | 505 +--------------------
23 files changed, 1235 insertions(+), 1761 deletions(-)
rename inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/metamanage/metastore/dao/mapper/{GroupConsumeCtrlMapper.java => ConsumeCtrlMapper.java} (85%)
copy inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/metamanage/metastore/impl/{bdbimpl/BdbBrokerConfigMapperImpl.java => AbsBrokerConfigMapperImpl.java} (61%)
create mode 100644 inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/metamanage/metastore/impl/AbsClusterConfigMapperImpl.java
rename inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/metamanage/metastore/impl/{bdbimpl/BdbGroupConsumeCtrlMapperImpl.java => AbsConsumeCtrlMapperImpl.java} (68%)
create mode 100644 inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/metamanage/metastore/impl/AbsGroupResCtrlMapperImpl.java
create mode 100644 inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/metamanage/metastore/impl/AbsTopicCtrlMapperImpl.java
copy inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/metamanage/metastore/impl/{bdbimpl/BdbTopicDeployMapperImpl.java => AbsTopicDeployMapperImpl.java} (75%)
create mode 100644 inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/metamanage/metastore/impl/bdbimpl/BdbConsumeCtrlMapperImpl.java