本文整理了Java中org.elasticsearch.search.builder.SearchSourceBuilder.version()
方法的一些代码示例,展示了SearchSourceBuilder.version()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。SearchSourceBuilder.version()
方法的具体详情如下:
包路径:org.elasticsearch.search.builder.SearchSourceBuilder
类名称:SearchSourceBuilder
方法名:version
[英]Indicates whether the document's version will be included in the search hits.
[中]指示文档的版本是否将包含在搜索命中中。
代码示例来源:origin: spring-projects/spring-data-elasticsearch
private SearchResponse doScroll(SearchRequest request, SearchQuery searchQuery) {
Assert.notNull(searchQuery.getIndices(), "No index defined for Query");
Assert.notNull(searchQuery.getTypes(), "No type define for Query");
Assert.notNull(searchQuery.getPageable(), "Query.pageable is required for scan & scroll");
if (searchQuery.getFilter() != null) {
request.source().postFilter(searchQuery.getFilter());
}
request.source().version(true);
try {
return client.search(request);
} catch (IOException e) {
throw new ElasticsearchException("Error for search request with scroll: " + request.toString(), e);
}
}
代码示例来源:origin: spring-projects/spring-data-elasticsearch
private SearchResponse doScroll(SearchRequest request, CriteriaQuery criteriaQuery) {
Assert.notNull(criteriaQuery.getIndices(), "No index defined for Query");
Assert.notNull(criteriaQuery.getTypes(), "No type define for Query");
Assert.notNull(criteriaQuery.getPageable(), "Query.pageable is required for scan & scroll");
QueryBuilder elasticsearchQuery = new CriteriaQueryProcessor().createQueryFromCriteria(criteriaQuery.getCriteria());
QueryBuilder elasticsearchFilter = new CriteriaFilterProcessor()
.createFilterFromCriteria(criteriaQuery.getCriteria());
if (elasticsearchQuery != null) {
request.source().query(elasticsearchQuery);
} else {
request.source().query(QueryBuilders.matchAllQuery());
}
if (elasticsearchFilter != null) {
request.source().postFilter(elasticsearchFilter);
}
request.source().version(true);
try {
return client.search(request);
} catch (IOException e) {
throw new ElasticsearchException("Error for search request with scroll: " + request.toString(), e);
}
}
代码示例来源:origin: spring-projects/spring-data-elasticsearch
searchSourceBuilder.version(entity.hasVersionProperty());
searchSourceBuilder.trackScores(query.getTrackScores());
代码示例来源:origin: org.elasticsearch/elasticsearch
/**
* Should each {@link org.elasticsearch.search.SearchHit} be returned with its
* version.
*/
public SearchRequestBuilder setVersion(boolean version) {
sourceBuilder().version(version);
return this;
}
代码示例来源:origin: spring-projects/spring-data-elasticsearch
SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
request.types(toArray(query.getTypes()));
sourceBuilder.version(true);
sourceBuilder.trackScores(query.getTrackScores());
代码示例来源:origin: org.apache.servicemix.bundles/org.apache.servicemix.bundles.elasticsearch
/**
* Should each {@link org.elasticsearch.search.SearchHit} be returned with its
* version.
*/
public SearchRequestBuilder setVersion(boolean version) {
sourceBuilder().version(version);
return this;
}
代码示例来源:origin: apache/servicemix-bundles
/**
* Should each {@link org.elasticsearch.search.SearchHit} be returned with its
* version.
*/
public SearchRequestBuilder setVersion(boolean version) {
sourceBuilder().version(version);
return this;
}
代码示例来源:origin: harbby/presto-connectors
/**
* Should each {@link org.elasticsearch.search.SearchHit} be returned with its
* version.
*/
public T setVersion(boolean version) {
sourceBuilder().version(version);
return (T) this;
}
代码示例来源:origin: com.strapdata.elasticsearch/elasticsearch
/**
* Should each {@link org.elasticsearch.search.SearchHit} be returned with its
* version.
*/
public SearchRequestBuilder setVersion(boolean version) {
sourceBuilder().version(version);
return this;
}
代码示例来源:origin: harbby/presto-connectors
/**
* Should each {@link org.elasticsearch.search.SearchHit} be returned with its
* version.
*/
public SearchRequestBuilder setVersion(boolean version) {
sourceBuilder().version(version);
return this;
}
代码示例来源:origin: harbby/presto-connectors
/**
* Should each {@link org.elasticsearch.search.SearchHit} be returned with its
* version.
*/
public TopHitsBuilder setVersion(boolean version) {
sourceBuilder().version(version);
return this;
}
代码示例来源:origin: javanna/elasticshell
public SearchRequestBuilder<JsonInput, JsonOutput> version(boolean version) {
sourceBuilder().version(version);
return this;
}
代码示例来源:origin: org.elasticsearch/elasticsearch
searchSourceBuilder.version(request.paramAsBoolean("version", null));
代码示例来源:origin: org.elasticsearch/elasticsearch
groupSource.version(options.isVersion());
if (innerCollapseBuilder != null) {
groupSource.collapse(innerCollapseBuilder);
代码示例来源:origin: org.elasticsearch/elasticsearch
if (source.version() != null) {
context.version(source.version());
代码示例来源:origin: org.elasticsearch.plugin/reindex-client
public AbstractAsyncBulkByScrollAction(BulkByScrollTask task, Logger logger, ParentTaskAssigningClient client,
ThreadPool threadPool, Request mainRequest, ScriptService scriptService, ClusterState clusterState,
ActionListener<BulkByScrollResponse> listener) {
this.task = task;
if (!task.isWorker()) {
throw new IllegalArgumentException("Given task [" + task.getId() + "] must have a child worker");
}
this.worker = task.getWorkerState();
this.logger = logger;
this.client = client;
this.threadPool = threadPool;
this.scriptService = scriptService;
this.clusterState = clusterState;
this.mainRequest = mainRequest;
this.listener = listener;
BackoffPolicy backoffPolicy = buildBackoffPolicy();
bulkRetry = new Retry(BackoffPolicy.wrap(backoffPolicy, worker::countBulkRetry), threadPool);
scrollSource = buildScrollableResultSource(backoffPolicy);
scriptApplier = Objects.requireNonNull(buildScriptApplier(), "script applier must not be null");
/*
* Default to sorting by doc. We can't do this in the request itself because it is normal to *add* to the sorts rather than replace
* them and if we add _doc as the first sort by default then sorts will never work.... So we add it here, only if there isn't
* another sort.
*/
List<SortBuilder<?>> sorts = mainRequest.getSearchRequest().source().sorts();
if (sorts == null || sorts.isEmpty()) {
mainRequest.getSearchRequest().source().sort(fieldSort("_doc"));
}
mainRequest.getSearchRequest().source().version(needsSourceDocumentVersions());
}
代码示例来源:origin: org.elasticsearch.plugin/reindex-client
if (searchRequest.source().version() == null || searchRequest.source().version() == true) {
代码示例来源:origin: org.apache.servicemix.bundles/org.apache.servicemix.bundles.elasticsearch
groupSource.version(options.isVersion());
if (innerCollapseBuilder != null) {
groupSource.collapse(innerCollapseBuilder);
代码示例来源:origin: apache/servicemix-bundles
groupSource.version(options.isVersion());
if (innerCollapseBuilder != null) {
groupSource.collapse(innerCollapseBuilder);
代码示例来源:origin: org.elasticsearch.plugin/delete-by-query
.sort("_doc") // important for performance
.fetchSource(false)
.version(true);
if (request.size() > 0) {
source.size(request.size());
内容来源于网络,如有侵权,请联系作者删除!