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

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

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

BulkRequest.consistencyLevel介绍

[英]Sets the consistency level of write. Defaults to org.elasticsearch.action.WriteConsistencyLevel#DEFAULT
[中]设置写入的一致性级别。默认为组织。弹性搜索。行动WriteConsistencyLevel#默认值

代码示例

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

/**
 * Sets the consistency level. Defaults to {@link org.elasticsearch.action.WriteConsistencyLevel#DEFAULT}.
 */
public BulkRequestBuilder setConsistencyLevel(WriteConsistencyLevel consistencyLevel) {
  request.consistencyLevel(consistencyLevel);
  return this;
}

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

request.consistencyLevel(mainRequest.getConsistency());
if (logger.isDebugEnabled()) {
  logger.debug("sending [{}] entry, [{}] bulk request", request.requests().size(),

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

request.consistencyLevel(mainRequest.getConsistency());
if (logger.isDebugEnabled()) {
  logger.debug("sending [{}] entry, [{}] bulk request", request.requests().size(),

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

final List<BulkItemRequest> requests = entry.getValue();
BulkShardRequest bulkShardRequest = new BulkShardRequest(bulkRequest, shardId, bulkRequest.refresh(), requests.toArray(new BulkItemRequest[requests.size()]));
bulkShardRequest.consistencyLevel(bulkRequest.consistencyLevel());
bulkShardRequest.timeout(bulkRequest.timeout());
shardBulkAction.execute(bulkShardRequest, new ActionListener<BulkShardResponse>() {

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

bulkRequest.consistencyLevel(WriteConsistencyLevel.fromString(consistencyLevel));

相关文章