[Improvement-18056] Clean up unused methods and classes in the dolphinschudler-registry module (#18165)

Author: njnu-seafish

dolphinscheduler-registry/dolphinscheduler-registry-api/src/main/java/org/apache/dolphinscheduler/registry/api/ConnectStrategy.java

@@ -31,7 +31,6 @@
 import org.apache.commons.lang3.StringUtils;
 
 import java.io.IOException;
-import java.time.Duration;
 import java.util.ArrayList;
 import java.util.Collection;
 import java.util.Date;
@@ -42,7 +41,6 @@
 import java.util.Optional;
 import java.util.Set;
 
-import lombok.NonNull;
 import lombok.extern.slf4j.Slf4j;
 
 import org.springframework.stereotype.Component;
@@ -77,10 +75,6 @@ public boolean isConnected() {
 
     }
 
-    public void connectUntilTimeout(@NonNull Duration duration) throws RegistryException {
-        registry.connectUntilTimeout(duration);
-    }
-
     public List<Server> getServerList(RegistryNodeType registryNodeType) {
         Map<String, String> serverMaps = getServerMaps(registryNodeType);
 

dolphinscheduler-registry/dolphinscheduler-registry-api/src/main/java/org/apache/dolphinscheduler/registry/api/RegistryClient.java

@@ -19,11 +19,8 @@
 
 import org.apache.dolphinscheduler.plugin.registry.jdbc.mapper.JdbcRegistryDataMapper;
 import org.apache.dolphinscheduler.plugin.registry.jdbc.model.DO.JdbcRegistryData;
-import org.apache.dolphinscheduler.plugin.registry.jdbc.model.DTO.DataType;
 import org.apache.dolphinscheduler.plugin.registry.jdbc.model.DTO.JdbcRegistryDataDTO;
 
-import org.apache.commons.collections4.CollectionUtils;
-
 import java.util.List;
 import java.util.Optional;
 import java.util.stream.Collectors;
@@ -50,13 +47,6 @@ public Optional<JdbcRegistryDataDTO> selectByKey(String key) {
                 .map(JdbcRegistryDataDTO::fromJdbcRegistryData);
     }
 
-    public void deleteEphemeralDateByClientIds(List<Long> clientIds) {
-        if (CollectionUtils.isEmpty(clientIds)) {
-            return;
-        }
-        jdbcRegistryDataMapper.deleteByClientIds(clientIds, DataType.EPHEMERAL.name());
-    }
-
     public void deleteByKey(String key) {
         jdbcRegistryDataMapper.deleteByKey(key);
     }

dolphinscheduler-registry/dolphinscheduler-registry-plugins/dolphinscheduler-registry-jdbc/src/main/java/org/apache/dolphinscheduler/plugin/registry/jdbc/repository/JdbcRegistryDataRepository.java

@@ -23,8 +23,6 @@
 import org.apache.dolphinscheduler.plugin.registry.jdbc.model.DO.JdbcRegistryLock;
 import org.apache.dolphinscheduler.plugin.registry.jdbc.model.DTO.JdbcRegistryLockDTO;
 
-import org.apache.commons.collections4.CollectionUtils;
-
 import java.util.List;
 import java.util.stream.Collectors;
 
@@ -44,13 +42,6 @@ public List<JdbcRegistryLockDTO> queryAll() {
                 .collect(Collectors.toList());
     }
 
-    public void deleteByClientIds(List<Long> clientIds) {
-        if (CollectionUtils.isEmpty(clientIds)) {
-            return;
-        }
-        jdbcRegistryLockMapper.deleteByClientIds(clientIds);
-    }
-
     public void insert(JdbcRegistryLockDTO jdbcRegistryLock) {
         checkNotNull(jdbcRegistryLock);
         JdbcRegistryLock jdbcRegistryLockDO = JdbcRegistryLockDTO.toJdbcRegistryLock(jdbcRegistryLock);

dolphinscheduler-registry/dolphinscheduler-registry-plugins/dolphinscheduler-registry-jdbc/src/main/java/org/apache/dolphinscheduler/plugin/registry/jdbc/repository/JdbcRegistryLockRepository.java

@@ -61,8 +61,6 @@ public class JdbcRegistryServer implements IJdbcRegistryServer {
 
     private final JdbcRegistryProperties jdbcRegistryProperties;
 
-    private final JdbcRegistryDataRepository jdbcRegistryDataRepository;
-
     private final JdbcRegistryLockRepository jdbcRegistryLockRepository;
 
     private final JdbcRegistryClientRepository jdbcRegistryClientRepository;
@@ -88,7 +86,6 @@ public JdbcRegistryServer(JdbcRegistryDataRepository jdbcRegistryDataRepository,
                               JdbcRegistryDataChangeEventRepository jdbcRegistryDataChangeEventRepository,
                               JdbcRegistryProperties jdbcRegistryProperties,
                               TransactionTemplate transactionTemplate) {
-        this.jdbcRegistryDataRepository = checkNotNull(jdbcRegistryDataRepository);
         this.jdbcRegistryLockRepository = checkNotNull(jdbcRegistryLockRepository);
         this.jdbcRegistryClientRepository = checkNotNull(jdbcRegistryClientRepository);
         this.jdbcRegistryProperties = checkNotNull(jdbcRegistryProperties);