public static Schema getSchema()

in src/main/java/org/apache/doris/kafka/connector/service/RestService.java [313:329]

• 17 lines of code
• 2 McCabe index (conditional complexity)

    public static Schema getSchema(
            DorisOptions dorisOptions, String db, String table, Logger logger) {
        logger.trace("start get {}.{} schema from doris.", db, table);
        Object responseData = null;
        try {
            String tableSchemaUri =
                    String.format(TABLE_SCHEMA_API, dorisOptions.getHttpUrl(), db, table);
            HttpGet httpGet = new HttpGet(tableSchemaUri);
            httpGet.setHeader(HttpHeaders.AUTHORIZATION, authHeader(dorisOptions));
            Map<String, Object> responseMap = handleResponse(httpGet, logger);
            responseData = responseMap.get("data");
            String schemaStr = OBJECT_MAPPER.writeValueAsString(responseData);
            return OBJECT_MAPPER.readValue(schemaStr, Schema.class);
        } catch (JsonProcessingException | IllegalArgumentException e) {
            throw new SchemaChangeException("can not parse response schema " + responseData, e);
        }
    }