private HttpPut getHttpPut()

in spark-doris-connector/src/main/java/org/apache/doris/spark/load/DorisStreamLoad.java [137:156]

• 20 lines of code
• 5 McCabe index (conditional complexity)

    private HttpPut getHttpPut(String label, String loadUrlStr, Boolean enable2PC) {
        HttpPut httpPut = new HttpPut(loadUrlStr);
        httpPut.setHeader(HttpHeaders.AUTHORIZATION, "Basic " + authEncoded);
        httpPut.setHeader(HttpHeaders.EXPECT, "100-continue");
        httpPut.setHeader(HttpHeaders.CONTENT_TYPE, "text/plain; charset=UTF-8");
        httpPut.setHeader("label", label);
        if (StringUtils.isNotBlank(columns)) {
            httpPut.setHeader("columns", columns);
        }
        if (StringUtils.isNotBlank(maxFilterRatio)) {
            httpPut.setHeader("max_filter_ratio", maxFilterRatio);
        }
        if (enable2PC) {
            httpPut.setHeader("two_phase_commit", "true");
        }
        if (MapUtils.isNotEmpty(streamLoadProp)) {
            streamLoadProp.forEach(httpPut::setHeader);
        }
        return httpPut;
    }