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

BulkRequest.timeout介绍

[英]A timeout to wait if the index operation can't be performed immediately. Defaults to 1m.
[中]如果无法立即执行索引操作，则等待超时。默认值为1m。

代码示例

代码示例来源：origin: thinkaurelius/titan

log.error("Failed to execute ES query {}", brb.request().timeout(), e);
throw convert(e);

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

/**
 * A timeout to wait if the index operation can't be performed immediately. Defaults to {@code 1m}.
 */
public final BulkRequestBuilder setTimeout(String timeout) {
  request.timeout(timeout);
  return this;
}

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

/**
 * A timeout to wait if the index operation can't be performed immediately. Defaults to {@code 1m}.
 */
public final BulkRequestBuilder setTimeout(TimeValue timeout) {
  request.timeout(timeout);
  return this;
}

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

/**
 * A timeout to wait if the index operation can't be performed immediately. Defaults to {@code 1m}.
 */
public final BulkRequest timeout(String timeout) {
  return timeout(TimeValue.parseTimeValue(timeout, null, getClass().getSimpleName() + ".timeout"));
}

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

parameters.withTimeout(bulkRequest.timeout());
parameters.withRefreshPolicy(bulkRequest.getRefreshPolicy());

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

BulkOperation(Task task, BulkRequest bulkRequest, ActionListener<BulkResponse> listener, AtomicArray<BulkItemResponse> responses,
    long startTimeNanos, Map<String, IndexNotFoundException> indicesThatCannotBeCreated) {
  this.task = task;
  this.bulkRequest = bulkRequest;
  this.listener = listener;
  this.responses = responses;
  this.startTimeNanos = startTimeNanos;
  this.indicesThatCannotBeCreated = indicesThatCannotBeCreated;
  this.observer = new ClusterStateObserver(clusterService, bulkRequest.timeout(), logger, threadPool.getThreadContext());
}

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

BulkRequest getBulkRequest() {
  if (itemResponses.isEmpty()) {
    return bulkRequest;
  } else {
    BulkRequest modifiedBulkRequest = new BulkRequest();
    modifiedBulkRequest.setRefreshPolicy(bulkRequest.getRefreshPolicy());
    modifiedBulkRequest.waitForActiveShards(bulkRequest.waitForActiveShards());
    modifiedBulkRequest.timeout(bulkRequest.timeout());
    int slot = 0;
    List<DocWriteRequest<?>> requests = bulkRequest.requests();
    originalSlots = new int[requests.size()]; // oversize, but that's ok
    for (int i = 0; i < requests.size(); i++) {
      DocWriteRequest request = requests.get(i);
      if (failedSlots.get(i) == false) {
        modifiedBulkRequest.add(request);
        originalSlots[slot++] = i;
      }
    }
    return modifiedBulkRequest;
  }
}

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

final AtomicInteger counter = new AtomicInteger(autoCreateIndices.size());
for (String index : autoCreateIndices) {
  createIndex(index, bulkRequest.timeout(), new ActionListener<CreateIndexResponse>() {
    @Override
    public void onResponse(CreateIndexResponse result) {

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

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

/**
 * A timeout to wait if the index operation can't be performed immediately. Defaults to <tt>1m</tt>.
 */
public final BulkRequestBuilder setTimeout(TimeValue timeout) {
  request.timeout(timeout);
  return this;
}

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

/**
 * A timeout to wait if the index operation can't be performed immediately. Defaults to <tt>1m</tt>.
 */
public final BulkRequestBuilder setTimeout(String timeout) {
  request.timeout(timeout);
  return this;
}

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

/**
 * A timeout to wait if the index operation can't be performed immediately. Defaults to {@code 1m}.
 */
public final BulkRequestBuilder setTimeout(String timeout) {
  request.timeout(timeout);
  return this;
}

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

/**
 * A timeout to wait if the index operation can't be performed immediately. Defaults to {@code 1m}.
 */
public final BulkRequestBuilder setTimeout(TimeValue timeout) {
  request.timeout(timeout);
  return this;
}

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

requests.toArray(new BulkItemRequest[requests.size()]));
bulkShardRequest.waitForActiveShards(bulkRequest.waitForActiveShards());
bulkShardRequest.timeout(bulkRequest.timeout());
if (task != null) {
  bulkShardRequest.setParentTask(nodeId, task.getId());

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

/**
 * A timeout to wait if the index operation can't be performed immediately. Defaults to {@code 1m}.
 */
public final BulkRequest timeout(String timeout) {
  return timeout(TimeValue.parseTimeValue(timeout, null, getClass().getSimpleName() + ".timeout"));
}

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

@Override
public RestChannelConsumer prepareRequest(final RestRequest request, final NodeClient client) throws IOException {
  BulkRequest bulkRequest = Requests.bulkRequest();
  String defaultIndex = request.param("index");
  String defaultType = request.param("type");
  String defaultRouting = request.param("routing");
  FetchSourceContext defaultFetchSourceContext = FetchSourceContext.parseFromRestRequest(request);
  String fieldsParam = request.param("fields");
  if (fieldsParam != null) {
    DEPRECATION_LOGGER.deprecated("Deprecated field [fields] used, expected [_source] instead");
  }
  String[] defaultFields = fieldsParam != null ? Strings.commaDelimitedListToStringArray(fieldsParam) : null;
  String defaultPipeline = request.param("pipeline");
  String waitForActiveShards = request.param("wait_for_active_shards");
  if (waitForActiveShards != null) {
    bulkRequest.waitForActiveShards(ActiveShardCount.parseString(waitForActiveShards));
  }
  bulkRequest.timeout(request.paramAsTime("timeout", BulkShardRequest.DEFAULT_TIMEOUT));
  bulkRequest.setRefreshPolicy(request.param("refresh"));
  bulkRequest.add(request.requiredContent(), defaultIndex, defaultType, defaultRouting, defaultFields,
    defaultFetchSourceContext, defaultPipeline, null, allowExplicitIndex, request.getXContentType());
  return channel -> client.bulk(bulkRequest, new RestStatusToXContentListener<>(channel));
}

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

BulkOperation(Task task, BulkRequest bulkRequest, ActionListener<BulkResponse> listener, AtomicArray<BulkItemResponse> responses,
    long startTimeNanos, Map<String, IndexNotFoundException> indicesThatCannotBeCreated) {
  this.task = task;
  this.bulkRequest = bulkRequest;
  this.listener = listener;
  this.responses = responses;
  this.startTimeNanos = startTimeNanos;
  this.indicesThatCannotBeCreated = indicesThatCannotBeCreated;
  this.observer = new ClusterStateObserver(clusterService, bulkRequest.timeout(), logger, threadPool.getThreadContext());
}

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

BulkOperation(Task task, BulkRequest bulkRequest, ActionListener<BulkResponse> listener, AtomicArray<BulkItemResponse> responses,
    long startTimeNanos, Map<String, IndexNotFoundException> indicesThatCannotBeCreated) {
  this.task = task;
  this.bulkRequest = bulkRequest;
  this.listener = listener;
  this.responses = responses;
  this.startTimeNanos = startTimeNanos;
  this.indicesThatCannotBeCreated = indicesThatCannotBeCreated;
  this.observer = new ClusterStateObserver(clusterService, bulkRequest.timeout(), logger, threadPool.getThreadContext());
}

代码示例来源：origin: org.apache.servicemix.bundles/org.apache.servicemix.bundles.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;
  }
}

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

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;
  }
}