Examples of org.elasticsearch.action.search.SearchRequest

org.elasticsearch.action.search.SearchRequest
A request to execute search against one or more indices (or all). Best created using {@link org.elasticsearch.client.Requests#searchRequest(String)}.
Note, the search {@link #source(org.elasticsearch.search.builder.SearchSourceBuilder)}is required. The search source is the different search options, including facets and such.
There is an option to specify an addition search source using the {@link #extraSource(org.elasticsearch.search.builder.SearchSourceBuilder)}. @author kimchy (shay.banon) @see org.elasticsearch.client.Requests#searchRequest(String) @see org.elasticsearch.client.Client#search(SearchRequest) @see SearchResponse

        }
    }


    @Test
    public void testListBenchmarks() throws Exception {
        SearchRequest searchRequest = prepareBlockingScriptQuery();
        final BenchmarkRequest request =
                BenchmarkTestUtil.randomRequest(client(), indices, numExecutorNodes, competitionSettingsMap, searchRequest);
        logger.info("--> Submitting benchmark - competitors [{}] iterations [{}]", request.competitors().size(),
                request.settings().iterations());

View Full Code Here

        waitForQuery = new CountDownLatch(1);
        waitForTestLatch = new CountDownLatch(1);
        String className = "BenchmarkIntegrationTest";
        ScriptScoreFunctionBuilder scriptFunction = scriptFunction("import " + this.getClass().getName() + "; \n" +
                className + ".waitForQuery.countDown(); \n" + className + ".waitForTestLatch.await(); \n return 1.0;");
        SearchRequest searchRequest = searchRequest().source(
                searchSource()
                        .query(functionScoreQuery(FilterBuilders.matchAllFilter(), scriptFunction)));
        return  searchRequest;
    }

View Full Code Here

        int numQueries = scaledRandomIntBetween(20, 100);
        int numErrors = scaledRandomIntBetween(1, numQueries);
        final boolean containsFatal = randomBoolean();
        if (containsFatal) {
            ScriptScoreFunctionBuilder scriptFunction = scriptFunction("DOES NOT COMPILE - fails on any shard");
            SearchRequest searchRequest = searchRequest().source(
                    searchSource()
                            .query(functionScoreQuery(FilterBuilders.matchAllFilter(), scriptFunction)));
            reqList.add(searchRequest);


        }
        for (int i = 0; reqList.size() < numErrors; i++) {
            ScriptScoreFunctionBuilder scriptFunction = scriptFunction("throw new RuntimeException();");
            SearchRequest searchRequest = searchRequest().source(
                    searchSource()
                            .query(functionScoreQuery(FilterBuilders.matchAllFilter(), scriptFunction)));
            reqList.add(searchRequest);
        }
        logger.info("--> run with [{}] errors ", numErrors);

View Full Code Here

        final int iters = between(1, 3); // we run this more than once to make sure metadata is cleaned up propperly
        for (int i = 0; i < iters ; i++) {
            List<BenchmarkRequest> requests = new ArrayList<>();
            List<ActionFuture<BenchmarkResponse>> responses = new ArrayList<>();


            SearchRequest searchRequest = prepareBlockingScriptQuery();
            final int benches = between(1, 3);
            String[] names = new String[benches];
            for (int k = 0; k < benches; k++) {
                final BenchmarkRequest request =
                        BenchmarkTestUtil.randomRequest(client(), indices, numExecutorNodes, competitionSettingsMap, searchRequest);

View Full Code Here


    @Test
    public void testAbortBenchmark() throws Exception {
        final int iters = between(1, 3); // we run this more than once to make sure metadata is cleaned up propperly
        for (int i = 0; i < iters ; i++) {
            SearchRequest searchRequest = prepareBlockingScriptQuery();
            final BenchmarkRequest request =
                    BenchmarkTestUtil.randomRequest(client(), indices, numExecutorNodes, competitionSettingsMap, searchRequest);
            request.settings().iterations(Integer.MAX_VALUE, true); // massive amount of iterations
            logger.info("--> Submitting benchmark - competitors [{}] iterations [{}]", request.competitors().size(),
                    request.settings().iterations());

View Full Code Here

                settings.addSearchRequest(requests[i]);
            }
        } else {
            final int numSearches = between(lowRandomIntervalBound, highRandomIntervalBound);
            for (int i = 0; i < numSearches; i++) {
                final SearchRequest searchRequest = randomSearch(client, indices);
                builder.addSearchRequest(searchRequest);
                settings.addSearchRequest(searchRequest);
            }
        }

View Full Code Here

                String text = iterator.term().utf8ToString();
                boolBuilder.should(QueryBuilders.termQuery(fieldName, text));
            }
        }
        // wrap a search request object
        this.searchRequest = new SearchRequest(indices).types(types).source(new SearchSourceBuilder().query(boolBuilder));
    }

View Full Code Here

    public void cascadeGlobalSettings() {
        for (BenchmarkCompetitor competitor : competitors) {
            competitor.settings().merge(settings);
            if (competitor.settings().searchRequests().isEmpty()) {
                for (SearchRequest defaultSearchRequest : settings.searchRequests()) {
                    SearchRequest copy = new SearchRequest();
                    if (defaultSearchRequest.indices() != null) {
                        copy.indices(defaultSearchRequest.indices());
                    }
                    copy.types(defaultSearchRequest.types());
                    copy.searchType(defaultSearchRequest.searchType());
                    copy.source(defaultSearchRequest.source(), true);
                    copy.extraSource(defaultSearchRequest.extraSource(), true);
                    copy.routing(defaultSearchRequest.routing());
                    copy.preference(defaultSearchRequest.preference());
                    competitor.settings().addSearchRequest(copy);
                }
            }
        }
    }

View Full Code Here

        types = in.readStringArray();
        searchType = SearchType.fromId(in.readByte());
        clearCaches = in.readOptionalStreamable(new ClearIndicesCacheRequest());
        final int size = in.readVInt();
        for (int i = 0; i < size; i++) {
            SearchRequest searchRequest = new SearchRequest();
            searchRequest.readFrom(in);
            searchRequests.add(searchRequest);
        }
    }

View Full Code Here


        @Override
        public void readFrom(StreamInput in) throws IOException {
            avgTimeTaken = in.readVLong();
            maxTimeTaken = in.readVLong();
            searchRequest = new SearchRequest();
            searchRequest.readFrom(in);
        }

View Full Code Here

0 1 2 3 4 5 6

TOP

Related Classes of org.elasticsearch.action.search.SearchRequest

co.diji.rest.SolrSearchHandlerRestAction

io.crate.executor.transport.task.elasticsearch.ESUpdateByQueryTask

io.crate.integrationtests.MappingDefaultsTest

io.crate.module.sql.benchmark.SelectBenchmark

io.crate.module.sql.benchmark.UpdateBenchmark

org.carrot2.elasticsearch.ClusteringAction$ClusteringActionRequest

org.carrot2.elasticsearch.ClusteringAction$RestClusteringAction

org.elasticsearch.action.admin.indices.warmer.put.PutWarmerRequest

org.elasticsearch.action.admin.indices.warmer.put.TransportPutWarmerAction

org.elasticsearch.action.bench.BenchmarkIntegrationTest

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.