本文整理了Java中org.elasticsearch.action.bulk.BulkRequest.consistencyLevel()
方法的一些代码示例,展示了BulkRequest.consistencyLevel()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。BulkRequest.consistencyLevel()
方法的具体详情如下:
包路径:org.elasticsearch.action.bulk.BulkRequest
类名称: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));
内容来源于网络,如有侵权,请联系作者删除!