本文整理了Java中org.elasticsearch.client.RestClient.builder方法的一些代码示例，展示了RestClient.builder的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。RestClient.builder方法的具体详情如下：
包路径：org.elasticsearch.client.RestClient
类名称：RestClient
方法名：builder

RestClient.builder介绍

[英]Returns a new RestClientBuilder to help with RestClient creation. Creates a new builder instance and sets the nodes that the client will send requests to.

You can use this if you do not have metadata up front about the nodes. If you do, prefer #builder(Node...).
[中]返回一个新的RestClientBuilder，以帮助创建RestClient。创建一个新的生成器实例，并设置客户端将向其发送请求的节点。
如果事先没有关于节点的元数据，可以使用此选项。如果需要，请选择#生成器（节点…）。

代码示例

代码示例来源：origin: spring-projects/spring-data-elasticsearch

protected void buildClient() throws Exception {
  Assert.hasText(hosts, "[Assertion Failed] At least one host must be set.");
  ArrayList<HttpHost> httpHosts = new ArrayList<HttpHost>();
  for (String host : hosts.split(COMMA)) {
    URL hostUrl = new URL(host);
    httpHosts.add(new HttpHost(hostUrl.getHost(), hostUrl.getPort(), hostUrl.getProtocol()));
  }
  client = new RestHighLevelClient(RestClient.builder(httpHosts.toArray(new HttpHost[httpHosts.size()])));
}

代码示例来源：origin: apache/flink

@Override
public RestHighLevelClient createClient(Map<String, String> clientConfig) throws IOException {
  RestClientBuilder builder = RestClient.builder(httpHosts.toArray(new HttpHost[httpHosts.size()]));
  restClientFactory.configureRestClientBuilder(builder);
  RestHighLevelClient rhlClient = new RestHighLevelClient(builder);
  if (LOG.isInfoEnabled()) {
    LOG.info("Pinging Elasticsearch cluster via hosts {} ...", httpHosts);
  }
  if (!rhlClient.ping()) {
    throw new RuntimeException("There are no reachable Elasticsearch nodes!");
  }
  if (LOG.isInfoEnabled()) {
    LOG.info("Created Elasticsearch RestHighLevelClient connected to {}", httpHosts.toString());
  }
  return rhlClient;
}

代码示例来源：origin: jooby-project/jooby

@Override
public void configure(final Env env, final Config config, final Binder binder) {
 HttpHost[] httpHosts = Arrays.stream(hosts).map(HttpHost::create).toArray(HttpHost[]::new);
 RestClient restClient = RestClient.builder(httpHosts).build();
 binder.bind(RestClient.class).toInstance(restClient);
 env.onStop(restClient::close);
}

代码示例来源：origin: Netflix/conductor

@Override
public RestClient get() {
  return RestClient.builder(convertToHttpHosts(configuration.getURIs())).build();
}

代码示例来源：origin: spring-projects/spring-data-elasticsearch

RestClientBuilder builder = RestClient.builder(httpHosts);
HttpHeaders headers = clientConfiguration.getDefaultHeaders();

代码示例来源：origin: brianfrankcooper/YCSB

restClient = RestClient.builder(esHttpHosts.toArray(new HttpHost[esHttpHosts.size()])).build();

代码示例来源：origin: apache/incubator-gobblin

RestClientBuilder builder = RestClient.builder(httpHosts);

代码示例来源：origin: testcontainers/testcontainers-java

private RestClient getClient(ElasticsearchContainer container) {
  if (client == null) {
    final CredentialsProvider credentialsProvider = new BasicCredentialsProvider();
    credentialsProvider.setCredentials(AuthScope.ANY,
      new UsernamePasswordCredentials(ELASTICSEARCH_USERNAME, ELASTICSEARCH_PASSWORD));
    client = RestClient.builder(HttpHost.create(container.getHttpHostAddress()))
      .setHttpClientConfigCallback(httpClientBuilder -> httpClientBuilder.setDefaultCredentialsProvider(credentialsProvider))
      .build();
  }
  return client;
}

代码示例来源：origin: apache/nifi

