public void processJobRelativeFiles()

in client/migrationx/migrationx-domain/migrationx-domain-azkaban/src/main/java/com/aliyun/dataworks/migrationx/domain/dataworks/azkaban/objects/HiveJob.java [51:89]

34 lines of code
18 McCabe index (conditional complexity)


    public void processJobRelativeFiles() {
        if (getRelatedFiles() == null) {
            setRelatedFiles(new ArrayList<>());
        }

        for (String query : queries) {
            String[] tokens = query.split(" ");
            if (tokens == null) {
                continue;
            }

            File jobFile = getJobFile();
            if (jobFile == null || !jobFile.exists()) {
                continue;
            }

            File dir = jobFile.getParentFile();
            for (String token : tokens) {
                File file = new File(dir, token);
                if (file.exists() && file.isFile() && !file.isHidden()) {
                    getRelatedFiles().add(file);
                }
            }
        }

        if (StringUtils.isNotBlank(getHiveScript())) {
            File file = new File(getJobFile().getParentFile(), getHiveScript());
            if (file.exists() && file.isFile() && !file.isHidden()) {
                getRelatedFiles().add(file);
            }
        }

        if (StringUtils.isNotBlank(getHiveQueryFile())) {
            File file = new File(getJobFile().getParentFile(), getHiveQueryFile());
            if (file.exists() && file.isFile() && !file.isHidden()) {
                getRelatedFiles().add(file);
            }
        }
    }