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

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

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

IndicesAdminClient.getTemplates介绍

[英]Gets index template.
[中]获取索引模板。

代码示例

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

@Override
public RestChannelConsumer prepareRequest(final RestRequest request, final NodeClient client) throws IOException {
  final String[] names = Strings.splitStringByCommaToArray(request.param("name"));
  final GetIndexTemplatesRequest getIndexTemplatesRequest = new GetIndexTemplatesRequest(names);
  getIndexTemplatesRequest.local(request.paramAsBoolean("local", getIndexTemplatesRequest.local()));
  getIndexTemplatesRequest.masterNodeTimeout(request.paramAsTime("master_timeout", getIndexTemplatesRequest.masterNodeTimeout()));
  final boolean implicitAll = getIndexTemplatesRequest.names().length == 0;
  return channel ->
      client.admin()
          .indices()
          .getTemplates(getIndexTemplatesRequest, new RestToXContentListener<GetIndexTemplatesResponse>(channel) {
            @Override
            protected RestStatus getStatus(final GetIndexTemplatesResponse response) {
              final boolean templateExists = response.getIndexTemplates().isEmpty() == false;
              return (templateExists || implicitAll) ? OK : NOT_FOUND;
            }
          });
}

代码示例来源:origin: dqeasycloud/easy-cloud

@Override
public List<IndexTemplateMetaData> getIndexTemplate(String templateName) {
  GetIndexTemplatesRequest request = new GetIndexTemplatesRequest(templateName);
  return getIndicesAdminClient().getTemplates(request).actionGet().getIndexTemplates();
}

代码示例来源:origin: io.zipkin.java/zipkin-storage-elasticsearch

@Override
public void ensureTemplate(String name, String indexTemplate) {
 GetIndexTemplatesResponse existingTemplates =
   client.admin().indices().getTemplates(new GetIndexTemplatesRequest(name))
     .actionGet();
 if (!existingTemplates.getIndexTemplates().isEmpty()) {
  return;
 }
 client.admin().indices().putTemplate(
   new PutIndexTemplateRequest(name).source(indexTemplate)).actionGet();
}

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

@Override
  public void handleRequest(final RestRequest request, final RestChannel channel, final Client client) {
    GetIndexTemplatesRequest getIndexTemplatesRequest = new GetIndexTemplatesRequest(request.param("name"));
    getIndexTemplatesRequest.local(request.paramAsBoolean("local", getIndexTemplatesRequest.local()));
    getIndexTemplatesRequest.masterNodeTimeout(request.paramAsTime("master_timeout", getIndexTemplatesRequest.masterNodeTimeout()));
    client.admin().indices().getTemplates(getIndexTemplatesRequest, new RestResponseListener<GetIndexTemplatesResponse>(channel) {
      @Override
      public RestResponse buildResponse(GetIndexTemplatesResponse getIndexTemplatesResponse) {
        boolean templateExists = getIndexTemplatesResponse.getIndexTemplates().size() > 0;
        if (templateExists) {
          return new BytesRestResponse(OK);
        } else {
          return new BytesRestResponse(NOT_FOUND);
        }
      }
    });
  }
}

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

client.admin().indices().getTemplates(getIndexTemplatesRequest, new RestBuilderListener<GetIndexTemplatesResponse>(channel) {
  @Override
  public RestResponse buildResponse(GetIndexTemplatesResponse getIndexTemplatesResponse, XContentBuilder builder) throws Exception {

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

@Override
public RestChannelConsumer prepareRequest(final RestRequest request, final NodeClient client) throws IOException {
  final String[] names = Strings.splitStringByCommaToArray(request.param("name"));
  final GetIndexTemplatesRequest getIndexTemplatesRequest = new GetIndexTemplatesRequest(names);
  getIndexTemplatesRequest.local(request.paramAsBoolean("local", getIndexTemplatesRequest.local()));
  getIndexTemplatesRequest.masterNodeTimeout(request.paramAsTime("master_timeout", getIndexTemplatesRequest.masterNodeTimeout()));
  final boolean implicitAll = getIndexTemplatesRequest.names().length == 0;
  return channel ->
      client.admin()
          .indices()
          .getTemplates(getIndexTemplatesRequest, new RestToXContentListener<GetIndexTemplatesResponse>(channel) {
            @Override
            protected RestStatus getStatus(final GetIndexTemplatesResponse response) {
              final boolean templateExists = response.getIndexTemplates().isEmpty() == false;
              return (templateExists || implicitAll) ? OK : NOT_FOUND;
            }
          });
}

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

@Override
public RestChannelConsumer prepareRequest(final RestRequest request, final NodeClient client) throws IOException {
  final String[] names = Strings.splitStringByCommaToArray(request.param("name"));
  final GetIndexTemplatesRequest getIndexTemplatesRequest = new GetIndexTemplatesRequest(names);
  getIndexTemplatesRequest.local(request.paramAsBoolean("local", getIndexTemplatesRequest.local()));
  getIndexTemplatesRequest.masterNodeTimeout(request.paramAsTime("master_timeout", getIndexTemplatesRequest.masterNodeTimeout()));
  final boolean implicitAll = getIndexTemplatesRequest.names().length == 0;
  return channel ->
      client.admin()
          .indices()
          .getTemplates(getIndexTemplatesRequest, new RestToXContentListener<GetIndexTemplatesResponse>(channel) {
            @Override
            protected RestStatus getStatus(final GetIndexTemplatesResponse response) {
              final boolean templateExists = response.getIndexTemplates().isEmpty() == false;
              return (templateExists || implicitAll) ? OK : NOT_FOUND;
            }
          });
}

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

@Override
public RestChannelConsumer prepareRequest(final RestRequest request, final NodeClient client) throws IOException {
  final String[] names = Strings.splitStringByCommaToArray(request.param("name"));
  final GetIndexTemplatesRequest getIndexTemplatesRequest = new GetIndexTemplatesRequest(names);
  getIndexTemplatesRequest.local(request.paramAsBoolean("local", getIndexTemplatesRequest.local()));
  getIndexTemplatesRequest.masterNodeTimeout(request.paramAsTime("master_timeout", getIndexTemplatesRequest.masterNodeTimeout()));
  final boolean implicitAll = getIndexTemplatesRequest.names().length == 0;
  return channel ->
      client.admin()
          .indices()
          .getTemplates(getIndexTemplatesRequest, new RestToXContentListener<GetIndexTemplatesResponse>(channel) {
            @Override
            protected RestStatus getStatus(final GetIndexTemplatesResponse response) {
              final boolean templateExists = response.getIndexTemplates().isEmpty() == false;
              return (templateExists || implicitAll) ? OK : NOT_FOUND;
            }
          });
}

相关文章

微信公众号

最新文章

更多

IndicesAdminClient类方法