RestClientBuilder builder = RestClient.builder(hh)
  .setHttpClientConfigCallback(httpClientBuilder -> {
    if (sslContext != null) {

代码示例来源：origin: apache/storm

/**
   * Creates a new {@link RestClient} using given {@link EsConfig}.
   *
   * @return {@link RestClient} for Elasticsearch connection
   */
  public RestClient construct() {
    RestClientBuilder builder = RestClient.builder(esConfig.getHttpHosts());
    if (esConfig.getMaxRetryTimeoutMillis() != null) {
      builder.setMaxRetryTimeoutMillis(esConfig.getMaxRetryTimeoutMillis());
    }
    if (esConfig.getDefaultHeaders() != null) {
      builder.setDefaultHeaders(esConfig.getDefaultHeaders());
    }
    if (esConfig.getFailureListener() != null) {
      builder.setFailureListener(esConfig.getFailureListener());
    }
    if (esConfig.getHttpClientConfigCallback() != null) {
      builder.setHttpClientConfigCallback(esConfig.getHttpClientConfigCallback());
    }
    if (esConfig.getRequestConfigCallback() != null) {
      builder.setRequestConfigCallback(esConfig.getRequestConfigCallback());
    }
    if (esConfig.getPathPrefix() != null) {
      builder.setPathPrefix(esConfig.getPathPrefix());
    }
    return builder.build();
  }
}

代码示例来源：origin: dadoonet/fscrawler

private static RestClientBuilder buildRestClient(Elasticsearch settings) {
  List<HttpHost> hosts = new ArrayList<>(settings.getNodes().size());
  settings.getNodes().forEach(node -> hosts.add(HttpHost.create(node.getDecodedUrl())));
  RestClientBuilder builder = RestClient.builder(hosts.toArray(new HttpHost[hosts.size()]));
  if (settings.getUsername() != null) {
    CredentialsProvider credentialsProvider = new BasicCredentialsProvider();
    credentialsProvider.setCredentials(AuthScope.ANY, new UsernamePasswordCredentials(settings.getUsername(), settings.getPassword()));
    builder.setHttpClientConfigCallback(httpClientBuilder ->
        httpClientBuilder.setDefaultCredentialsProvider(credentialsProvider));
  }
  return builder;
}

代码示例来源：origin: dadoonet/fscrawler

private static RestClientBuilder buildRestClient(Elasticsearch settings) {
  List<HttpHost> hosts = new ArrayList<>(settings.getNodes().size());
  settings.getNodes().forEach(node -> hosts.add(HttpHost.create(node.getDecodedUrl())));
  RestClientBuilder builder = RestClient.builder(hosts.toArray(new HttpHost[hosts.size()]));
  if (settings.getUsername() != null) {
    CredentialsProvider credentialsProvider = new BasicCredentialsProvider();
    credentialsProvider.setCredentials(AuthScope.ANY, new UsernamePasswordCredentials(settings.getUsername(), settings.getPassword()));
    builder.setHttpClientConfigCallback(httpClientBuilder ->
        httpClientBuilder.setDefaultCredentialsProvider(credentialsProvider));
  }
  return builder;
}

代码示例来源：origin: dadoonet/fscrawler

private static RestClientBuilder buildRestClient(Elasticsearch settings) {
  List<HttpHost> hosts = new ArrayList<>(settings.getNodes().size());
  settings.getNodes().forEach(node -> hosts.add(HttpHost.create(node.getDecodedUrl())));
  RestClientBuilder builder = RestClient.builder(hosts.toArray(new HttpHost[hosts.size()]));
  if (settings.getUsername() != null) {
    CredentialsProvider credentialsProvider = new BasicCredentialsProvider();
    credentialsProvider.setCredentials(AuthScope.ANY, new UsernamePasswordCredentials(settings.getUsername(), settings.getPassword()));
    builder.setHttpClientConfigCallback(httpClientBuilder ->
        httpClientBuilder.setDefaultCredentialsProvider(credentialsProvider));
  }
  return builder;
}

代码示例来源：origin: tomoya92/pybbs

@Override
public RestHighLevelClient instance() {
 if (this.client != null) return client;
 try {
  SystemConfig systemConfigHost = systemConfigService.selectByKey("elasticsearch_host");
  String host = systemConfigHost.getValue();
  SystemConfig systemConfigPort = systemConfigService.selectByKey("elasticsearch_port");
  String port = systemConfigPort.getValue();
  SystemConfig systemConfigName = systemConfigService.selectByKey("elasticsearch_index");
  name = systemConfigName.getValue();
  if (StringUtils.isEmpty(host) || StringUtils.isEmpty(port)) return null;
  client = new RestHighLevelClient(
    RestClient.builder(
      new HttpHost(host, Integer.parseInt(port), "http")));
  // 判断索引是否存在，不存在创建
  if (!this.existIndex()) this.createIndex("topic", topicMappingBuilder);
  return client;
 } catch (NumberFormatException e) {
  log.error(e.getMessage());
  return null;
 }
}

代码示例来源：origin: apache/metron

/**
 * Creates an Elasticsearch client from settings provided via the global config.
 *
 * @return new client
 */
public static ElasticsearchClient create(Map<String, Object> globalConfig) {
 ElasticsearchClientConfig esClientConfig = new ElasticsearchClientConfig(
   getEsSettings(globalConfig));
 HttpHost[] httpHosts = getHttpHosts(globalConfig, esClientConfig.getConnectionScheme());
 RestClientBuilder builder = RestClient.builder(httpHosts);
 builder.setRequestConfigCallback(reqConfigBuilder -> {
  // Modifies request config builder with connection and socket timeouts.
  // https://www.elastic.co/guide/en/elasticsearch/client/java-rest/5.6/_timeouts.html
  reqConfigBuilder.setConnectTimeout(esClientConfig.getConnectTimeoutMillis());
  reqConfigBuilder.setSocketTimeout(esClientConfig.getSocketTimeoutMillis());
  return reqConfigBuilder;
 });
 builder.setMaxRetryTimeoutMillis(esClientConfig.getMaxRetryTimeoutMillis());
 builder.setHttpClientConfigCallback(clientBuilder -> {
  clientBuilder.setDefaultIOReactorConfig(getIOReactorConfig(esClientConfig));
  clientBuilder.setDefaultCredentialsProvider(getCredentialsProvider(esClientConfig));
  clientBuilder.setSSLContext(getSSLContext(esClientConfig));
  return clientBuilder;
 });
 RestClient lowLevelClient = builder.build();
 RestHighLevelClient client = new RestHighLevelClient(lowLevelClient);
 return new ElasticsearchClient(lowLevelClient, client);
}

代码示例来源：origin: tmobile/pacbot

private RestClient getRestClient() {
  if (restClient == null) {
    restClient = RestClient.builder(new HttpHost(updateESHost, updateESPort)).build();
  }
  return restClient;
}

代码示例来源：origin: tmobile/pacbot

private RestClient getRestClient() {
  if (restClient == null) {
    restClient = RestClient.builder(new HttpHost(updateESHost, updateESPort)).build();
  }
  return restClient;
}

代码示例来源：origin: DTStack/flinkx

public static RestHighLevelClient getClient(String address) {
  List<HttpHost> httpHostList = new ArrayList<>();
  String[] addr = address.split(",");
  for(String add : addr) {
    String[] pair = add.split(":");
    TelnetUtil.telnet(pair[0], Integer.valueOf(pair[1]));
    httpHostList.add(new HttpHost(pair[0], Integer.valueOf(pair[1]), "http"));
  }
  RestHighLevelClient client = new RestHighLevelClient(
      RestClient.builder(httpHostList.toArray(new HttpHost[httpHostList.size()])));
  return client;
}

代码示例来源：origin: tmobile/pacbot

/**
 * Instantiates a new elastic search data publisher.
 */
public ElasticSearchDataPublisher() {
  restClient = RestClient.builder(new HttpHost(ESUtils.getESHost(), ESUtils.getESPort())).build();
  client = new RestHighLevelClient(restClient);
}

代码示例来源：origin: zeebe-io/zeebe

private RestHighLevelClient createClient() {
 final HttpHost httpHost = urlToHttpHost(configuration.url);
 // use single thread for rest client
 final RestClientBuilder builder =
   RestClient.builder(httpHost)
     .setHttpClientConfigCallback(
       httpClientBuilder ->
         httpClientBuilder.setDefaultIOReactorConfig(
           IOReactorConfig.custom().setIoThreadCount(1).build()));
 return new RestHighLevelClient(builder);
}