flink-connector-elasticsearch6/src/main/java/org/apache/flink/connector/elasticsearch/Elasticsearch6ApiCallBridge.java [46:56]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    @Override
    public RestHighLevelClient createClient(
            NetworkClientConfig networkClientConfig, List<HttpHost> hosts) {
        return new RestHighLevelClient(
                RestClientUtils.configureRestClientBuilder(
                        RestClient.builder(hosts.toArray(new HttpHost[0])), networkClientConfig));
    }

    @Override
    public Tuple2<String, String[]> search(RestHighLevelClient client, SearchRequest searchRequest)
            throws IOException {
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



flink-connector-elasticsearch7/src/main/java/org/apache/flink/connector/elasticsearch/Elasticsearch7ApiCallBridge.java [47:57]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    @Override
    public RestHighLevelClient createClient(
            NetworkClientConfig networkClientConfig, List<HttpHost> hosts) {
        return new RestHighLevelClient(
                RestClientUtils.configureRestClientBuilder(
                        RestClient.builder(hosts.toArray(new HttpHost[0])), networkClientConfig));
    }

    @Override
    public Tuple2<String, String[]> search(RestHighLevelClient client, SearchRequest searchRequest)
            throws IOException {
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -