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

AcknowledgedResponse介绍

[英]Abstract class that allows to mark action responses that support acknowledgements. Facilitates consistency across different api.
[中]

代码示例

代码示例来源：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: org.elasticsearch/elasticsearch

@Override
  public AcknowledgedResponse newResponse() {
    return new AcknowledgedResponse();
  }
}

代码示例来源：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

@Override
public void readFrom(StreamInput in) throws IOException {
  if (in.getVersion().onOrAfter(Version.V_6_4_0)) {
    super.readFrom(in);
    state = ClusterState.readFrom(in, null);
    explanations = RoutingExplanations.readFrom(in);
  } else {
    state = ClusterState.readFrom(in, null);
    acknowledged = in.readBoolean();
    explanations = RoutingExplanations.readFrom(in);
  }
}

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

@Override
public void writeTo(StreamOutput out) throws IOException {
  if (out.getVersion().onOrAfter(Version.V_6_4_0)) {
    super.writeTo(out);
    Settings.writeSettingsToStream(transientSettings, out);
    Settings.writeSettingsToStream(persistentSettings, out);
  } else {
    Settings.writeSettingsToStream(transientSettings, out);
    Settings.writeSettingsToStream(persistentSettings, out);
    out.writeBoolean(acknowledged);
  }
}

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

@Override
public boolean equals(Object o) {
  if (super.equals(o)) {
    ShardsAcknowledgedResponse that = (ShardsAcknowledgedResponse) o;
    return shardsAcknowledged == that.shardsAcknowledged;
  }
  return false;
}

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

@Override
public void readFrom(StreamInput in) throws IOException {
  if (in.getVersion().onOrAfter(Version.V_6_4_0)) {
    super.readFrom(in);
    transientSettings = Settings.readSettingsFromStream(in);
    persistentSettings = Settings.readSettingsFromStream(in);
  } else {
    transientSettings = Settings.readSettingsFromStream(in);
    persistentSettings = Settings.readSettingsFromStream(in);
    acknowledged = in.readBoolean();
  }
}

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

@Override
public void writeTo(StreamOutput out) throws IOException {
  if (out.getVersion().onOrAfter(Version.V_6_4_0)) {
    super.writeTo(out);
    state.writeTo(out);
    RoutingExplanations.writeTo(explanations, out);
  } else {
    if (out.getVersion().onOrAfter(Version.V_6_3_0)) {
      state.writeTo(out);
    } else {
      ClusterModule.filterCustomsForPre63Clients(state).writeTo(out);
    }
    out.writeBoolean(acknowledged);
    RoutingExplanations.writeTo(explanations, out);
  }
}

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

@Override
public boolean equals(Object o) {
  if (super.equals(o)) {
    ClusterUpdateSettingsResponse that = (ClusterUpdateSettingsResponse) o;
    return Objects.equals(transientSettings, that.transientSettings) &&
        Objects.equals(persistentSettings, that.persistentSettings);
  }
  return false;
}

代码示例来源：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: org.apache.servicemix.bundles/org.apache.servicemix.bundles.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: com.strapdata.elasticsearch/elasticsearch

@Override
public void readFrom(StreamInput in) throws IOException {
  super.readFrom(in);
  readAcknowledged(in);
}

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

@Override
  public void writeTo(StreamOutput out) throws IOException {
    super.writeTo(out);
    writeAcknowledged(out);
  }
}

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

@Override
public AcknowledgedResponse newResponse() {
  return new AcknowledgedResponse();
}

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

@Override
public boolean equals(Object o) {
  if (super.equals(o)) {
    ShardsAcknowledgedResponse that = (ShardsAcknowledgedResponse) o;
    return shardsAcknowledged == that.shardsAcknowledged;
  }
  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: apache/servicemix-bundles

@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: com.strapdata.elasticsearch/elasticsearch

@Override
public void readFrom(StreamInput in) throws IOException {
  super.readFrom(in);
  readAcknowledged(in);
}

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

@Override
  public void writeTo(StreamOutput out) throws IOException {
    super.writeTo(out);
    writeAcknowledged(out);
  }
}

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

@Override
public AcknowledgedResponse newResponse() {
  return new AcknowledgedResponse();
}