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

Requests.deleteRequest介绍

[英]Creates a delete request against a specific index. Note the DeleteRequest#type(String) and DeleteRequest#id(String) must be set.
[中]针对特定索引创建删除请求。注意，必须设置DeleteRequest#类型（字符串）和DeleteRequest#id（字符串）。

代码示例

代码示例来源：origin: richardwilly98/elasticsearch-river-mongodb

public void deleteBulkRequest(String id, String routing, String parent) {
  logger.trace("deleteBulkRequest - id: {} - index: {} - type: {} - routing: {} - parent: {}", id, index, type, routing, parent);
  bulkProcessor.add(deleteRequest(index).type(type).id(id).routing(routing).parent(parent));
  deletedDocuments.incrementAndGet();
}

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

return new Result(indexRequest, DocWriteResponse.Result.UPDATED, updatedSourceAsMap, updateSourceContentType);
case DELETE:
  DeleteRequest deleteRequest = Requests.deleteRequest(request.index())
      .type(request.type()).id(request.id()).routing(routing).parent(parent)
      .version(updateVersion).versionType(request.versionType()).waitForActiveShards(request.waitForActiveShards())

代码示例来源：origin: mariamhakobyan/elasticsearch-river-kafka

String id = (String)messageMap.get("id");
final DeleteRequest request = Requests.deleteRequest(riverConfig.getIndexName()).
    type(riverConfig.getTypeName()).
    id(id);

代码示例来源：origin: searchisko/elasticsearch-river-jira

@Override
public boolean deleteIssueDocument(BulkRequestBuilder esBulk, SearchHit documentToDelete) throws Exception {
  esBulk.add(deleteRequest(indexName).type(documentToDelete.getType()).id(documentToDelete.getId()));
  return issueTypeName.equals(documentToDelete.getType());
}

代码示例来源：origin: scharron/elasticsearch-river-mysql

bulk.add(deleteRequest(index).type(type).id(id).routing(route).parent(parent));
} else if (action.equals("update") || action.equals("insert")) {
  logger.info("INSERTING / UPDATING {}", id);

代码示例来源：origin: jprante/elasticsearch-transport-websocket

@Override
  public void handleRequest(final InteractiveRequest request, final InteractiveChannel channel) {
    String index = request.paramAsString("index");
    String type = request.paramAsString("type");
    String id = request.paramAsString("id");
    try {
      if (index == null) {
        channel.sendResponse(TYPE, new IllegalArgumentException("index is null"));
        return;
      }
      if (type == null) {
        channel.sendResponse(TYPE, new IllegalArgumentException("type is null"));
        return;
      }
      if (id == null) {
        channel.sendResponse(TYPE, new IllegalArgumentException("id is null"));
        return;
      }
      DeleteRequest deleteRequest = Requests.deleteRequest(index).type(type).id(id);
      add(deleteRequest, channel);
    } catch (IOException ex) {
      try {
        channel.sendResponse(TYPE, ex);
      } catch (IOException ex1) {
        logger.error("error while sending exception");
      }
    }
  }
}

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

return new Result(indexRequest, DocWriteResponse.Result.UPDATED, updatedSourceAsMap, updateSourceContentType);
case DELETE:
  DeleteRequest deleteRequest = Requests.deleteRequest(request.index())
      .type(request.type()).id(request.id()).routing(routing).parent(parent)
      .version(updateVersion).versionType(request.versionType()).waitForActiveShards(request.waitForActiveShards())

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

return new Result(indexRequest, DocWriteResponse.Result.UPDATED, updatedSourceAsMap, updateSourceContentType);
case DELETE:
  DeleteRequest deleteRequest = Requests.deleteRequest(request.index())
      .type(request.type()).id(request.id()).routing(routing).parent(parent)
      .version(updateVersion).versionType(request.versionType()).waitForActiveShards(request.waitForActiveShards())

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

return new Result(indexRequest, DocWriteResponse.Result.UPDATED, updatedSourceAsMap, updateSourceContentType);
} else if ("delete".equals(operation)) {
  DeleteRequest deleteRequest = Requests.deleteRequest(request.index()).type(request.type()).id(request.id()).routing(routing).parent(parent)
      .version(updateVersion).versionType(request.versionType())
      .waitForActiveShards(request.waitForActiveShards())

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

return new Result(indexRequest, Operation.INDEX, updatedSourceAsMap, updateSourceContentType);
} else if ("delete".equals(operation)) {
  DeleteRequest deleteRequest = Requests.deleteRequest(request.index()).type(request.type()).id(request.id()).routing(routing).parent(parent)
      .version(updateVersion).versionType(request.versionType())
      .consistencyLevel(request.consistencyLevel());