public static JobConfigurationPOJO fromJobConfiguration()

in kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/internal/config/JobConfigurationPOJO.java [111:137]

27 lines of code
1 McCabe index (conditional complexity)


    public static JobConfigurationPOJO fromJobConfiguration(final JobConfiguration jobConfig) {
        JobConfigurationPOJO result = new JobConfigurationPOJO();
        result.setJobName(jobConfig.getJobName());
        result.setCron(jobConfig.getCron());
        result.setTimeZone(jobConfig.getTimeZone());
        result.setShardingTotalCount(jobConfig.getShardingTotalCount());
        result.setShardingItemParameters(jobConfig.getShardingItemParameters());
        result.setJobParameter(jobConfig.getJobParameter());
        result.setMonitorExecution(jobConfig.isMonitorExecution());
        result.setFailover(jobConfig.isFailover());
        result.setMisfire(jobConfig.isMisfire());
        result.setMaxTimeDiffSeconds(jobConfig.getMaxTimeDiffSeconds());
        result.setReconcileIntervalMinutes(jobConfig.getReconcileIntervalMinutes());
        result.setJobShardingStrategyType(jobConfig.getJobShardingStrategyType());
        result.setJobExecutorThreadPoolSizeProviderType(jobConfig.getJobExecutorThreadPoolSizeProviderType());
        result.setJobErrorHandlerType(jobConfig.getJobErrorHandlerType());
        result.setJobListenerTypes(jobConfig.getJobListenerTypes());
        jobConfig.getExtraConfigurations().stream()
                .map(each -> TypedSPILoader.getService(YamlConfigurationConverter.class, each.getClass()).convertToYamlConfiguration(each)).forEach(result.getJobExtraConfigurations()::add);
        result.setDescription(jobConfig.getDescription());
        result.setProps(jobConfig.getProps());
        result.setDisabled(jobConfig.isDisabled());
        result.setOverwrite(jobConfig.isOverwrite());
        result.setLabel(jobConfig.getLabel());
        result.setStaticSharding(jobConfig.isStaticSharding());
        return result;
    }