private RestClient getRestClient()

in flink-connector-elasticsearch8/src/main/java/org/apache/flink/connector/elasticsearch/sink/NetworkConfig.java [82:109]

23 lines of code
6 McCabe index (conditional complexity)


    private RestClient getRestClient() {
        RestClientBuilder restClientBuilder =
                RestClient.builder(hosts.toArray(new HttpHost[0]))
                        .setHttpClientConfigCallback(
                                httpClientBuilder -> {
                                    if (username != null && password != null) {
                                        httpClientBuilder.setDefaultCredentialsProvider(
                                                getCredentials());
                                    }

                                    if (sslContextSupplier != null) {
                                        httpClientBuilder.setSSLContext(sslContextSupplier.get());
                                    }

                                    if (sslHostnameVerifier != null) {
                                        httpClientBuilder.setSSLHostnameVerifier(
                                                sslHostnameVerifier.get());
                                    }

                                    return httpClientBuilder;
                                });

        if (headers != null) {
            restClientBuilder.setDefaultHeaders(headers.toArray(new Header[0]));
        }

        return restClientBuilder.build();
    }