org.elasticsearch.action.bulk.BulkRequest.waitForActiveShards()方法的使用及代码示例

x33g5p2x  于2022-01-16 转载在 其他  
字(11.7k)|赞(0)|评价(0)|浏览(79)

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

BulkRequest.waitForActiveShards介绍

[英]A shortcut for #waitForActiveShards(ActiveShardCount) where the numerical shard count is passed in, instead of having to first call ActiveShardCount#from(int)to get the ActiveShardCount.
[中]waitForActiveShards（ActiveShardCount）的快捷方式，其中传入数值碎片计数，而不必首先从（int）调用ActiveShardCount来获取ActiveShardCount。

代码示例

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

/**
 * Sets the number of shard copies that must be active before proceeding with the write.
 * See {@link ReplicationRequest#waitForActiveShards(ActiveShardCount)} for details.
 */
public BulkRequestBuilder setWaitForActiveShards(ActiveShardCount waitForActiveShards) {
  request.waitForActiveShards(waitForActiveShards);
  return this;
}

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

/**
 * A shortcut for {@link #waitForActiveShards(ActiveShardCount)} where the numerical
 * shard count is passed in, instead of having to first call {@link ActiveShardCount#from(int)}
 * to get the ActiveShardCount.
 */
public BulkRequest waitForActiveShards(final int waitForActiveShards) {
  return waitForActiveShards(ActiveShardCount.from(waitForActiveShards));
}

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

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: org.apache.servicemix.bundles/org.apache.servicemix.bundles.elasticsearch

/**
 * Sets the number of shard copies that must be active before proceeding with the write.
 * See {@link ReplicationRequest#waitForActiveShards(ActiveShardCount)} for details.
 */
public BulkRequestBuilder setWaitForActiveShards(ActiveShardCount waitForActiveShards) {
  request.waitForActiveShards(waitForActiveShards);
  return this;
}

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

/**
 * Sets the number of shard copies that must be active before proceeding with the write.
 * See {@link ReplicationRequest#waitForActiveShards(ActiveShardCount)} for details.
 */
public BulkRequestBuilder setWaitForActiveShards(ActiveShardCount waitForActiveShards) {
  request.waitForActiveShards(waitForActiveShards);
  return this;
}

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

/**
 * Sets the number of shard copies that must be active before proceeding with the write.
 * See {@link ReplicationRequest#waitForActiveShards(ActiveShardCount)} for details.
 */
public BulkRequestBuilder setWaitForActiveShards(ActiveShardCount waitForActiveShards) {
  request.waitForActiveShards(waitForActiveShards);
  return this;
}

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

BulkShardRequest bulkShardRequest = new BulkShardRequest(shardId, bulkRequest.getRefreshPolicy(),
    requests.toArray(new BulkItemRequest[requests.size()]));
bulkShardRequest.waitForActiveShards(bulkRequest.waitForActiveShards());
bulkShardRequest.timeout(bulkRequest.timeout());
if (task != null) {

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

/**
 * A shortcut for {@link #waitForActiveShards(ActiveShardCount)} where the numerical
 * shard count is passed in, instead of having to first call {@link ActiveShardCount#from(int)}
 * to get the ActiveShardCount.
 */
public BulkRequest waitForActiveShards(final int waitForActiveShards) {
  return waitForActiveShards(ActiveShardCount.from(waitForActiveShards));
}

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

/**
 * A shortcut for {@link #waitForActiveShards(ActiveShardCount)} where the numerical
 * shard count is passed in, instead of having to first call {@link ActiveShardCount#from(int)}
 * to get the ActiveShardCount.
 */
public BulkRequest waitForActiveShards(final int waitForActiveShards) {
  return waitForActiveShards(ActiveShardCount.from(waitForActiveShards));
}

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

/**
 * A shortcut for {@link #waitForActiveShards(ActiveShardCount)} where the numerical
 * shard count is passed in, instead of having to first call {@link ActiveShardCount#from(int)}
 * to get the ActiveShardCount.
 */
public BulkRequest waitForActiveShards(final int waitForActiveShards) {
  return waitForActiveShards(ActiveShardCount.from(waitForActiveShards));
}

代码示例来源：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: hellobike/tunnel

private BulkRequest createBulkRequest(List<DocWriteRequest> doc) {
  BulkRequest br = new BulkRequest();
  br.add(doc);
  br.setRefreshPolicy(WriteRequest.RefreshPolicy.IMMEDIATE);
  br.waitForActiveShards(ActiveShardCount.ONE);
  return br;
}

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

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.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: com.strapdata.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: 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;
  }
}

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

内容来源于网络，如有侵权，请联系作者删除！

BulkRequest

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com