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

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

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

SearchSourceBuilder.sorts介绍

[英]Gets the bytes representing the sort builders for this request.
[中]获取表示此请求的排序生成器的字节。

代码示例

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

if (source.sorts() != null) {
  try {
    Optional<SortAndFormats> optionalSort = SortBuilder.buildSort(source.sorts(), context.getQueryShardContext());
    if (optionalSort.isPresent()) {
      context.sort(optionalSort.get());

代码示例来源: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().sorts() != null) {
  boolean useScan = false;
    for (SortBuilder<?> sort : searchRequest.source().sorts()) {
      if (sort instanceof FieldSortBuilder) {
        FieldSortBuilder f = (FieldSortBuilder) sort;
    request.addParameter("search_type", "scan");
  } else {
    StringBuilder sorts = new StringBuilder(sortToUri(searchRequest.source().sorts().get(0)));
    for (int i = 1; i < searchRequest.source().sorts().size(); i++) {
      sorts.append(',').append(sortToUri(searchRequest.source().sorts().get(i)));

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

if (source.sorts() != null) {
  try {
    Optional<SortAndFormats> optionalSort = SortBuilder.buildSort(source.sorts(), context.getQueryShardContext());
    if (optionalSort.isPresent()) {
      context.sort(optionalSort.get());

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

if (source.sorts() != null) {
  try {
    Optional<SortAndFormats> optionalSort = SortBuilder.buildSort(source.sorts(), context.getQueryShardContext());
    if (optionalSort.isPresent()) {
      context.sort(optionalSort.get());

相关文章

微信公众号

最新文章

更多

SearchSourceBuilder类方法