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

AcknowledgedResponse.isAcknowledged介绍

[英]Returns whether the response is acknowledged or not
[中]返回响应是否已确认

代码示例

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

@Override
public boolean deleteIndex(String indexName) {
  Assert.notNull(indexName, "No index defined for delete operation");
  if (indexExists(indexName)) {
    DeleteIndexRequest request = new DeleteIndexRequest(indexName);
    try {
      return client.indices().delete(request).isAcknowledged();
    } catch (IOException e) {
      throw new ElasticsearchException("Error while deleting index request: " + request.toString(), e);
    }
  }
  return false;
}

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

@Override
public Boolean removeAlias(AliasQuery query) {
  Assert.notNull(query.getIndexName(), "No index defined for Alias");
  Assert.notNull(query.getAliasName(), "No alias defined");
  IndicesAliasesRequest request = new IndicesAliasesRequest();
  AliasActions aliasAction = new AliasActions(AliasActions.Type.REMOVE);
  request.addAliasAction(aliasAction);
  try {
    return client.indices().updateAliases(request).isAcknowledged();
  } catch (IOException e) {
    throw new ElasticsearchException("failed to update aliases with request: " + request, e);
  }
}

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

@Override
public boolean putMapping(String indexName, String type, Object mapping) {
  Assert.notNull(indexName, "No index defined for putMapping()");
  Assert.notNull(type, "No type defined for putMapping()");
  PutMappingRequest request = new PutMappingRequest(indexName).type(type);
  if (mapping instanceof String) {
    request.source(String.valueOf(mapping), XContentType.JSON);
  } else if (mapping instanceof Map) {
    request.source((Map) mapping);
  } else if (mapping instanceof XContentBuilder) {
    request.source((XContentBuilder) mapping);
  }
  try {
    return client.indices().putMapping(request).isAcknowledged();
  } catch (IOException e) {
    throw new ElasticsearchException("Failed to put mapping for " + indexName, e);
  }
}

代码示例来源：origin: floragunncom/search-guard

final AcknowledgedResponse response = tc.admin().indices().updateSettings((new UpdateSettingsRequest(index).settings(indexSettings))).actionGet();
System.out.println("Reload config on all nodes");
System.out.println("Update number of replicas to "+(updateSettings) +" with result: "+response.isAcknowledged());
System.exit(response.isAcknowledged()?0:-1);
System.out.println("Reload config on all nodes");
System.out.println("Auto-expand replicas "+(replicaAutoExpand?"enabled":"disabled"));
System.exit(response.isAcknowledged()?0:-1);
  success = tc.admin().indices().delete(new DeleteIndexRequest(index)).actionGet().isAcknowledged();
  System.out.print("Deleted index '"+index+"'");
} else {

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

@Override
public Boolean addAlias(AliasQuery query) {
  Assert.notNull(query.getIndexName(), "No index defined for Alias");
  Assert.notNull(query.getAliasName(), "No alias defined");
  final IndicesAliasesRequest.AliasActions aliasAction = IndicesAliasesRequest.AliasActions.add()
      .alias(query.getAliasName()).index(query.getIndexName());
  if (query.getFilterBuilder() != null) {
    aliasAction.filter(query.getFilterBuilder());
  } else if (query.getFilter() != null) {
    aliasAction.filter(query.getFilter());
  } else if (hasText(query.getRouting())) {
    aliasAction.routing(query.getRouting());
  } else if (hasText(query.getSearchRouting())) {
    aliasAction.searchRouting(query.getSearchRouting());
  } else if (hasText(query.getIndexRouting())) {
    aliasAction.indexRouting(query.getIndexRouting());
  }
  IndicesAliasesRequest request = new IndicesAliasesRequest();
  request.addAliasAction(aliasAction);
  try {
    return client.indices().updateAliases(request).isAcknowledged();
  } catch (IOException e) {
    throw new ElasticsearchException("failed to update aliases with request: " + request, e);
  }
}

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

@Override
public boolean equals(Object o) {
  if (this == o) {
    return true;
  }
  if (o == null || getClass() != o.getClass()) {
    return false;
  }
  AcknowledgedResponse that = (AcknowledgedResponse) o;
  return isAcknowledged() == that.isAcknowledged();
}

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

@Override
  public int hashCode() {
    return Objects.hash(isAcknowledged());
  }
}

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

@Override
public void onResponse(AcknowledgedResponse response) {
  if (response.isAcknowledged() == false) {
    anyUpgradeFailed.set(true);
    logger.warn("Error deleting template [{}], request was not acknowledged", template);
  }
  tryFinishUpgrade(anyUpgradeFailed);
}

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

