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

BulkRequest.add介绍

[英]Adds a list of requests to be executed. Either index or delete requests.
[中]添加要执行的请求列表。索引或删除请求。

代码示例

代码示例来源：origin: apache/flink

@Override
  public Object answer(InvocationOnMock invocationOnMock) throws Throwable {
    // intercept the request and add it to our mock bulk request
    nextBulkRequest.add((IndexRequest) invocationOnMock.getArgument(0));
    return null;
  }
});

代码示例来源：origin: apache/nifi

@Override
public DeleteOperationResponse deleteById(String index, String type, List<String> ids) throws IOException {
  BulkRequest bulk = new BulkRequest();
  for (int idx = 0; idx < ids.size(); idx++) {
    DeleteRequest request = new DeleteRequest(index, type, ids.get(idx));
    bulk.add(request);
  }
  BulkResponse response = highLevelClient.bulk(bulk);
  DeleteOperationResponse dor = new DeleteOperationResponse(response.getTookInMillis());
  return dor;
}

代码示例来源：origin: Netflix/conductor

bulkRequest.add(request);

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

@Override
public void bulkUpdate(List<UpdateQuery> queries) {
  BulkRequest bulkRequest = new BulkRequest();
  for (UpdateQuery query : queries) {
    bulkRequest.add(prepareUpdate(query));
  }
  try {
    checkForBulkUpdateFailure(client.bulk(bulkRequest));
  } catch (IOException e) {
    throw new ElasticsearchException("Error while bulk for request: " + bulkRequest.toString(), e);
  }
}

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

@Override
public void bulkIndex(List<IndexQuery> queries) {
  BulkRequest bulkRequest = new BulkRequest();
  for (IndexQuery query : queries) {
    bulkRequest.add(prepareIndex(query));
  }
  try {
    checkForBulkUpdateFailure(client.bulk(bulkRequest));
  } catch (IOException e) {
    throw new ElasticsearchException("Error while bulk for request: " + bulkRequest.toString(), e);
  }
}

代码示例来源：origin: apache/incubator-gobblin

protected Pair<BulkRequest, FutureCallbackHolder> prepareBatch(Batch<Object> batch, WriteCallback callback) {
 BulkRequest bulkRequest = new BulkRequest();
 final StringBuilder stringBuilder = new StringBuilder();
 for (Object record : batch.getRecords()) {
  try {
   byte[] serializedBytes = this.serializer.serializeToJson(record);
   log.debug("serialized record: {}", serializedBytes);
   IndexRequest indexRequest = new IndexRequest(this.indexName, this.indexType)
     .source(serializedBytes, 0, serializedBytes.length, XContentType.JSON);
   if (this.idMappingEnabled) {
    String id = this.typeMapper.getValue(this.idFieldName, record);
    indexRequest.id(id);
    stringBuilder.append(";").append(id);
   }
   bulkRequest.add(indexRequest);
  }
  catch (Exception e) {
   log.error("Encountered exception {}", e);
  }
 }
 FutureCallbackHolder futureCallbackHolder = new FutureCallbackHolder(callback,
   exception -> log.error("Batch: {} failed on ids; {} with exception {}", batch.getId(),
     stringBuilder.toString(), exception),
   this.malformedDocPolicy);
 return new Pair(bulkRequest, futureCallbackHolder);
}

代码示例来源：origin: apache/nifi

@Override
public IndexOperationResponse add(List<IndexOperationRequest> operations) throws IOException {
  BulkRequest bulkRequest = new BulkRequest();
  for (int index = 0; index < operations.size(); index++) {
    IndexOperationRequest or = operations.get(index);
    IndexRequest indexRequest = new IndexRequest(or.getIndex(), or.getType(), or.getId())
      .source(or.getFields());
    bulkRequest.add(indexRequest);
  }
  bulkRequest.setRefreshPolicy(WriteRequest.RefreshPolicy.IMMEDIATE);
  BulkResponse response = highLevelClient.bulk(bulkRequest);
  IndexOperationResponse retVal = new IndexOperationResponse(response.getTookInMillis(), response.getIngestTookInMillis());
  return retVal;
}

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

/**
 * Adds an {@link IndexRequest} to the list of actions to execute. Follows the same behavior of {@link IndexRequest}
 * (for example, if no id is provided, one will be generated, or usage of the create flag).
 */
public BulkRequestBuilder add(IndexRequest request) {
  super.request.add(request);
  return this;
}

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

/**
 * Adds an {@link DeleteRequest} to the list of actions to execute.
 */
public BulkRequestBuilder add(DeleteRequest request) {
  super.request.add(request);
  return this;
}

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

/**
 * Adds an {@link UpdateRequest} to the list of actions to execute.
 */
public BulkRequestBuilder add(UpdateRequest request) {
  super.request.add(request);
  return this;
}

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

/**
 * Adds a framed data in binary format
 */
public BulkRequestBuilder add(byte[] data, int from, int length, XContentType xContentType) throws Exception {
  request.add(data, from, length, null, null, xContentType);
  return this;
}

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

request.add(new DeleteRequest(indexName, typeName, id));

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

/**
 * Adds an {@link DeleteRequest} to the list of actions to execute.
 */
public BulkRequestBuilder add(DeleteRequestBuilder request) {
  super.request.add(request.request());
  return this;
}

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

/**
 * Adds an {@link UpdateRequest} to the list of actions to execute.
 */
public BulkRequestBuilder add(UpdateRequestBuilder request) {
  super.request.add(request.request());
  return this;
}

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

/**
 * Adds an {@link IndexRequest} to the list of actions to execute. Follows the same behavior of {@link IndexRequest}
 * (for example, if no id is provided, one will be generated, or usage of the create flag).
 */
public BulkRequestBuilder add(IndexRequestBuilder request) {
  super.request.add(request.request());
  return this;
}

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

/**
 * Adds a framed data in binary format
 */
public BulkRequest add(BytesReference data, @Nullable String defaultIndex, @Nullable String defaultType,
            XContentType xContentType) throws IOException {
  return add(data, defaultIndex, defaultType, null, null, null, null, null, true, xContentType);
}

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

/**
 * Adds a framed data in binary format
 */
public BulkRequest add(BytesReference data, @Nullable String defaultIndex, @Nullable String defaultType, boolean allowExplicitIndex,
            XContentType xContentType) throws IOException {
  return add(data, defaultIndex, defaultType, null, null, null, null, null, allowExplicitIndex, xContentType);
}

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

private synchronized void internalAdd(DocWriteRequest request, @Nullable Object payload) {
  ensureOpen();
  bulkRequest.add(request, payload);
  executeIfNeeded();
}

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

private BulkRequest createBulkRequestForRetry(BulkResponse bulkItemResponses) {
  BulkRequest requestToReissue = new BulkRequest();
  int index = 0;
  for (BulkItemResponse bulkItemResponse : bulkItemResponses.getItems()) {
    if (bulkItemResponse.isFailed()) {
      requestToReissue.add(currentBulkRequest.requests().get(index));
    }
    index++;
  }
  return requestToReissue;
}

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

public static BulkRequest toSingleItemBulkRequest(ReplicatedWriteRequest request) {
    BulkRequest bulkRequest = new BulkRequest();
    bulkRequest.add(((DocWriteRequest) request));
    bulkRequest.setRefreshPolicy(request.getRefreshPolicy());
    bulkRequest.timeout(request.timeout());
    bulkRequest.waitForActiveShards(request.waitForActiveShards());
    request.setRefreshPolicy(WriteRequest.RefreshPolicy.NONE);
    return bulkRequest;
  }
}