Package org.elasticsearch.action.search

Examples of org.elasticsearch.action.search.SearchRequestBuilder.addSort()


        if (range != null) {
            srb.setPostFilter(IndexHelper.getTimestampRangeFilter(range));
        }

        if (sort != null) {
            srb.addSort(sort.getField(), sort.asElastic());
        }

        if (highlight && configuration.isAllowHighlighting()) {
            srb.setHighlighterRequireFieldMatch(false);
            srb.addHighlightedField("*", 0, 0);
View Full Code Here


    private SearchHit oneOfIndex(String index, QueryBuilder q, SortOrder sort) {
        SearchRequestBuilder srb = c.prepareSearch();
        srb.setIndices(index);
        srb.setQuery(q);
        srb.setSize(1);
        srb.addSort("timestamp", sort);

        SearchResponse r = c.search(srb.request()).actionGet();
        if (r.getHits() != null && r.getHits().totalHits() > 0) {
            return r.getHits().getAt(0);
        } else {
View Full Code Here

            }
            if( orderBySegments != null )
            {
                for( OrderBy order : orderBySegments )
                {
                    request.addSort( order.property().toString(),
                                     order.order() == OrderBy.Order.ASCENDING ? SortOrder.ASC : SortOrder.DESC );
                }
            }

            // Log
View Full Code Here

            builder.setQuery(queryBuilder);
        } else {
            builder.setQuery(QueryBuilders.matchAllQuery());
        }
        if (sortBuilder != null) {
            builder.addSort(sortBuilder);
        }
        if (from != null) {
            builder.setFrom(from);
        }
        if (size != null) {
View Full Code Here

    }

    public Collection<JUser> findByTopic(String topic, int size) {
        try {
            SearchRequestBuilder srb = createSearchBuilder();
            srb.addSort(LAST_VISIT_DT, SortOrder.DESC);
            srb.setQuery(QueryBuilders.queryString(topic).defaultOperator(Operator.AND).defaultField(TOPICS + ".name").
                    allowLeadingWildcard(false).useDisMax(true));
            srb.setSize(size);
            SearchResponse rsp = srb.execute().actionGet();
            logger.info("[user.findByTopic] took:" + rsp.getTookInMillis() / 1000f + " topic:" + topic + " hits:" + rsp.getHits().totalHits());
View Full Code Here

                FilterBuilders.existsFilter(TOKEN),
                FilterBuilders.termFilter(ACTIVE, true))));
        srb.setFrom(from);
        srb.setSize(size);
        // prefer last logged in users       
        srb.addSort(ElasticUserSearch.CREATED_DT, SortOrder.DESC);
        users.addAll(collectObjects(srb.execute().actionGet()));
    }
}
View Full Code Here

        return set;
    }

    public Collection<JTag> findLowFrequent(int from, int size, double limitOfTweetsPerSec) {
        SearchRequestBuilder srb = createSearchBuilder();
        srb.addSort(Q_INTERVAL, SortOrder.ASC);
        NumericRangeFilterBuilder rb = FilterBuilders.numericRangeFilter(TWEETS_SEC).lt(limitOfTweetsPerSec).includeUpper(true);
        srb.setQuery(QueryBuilders.filteredQuery(QueryBuilders.matchAllQuery(), rb));
        srb.setFrom(from);
        srb.setSize(size);
        return collectObjects(srb.execute().actionGet());
View Full Code Here

        return collectObjects(srb.execute().actionGet());
    }

    public Collection<JTag> findSorted(int from, int size) {
        SearchRequestBuilder srb = createSearchBuilder();
        srb.addSort(LAST_REQ, SortOrder.DESC);
        srb.setQuery(QueryBuilders.matchAllQuery());
        srb.setFrom(from);
        srb.setSize(size);
        return collectObjects(srb.execute().actionGet());
    }
View Full Code Here

            request.addFacet(facet);
        }

        // Sorting
        for (SortBuilder sort : sorts) {
            request.addSort(sort);
        }

        // Paging
        if (from > -1) {
            request.setFrom(from);
View Full Code Here

      request.addFacet(facet);
    }

    // Sorting
    for (SortBuilder sort : sorts) {
      request.addSort(sort);
    }

    // Paging
    if (from > -1) {
      request.setFrom(from);
View Full Code Here

TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.