@Override
public void onResponse(AcknowledgedResponse response) {
  if (response.isAcknowledged() == false) {
    anyUpgradeFailed.set(true);
    logger.warn("Error updating template [{}], request was not acknowledged", change.getKey());
  }
  tryFinishUpgrade(anyUpgradeFailed);
}

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

@Override
public final XContentBuilder toXContent(XContentBuilder builder, Params params) throws IOException {
  builder.startObject();
  builder.field(ACKNOWLEDGED.getPreferredName(), isAcknowledged());
  addCustomFields(builder, params);
  builder.endObject();
  return builder;
}

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

/**
   * Update mappings synchronously on the master node, waiting for at most
   * {@code timeout}. When this method returns successfully mappings have
   * been applied to the master node and propagated to data nodes.
   */
  public void updateMappingOnMaster(Index index, String type, Mapping mappingUpdate, TimeValue timeout) {
    if (updateMappingRequest(index, type, mappingUpdate, timeout).get().isAcknowledged() == false) {
      throw new ElasticsearchTimeoutException("Failed to acknowledge mapping update within [" + timeout + "]");
    }
  }
}

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

public boolean deleteIndex() {
 try {
  if (this.instance() == null) return false;
  DeleteIndexRequest request = new DeleteIndexRequest(name);
  request.indicesOptions(IndicesOptions.LENIENT_EXPAND_OPEN);
  AcknowledgedResponse response = client.indices().delete(request, RequestOptions.DEFAULT);
  return response.isAcknowledged();
 } catch (IOException e) {
  log.error(e.getMessage());
  return false;
 }
}

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

@Override
public boolean equals(Object o) {
  if (this == o) {
    return true;
  }
  if (o == null || getClass() != o.getClass()) {
    return false;
  }
  AcknowledgedResponse that = (AcknowledgedResponse) o;
  return isAcknowledged() == that.isAcknowledged();
}

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

@Override
public void onResponse(AcknowledgedResponse response) {
  if (response.isAcknowledged() == false) {
    anyUpgradeFailed.set(true);
    logger.warn("Error updating template [{}], request was not acknowledged", change.getKey());
  }
  tryFinishUpgrade(anyUpgradeFailed);
}

代码示例来源：origin: org.eclipse.rdf4j/rdf4j-sail-elasticsearch

private static void doAcknowledgedRequest(
    ActionRequestBuilder<?, ? extends AcknowledgedResponse, ?> request)
  throws IOException
{
  boolean ok = request.execute().actionGet().isAcknowledged();
  if (!ok) {
    throw new IOException("Request not acknowledged: " + request.get().getClass().getName());
  }
}

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

@Override
public RestResponse buildResponse(T response, XContentBuilder builder) throws Exception {
  builder.startObject()
      .field(Fields.ACKNOWLEDGED, response.isAcknowledged());
  addCustomFields(builder, response);
  builder.endObject();
  return new BytesRestResponse(OK, builder);
}

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

@Override
public RestResponse buildResponse(T response, XContentBuilder builder) throws Exception {
  // TODO - Once AcknowledgedResponse implements ToXContent, this method should be updated to call response.toXContent.
  builder.startObject()
      .field(Fields.ACKNOWLEDGED, response.isAcknowledged());
  addCustomFields(builder, response);
  builder.endObject();
  return new BytesRestResponse(OK, builder);
}

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

/** @return true if request was acknowledged */
private boolean putIndexTemplate(final PutIndexTemplateRequest putIndexTemplateRequest) {
 try {
  return client
    .indices()
    .putTemplate(putIndexTemplateRequest, RequestOptions.DEFAULT)
    .isAcknowledged();
 } catch (IOException e) {
  throw new ElasticsearchExporterException("Failed to put index template", e);
 }
}

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

/**
   * Update mappings synchronously on the master node, waiting for at most
   * {@code timeout}. When this method returns successfully mappings have
   * been applied to the master node and propagated to data nodes.
   */
  public void updateMappingOnMaster(Index index, String type, Mapping mappingUpdate, TimeValue timeout) {
    if (updateMappingRequest(index, type, mappingUpdate, timeout).get().isAcknowledged() == false) {
      throw new ElasticsearchTimeoutException("Failed to acknowledge mapping update within [" + timeout + "]");
    }
  }
}

代码示例来源：origin: codelibs/elasticsearch-cluster-runner

public AcknowledgedResponse updateAlias(
    final BuilderCallback<IndicesAliasesRequestBuilder> builder) {
  final AcknowledgedResponse actionGet = builder
      .apply(client().admin().indices().prepareAliases()).execute()
      .actionGet();
  if (!actionGet.isAcknowledged()) {
    onFailure("Failed to update aliases.", actionGet);
  }
  return actionGet;
}