static Params getJobParams()

in spark-job/src/main/java/org/apache/cassandra/diff/DiffJob.java [214:229]

• 13 lines of code
• 4 McCabe index (conditional complexity)

    static Params getJobParams(JobMetadataDb.JobLifeCycle job, JobConfiguration conf, List<KeyspaceTablePair> keyspaceTables) {
        if (conf.jobId().isPresent()) {
            final Params jobParams = job.getJobParams(conf.jobId().get());
            if(jobParams != null) {
                // When job_id is passed as a config property for the first time, we will not have metadata associated
                // with job_id in metadata table. we should return jobParams from the table only when jobParams is not null
                // Otherwise return new jobParams with provided job_id
               return jobParams;
            }
        }
        final UUID jobId = conf.jobId().isPresent() ? conf.jobId().get() : UUID.randomUUID();
        return new Params(jobId,
                          keyspaceTables,
                          conf.buckets(),
                          conf.splits());
    }