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

BulkRequest.addPayload介绍

暂无

代码示例

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

public BulkRequest add(DeleteRequest request, @Nullable Object payload) {
  Objects.requireNonNull(request, "'request' must not be null");
  applyGlobalMandatoryParameters(request);
  requests.add(request);
  addPayload(payload);
  sizeInBytes += REQUEST_OVERHEAD;
  indices.add(request.index());
  return this;
}

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

BulkRequest internalAdd(IndexRequest request, @Nullable Object payload) {
  Objects.requireNonNull(request, "'request' must not be null");
  applyGlobalMandatoryParameters(request);
  requests.add(request);
  addPayload(payload);
  // lack of source is validated in validate() method
  sizeInBytes += (request.source() != null ? request.source().length() : 0) + REQUEST_OVERHEAD;
  indices.add(request.index());
  return this;
}

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

BulkRequest internalAdd(UpdateRequest request, @Nullable Object payload) {
  Objects.requireNonNull(request, "'request' must not be null");
  applyGlobalMandatoryParameters(request);
  requests.add(request);
  addPayload(payload);
  if (request.doc() != null) {
    sizeInBytes += request.doc().source().length();
  }
  if (request.upsertRequest() != null) {
    sizeInBytes += request.upsertRequest().source().length();
  }
  if (request.script() != null) {
    sizeInBytes += request.script().getIdOrCode().length() * 2;
  }
  indices.add(request.index());
  return this;
}

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

public BulkRequest add(DeleteRequest request, @Nullable Object payload) {
  Objects.requireNonNull(request, "'request' must not be null");
  requests.add(request);
  addPayload(payload);
  sizeInBytes += REQUEST_OVERHEAD;
  return this;
}

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

public BulkRequest add(DeleteRequest request, @Nullable Object payload) {
  requests.add(request);
  addPayload(payload);
  sizeInBytes += REQUEST_OVERHEAD;
  return this;
}

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

public BulkRequest add(DeleteRequest request, @Nullable Object payload) {
  Objects.requireNonNull(request, "'request' must not be null");
  requests.add(request);
  addPayload(payload);
  sizeInBytes += REQUEST_OVERHEAD;
  indices.add(request.index());
  return this;
}

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

public BulkRequest add(DeleteRequest request, @Nullable Object payload) {
  Objects.requireNonNull(request, "'request' must not be null");
  requests.add(request);
  addPayload(payload);
  sizeInBytes += REQUEST_OVERHEAD;
  indices.add(request.index());
  return this;
}

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

BulkRequest internalAdd(IndexRequest request, @Nullable Object payload) {
  Objects.requireNonNull(request, "'request' must not be null");
  requests.add(request);
  addPayload(payload);
  // lack of source is validated in validate() method
  sizeInBytes += (request.source() != null ? request.source().length() : 0) + REQUEST_OVERHEAD;
  return this;
}

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

BulkRequest internalAdd(IndexRequest request, @Nullable Object payload) {
  Objects.requireNonNull(request, "'request' must not be null");
  requests.add(request);
  addPayload(payload);
  // lack of source is validated in validate() method
  sizeInBytes += (request.source() != null ? request.source().length() : 0) + REQUEST_OVERHEAD;
  indices.add(request.index());
  return this;
}

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

BulkRequest internalAdd(IndexRequest request, @Nullable Object payload) {
  Objects.requireNonNull(request, "'request' must not be null");
  requests.add(request);
  addPayload(payload);
  // lack of source is validated in validate() method
  sizeInBytes += (request.source() != null ? request.source().length() : 0) + REQUEST_OVERHEAD;
  indices.add(request.index());
  return this;
}

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

BulkRequest internalAdd(IndexRequest request, @Nullable Object payload) {
  requests.add(request);
  addPayload(payload);
  // lack of source is validated in validate() method
  sizeInBytes += (request.source() != null ? request.source().length() : 0) + REQUEST_OVERHEAD;
  return this;
}

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

BulkRequest internalAdd(UpdateRequest request, @Nullable Object payload) {
  Objects.requireNonNull(request, "'request' must not be null");
  requests.add(request);
  addPayload(payload);
  if (request.doc() != null) {
    sizeInBytes += request.doc().source().length();
  }
  if (request.upsertRequest() != null) {
    sizeInBytes += request.upsertRequest().source().length();
  }
  if (request.script() != null) {
    sizeInBytes += request.script().getIdOrCode().length() * 2;
  }
  return this;
}

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

BulkRequest internalAdd(UpdateRequest request, @Nullable Object payload) {
  Objects.requireNonNull(request, "'request' must not be null");
  requests.add(request);
  addPayload(payload);
  if (request.doc() != null) {
    sizeInBytes += request.doc().source().length();
  }
  if (request.upsertRequest() != null) {
    sizeInBytes += request.upsertRequest().source().length();
  }
  if (request.script() != null) {
    sizeInBytes += request.script().getIdOrCode().length() * 2;
  }
  indices.add(request.index());
  return this;
}

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

BulkRequest internalAdd(UpdateRequest request, @Nullable Object payload) {
  Objects.requireNonNull(request, "'request' must not be null");
  requests.add(request);
  addPayload(payload);
  if (request.doc() != null) {
    sizeInBytes += request.doc().source().length();
  }
  if (request.upsertRequest() != null) {
    sizeInBytes += request.upsertRequest().source().length();
  }
  if (request.script() != null) {
    sizeInBytes += request.script().getIdOrCode().length() * 2;
  }
  indices.add(request.index());
  return this;
}

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

BulkRequest internalAdd(UpdateRequest request, @Nullable Object payload) {
  requests.add(request);
  addPayload(payload);
  if (request.doc() != null) {
    sizeInBytes += request.doc().source().length();
  }
  if (request.upsertRequest() != null) {
    sizeInBytes += request.upsertRequest().source().length();
  }
  if (request.script() != null) {
    sizeInBytes += request.script().getScript().length() * 2;
  }
  return this;
}