private void init()

in flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisStreamOptions.java [37:125]
87 lines of code
1 McCabe index (conditional complexity)

    private void init() {
        DorisOptions.Builder optionsBuilder =
                DorisOptions.builder()
                        .setFenodes(prop.getProperty(ConfigurationOptions.DORIS_FENODES))
                        .setUsername(prop.getProperty(ConfigurationOptions.DORIS_USER))
                        .setPassword(prop.getProperty(ConfigurationOptions.DORIS_PASSWORD))
                        .setTableIdentifier(
                                prop.getProperty(ConfigurationOptions.TABLE_IDENTIFIER));

        DorisReadOptions.Builder readOptionsBuilder =
                DorisReadOptions.builder()
                        .setDeserializeArrowAsync(
                                Boolean.valueOf(
                                        prop.getProperty(
                                                ConfigurationOptions.DORIS_DESERIALIZE_ARROW_ASYNC,
                                                ConfigurationOptions
                                                        .DORIS_DESERIALIZE_ARROW_ASYNC_DEFAULT
                                                        .toString())))
                        .setDeserializeQueueSize(
                                Integer.valueOf(
                                        prop.getProperty(
                                                ConfigurationOptions.DORIS_DESERIALIZE_QUEUE_SIZE,
                                                ConfigurationOptions
                                                        .DORIS_DESERIALIZE_QUEUE_SIZE_DEFAULT
                                                        .toString())))
                        .setExecMemLimit(
                                Long.valueOf(
                                        prop.getProperty(
                                                ConfigurationOptions.DORIS_EXEC_MEM_LIMIT,
                                                ConfigurationOptions.DORIS_EXEC_MEM_LIMIT_DEFAULT
                                                        .toString())))
                        .setFilterQuery(prop.getProperty(ConfigurationOptions.DORIS_FILTER_QUERY))
                        .setReadFields(prop.getProperty(ConfigurationOptions.DORIS_READ_FIELD))
                        .setRequestQueryTimeoutS(
                                Integer.valueOf(
                                        prop.getProperty(
                                                ConfigurationOptions.DORIS_REQUEST_QUERY_TIMEOUT_S,
                                                ConfigurationOptions
                                                        .DORIS_REQUEST_QUERY_TIMEOUT_S_DEFAULT
                                                        .toString())))
                        .setRequestBatchSize(
                                Integer.valueOf(
                                        prop.getProperty(
                                                ConfigurationOptions.DORIS_BATCH_SIZE,
                                                ConfigurationOptions.DORIS_BATCH_SIZE_DEFAULT
                                                        .toString())))
                        .setRequestConnectTimeoutMs(
                                Integer.valueOf(
                                        prop.getProperty(
                                                ConfigurationOptions
                                                        .DORIS_REQUEST_CONNECT_TIMEOUT_MS,
                                                ConfigurationOptions
                                                        .DORIS_REQUEST_CONNECT_TIMEOUT_MS_DEFAULT
                                                        .toString())))
                        .setRequestReadTimeoutMs(
                                Integer.valueOf(
                                        prop.getProperty(
                                                ConfigurationOptions.DORIS_REQUEST_READ_TIMEOUT_MS,
                                                ConfigurationOptions
                                                        .DORIS_REQUEST_READ_TIMEOUT_MS_DEFAULT
                                                        .toString())))
                        .setRequestRetries(
                                Integer.valueOf(
                                        prop.getProperty(
                                                ConfigurationOptions.DORIS_REQUEST_RETRIES,
                                                ConfigurationOptions.DORIS_REQUEST_RETRIES_DEFAULT
                                                        .toString())))
                        .setRequestTabletSize(
                                Integer.valueOf(
                                        prop.getProperty(
                                                ConfigurationOptions.DORIS_TABLET_SIZE,
                                                ConfigurationOptions.DORIS_TABLET_SIZE_DEFAULT
                                                        .toString())))
                        .setUseFlightSql(
                                Boolean.valueOf(
                                        prop.getProperty(
                                                ConfigurationOptions.USE_FLIGHT_SQL,
                                                ConfigurationOptions.USE_FLIGHT_SQL_DEFAULT
                                                        .toString())))
                        .setFlightSqlPort(
                                Integer.valueOf(
                                        prop.getProperty(
                                                ConfigurationOptions.FLIGHT_SQL_PORT,
                                                ConfigurationOptions.FLIGHT_SQL_PORT_DEFAULT
                                                        .toString())));

        this.options = optionsBuilder.build();
        this.readOptions = readOptionsBuilder.build();
    }