org.elasticsearch.client.IndicesAdminClient.close()方法的使用及代码示例

x33g5p2x  于2022-01-20 转载在 其他  
字(5.0k)|赞(0)|评价(0)|浏览(161)

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

IndicesAdminClient.close介绍

[英]Closes an index based on the index name.
[中]根据索引名称关闭索引。

代码示例

代码示例来源:origin: org.elasticsearch/elasticsearch

@Override
public RestChannelConsumer prepareRequest(final RestRequest request, final NodeClient client) throws IOException {
  CloseIndexRequest closeIndexRequest = new CloseIndexRequest(Strings.splitStringByCommaToArray(request.param("index")));
  closeIndexRequest.masterNodeTimeout(request.paramAsTime("master_timeout", closeIndexRequest.masterNodeTimeout()));
  closeIndexRequest.timeout(request.paramAsTime("timeout", closeIndexRequest.timeout()));
  closeIndexRequest.indicesOptions(IndicesOptions.fromRequest(request, closeIndexRequest.indicesOptions()));
  return channel -> client.admin().indices().close(closeIndexRequest, new RestToXContentListener<>(channel));
}

代码示例来源:origin: javanna/elasticshell

@Override
protected ActionFuture<CloseIndexResponse> doExecute(CloseIndexRequest request) {
  return client.admin().indices().close(request);
}

代码示例来源:origin: ezbz/projectx

@Override
 public ActionFuture<CloseIndexResponse> execute(final IndicesAdminClient admin) {
  return admin.close(Requests.closeIndexRequest(indexName));
 }
});

代码示例来源:origin: karussell/elasticsearch-rollindex

public void closeIndex(String indexName) {
  client.admin().indices().close(new CloseIndexRequest(indexName)).actionGet();
}

代码示例来源:origin: harbby/presto-connectors

@Override
  public void handleRequest(final RestRequest request, final RestChannel channel, final Client client) {
    CloseIndexRequest closeIndexRequest = new CloseIndexRequest(Strings.splitStringByCommaToArray(request.param("index")));
    closeIndexRequest.masterNodeTimeout(request.paramAsTime("master_timeout", closeIndexRequest.masterNodeTimeout()));
    closeIndexRequest.timeout(request.paramAsTime("timeout", closeIndexRequest.timeout()));
    closeIndexRequest.indicesOptions(IndicesOptions.fromRequest(request, closeIndexRequest.indicesOptions()));
    client.admin().indices().close(closeIndexRequest, new AcknowledgedRestListener<CloseIndexResponse>(channel));
  }
}

代码示例来源:origin: jboss-fuse/fabric8

String[] indices = toClose.toArray(new String[toClose.size()]);
CloseIndexRequest req = indicesAdminClient.prepareClose(indices).request();
indicesAdminClient.close(req).actionGet();

代码示例来源:origin: org.apache.servicemix.bundles/org.apache.servicemix.bundles.elasticsearch

@Override
public RestChannelConsumer prepareRequest(final RestRequest request, final NodeClient client) throws IOException {
  CloseIndexRequest closeIndexRequest = new CloseIndexRequest(Strings.splitStringByCommaToArray(request.param("index")));
  closeIndexRequest.masterNodeTimeout(request.paramAsTime("master_timeout", closeIndexRequest.masterNodeTimeout()));
  closeIndexRequest.timeout(request.paramAsTime("timeout", closeIndexRequest.timeout()));
  closeIndexRequest.indicesOptions(IndicesOptions.fromRequest(request, closeIndexRequest.indicesOptions()));
  return channel -> client.admin().indices().close(closeIndexRequest, new RestToXContentListener<>(channel));
}

代码示例来源:origin: com.strapdata.elasticsearch/elasticsearch

@Override
public RestChannelConsumer prepareRequest(final RestRequest request, final NodeClient client) throws IOException {
  CloseIndexRequest closeIndexRequest = new CloseIndexRequest(Strings.splitStringByCommaToArray(request.param("index")));
  closeIndexRequest.masterNodeTimeout(request.paramAsTime("master_timeout", closeIndexRequest.masterNodeTimeout()));
  closeIndexRequest.timeout(request.paramAsTime("timeout", closeIndexRequest.timeout()));
  closeIndexRequest.indicesOptions(IndicesOptions.fromRequest(request, closeIndexRequest.indicesOptions()));
  return channel -> client.admin().indices().close(closeIndexRequest, new AcknowledgedRestListener<>(channel));
}

代码示例来源:origin: apache/servicemix-bundles

@Override
public RestChannelConsumer prepareRequest(final RestRequest request, final NodeClient client) throws IOException {
  CloseIndexRequest closeIndexRequest = new CloseIndexRequest(Strings.splitStringByCommaToArray(request.param("index")));
  closeIndexRequest.masterNodeTimeout(request.paramAsTime("master_timeout", closeIndexRequest.masterNodeTimeout()));
  closeIndexRequest.timeout(request.paramAsTime("timeout", closeIndexRequest.timeout()));
  closeIndexRequest.indicesOptions(IndicesOptions.fromRequest(request, closeIndexRequest.indicesOptions()));
  return channel -> client.admin().indices().close(closeIndexRequest, new RestToXContentListener<>(channel));
}

代码示例来源:origin: io.fabric8.insight/insight-elasticsearch

String[] indices = toClose.toArray(new String[toClose.size()]);
CloseIndexRequest req = indicesAdminClient.prepareClose(indices).request();
indicesAdminClient.close(req).actionGet();

相关文章

微信公众号

最新文章

更多

IndicesAdminClient类方法