org.elasticsearch.search.builder.SearchSourceBuilder.version()方法的使用及代码示例

x33g5p2x  于2022-01-30 转载在 其他  
字(6.8k)|赞(0)|评价(0)|浏览(182)

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

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());

相关文章

微信公众号

最新文章

更多

SearchSourceBuilder类方法