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

TransportClient.bulk介绍

暂无

代码示例

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

@Override
public Future<WriteResponse> write(Batch<Object> batch, @Nullable WriteCallback callback) {
 Pair<BulkRequest, FutureCallbackHolder> preparedBatch = this.prepareBatch(batch, callback);
 client.bulk(preparedBatch.getFirst(), preparedBatch.getSecond().getActionListener());
 return preparedBatch.getSecond().getFuture();
}

代码示例来源：origin: harbby/sylph

@Override
public void close(Throwable errorOrNull)
{
  try (TransportClient closeClient = client) {
    if (bulkBuilder != null && closeClient != null) {
      closeClient.bulk(bulkBuilder.request());
    }
  }
}

代码示例来源：origin: harbby/sylph

@Override
public void close(Throwable errorOrNull)
{
  try (TransportClient closeClient = client) {
    if (bulkBuilder != null && closeClient != null) {
      closeClient.bulk(bulkBuilder.request());
    }
  }
}

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

@Override
public Future<WriteResponse> write(Batch<Object> batch, @Nullable WriteCallback callback) {
 Pair<BulkRequest, FutureCallbackHolder> preparedBatch = this.prepareBatch(batch, callback);
 client.bulk(preparedBatch.getFirst(), preparedBatch.getSecond().getActionListener());
 return preparedBatch.getSecond().getFuture();
}

代码示例来源：origin: lumifyio/securegraph

protected void doBulkRequest(BulkRequest bulkRequest) {
  BulkResponse response = getClient().bulk(bulkRequest).actionGet();
  if (response.hasFailures()) {
    for (BulkItemResponse bulkResponse : response) {
      if (bulkResponse.isFailed()) {
        LOGGER.error("Failed to index " + bulkResponse.getId() + " (message: " + bulkResponse.getFailureMessage() + ")");
      }
    }
    throw new SecureGraphException("Could not add element.");
  }
}

代码示例来源：origin: org.neolumin.vertexium/vertexium-elasticsearch-base

protected void doBulkRequest(BulkRequest bulkRequest) {
  BulkResponse response = getClient().bulk(bulkRequest).actionGet();
  if (response.hasFailures()) {
    for (BulkItemResponse bulkResponse : response) {
      if (bulkResponse.isFailed()) {
        LOGGER.error("Failed to index " + bulkResponse.getId() + " (message: " + bulkResponse.getFailureMessage() + ")");
      }
    }
    throw new VertexiumException("Could not add element.");
  }
}

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

protected void doBulkRequest(BulkRequest bulkRequest) {
  BulkResponse response = getClient().bulk(bulkRequest).actionGet();
  if (response.hasFailures()) {
    for (BulkItemResponse bulkResponse : response) {
      if (bulkResponse.isFailed()) {
        LOGGER.error("Failed to index " + bulkResponse.getId() + " (message: " + bulkResponse.getFailureMessage() + ")");
      }
    }
    throw new SecureGraphException("Could not add element.");
  }
}

代码示例来源：origin: harbby/sylph

client.bulk(bulkBuilder.request()).actionGet();
cnt.set(0);
bulkBuilder = client.prepareBulk();

代码示例来源：origin: harbby/sylph

client.bulk(bulkBuilder.request()).actionGet();
cnt.set(0);
bulkBuilder = client.prepareBulk();