private static void genClusterPayload()

in bigtop-manager-server/src/main/java/org/apache/bigtop/manager/server/command/helper/JobCacheHelper.java [129:164]

• 30 lines of code
• 3 McCabe index (conditional complexity)

    private static void genClusterPayload(JobCachePayload payload, Long clusterId) {
        if (Objects.equals(payload.getClusterId(), clusterId)) {
            return;
        }

        ClusterPO clusterPO = clusterDao.findById(clusterId);
        List<ToolPO> toolPOList = toolDao.findAll();

        ClusterInfo clusterInfo = new ClusterInfo();
        clusterInfo.setName(clusterPO.getName());
        clusterInfo.setUserGroup(clusterPO.getUserGroup());
        clusterInfo.setRootDir(clusterPO.getRootDir());

        List<ToolInfo> toolInfoList = new ArrayList<>();
        for (ToolPO toolPO : toolPOList) {
            ToolInfo toolInfo = new ToolInfo();
            toolInfo.setName(toolPO.getName());
            toolInfo.setBaseUrl(toolPO.getBaseUrl());
            toolInfo.setPkgName(toolPO.getPkgName());
            toolInfo.setArch(toolPO.getArch());
            toolInfo.setChecksum(toolPO.getChecksum());
            toolInfoList.add(toolInfo);
        }
        clusterInfo.setTools(toolInfoList);

        Map<String, Map<String, String>> serviceConfigMap = payload.getConfigurations();
        serviceConfigMap.putAll(getServiceConfigMap(clusterId));

        Map<String, List<String>> componentHostMap = payload.getComponentHosts();
        componentHostMap.putAll(getComponentHostMap(clusterId));

        payload.setClusterId(clusterId);
        payload.setClusterInfo(clusterInfo);
        payload.setConfigurations(serviceConfigMap);
        payload.setComponentHosts(componentHostMap);
    }