Package org.elasticsearch.action.search

Examples of org.elasticsearch.action.search.SearchRequest

61
62
63
64
65
66
67
68
        request.searchRequest(new SearchRequest(index).source(jsonToString(source)));
        return this;
    }

    public PutWarmerRequestBuilder<JsonInput, JsonOutput> source(JsonInput source) {
        request.searchRequest(new SearchRequest(new String[0]).source(jsonToString(source)));
        return this;
    }
View Full Code Here
52
53
54
55
56
57
58
public class SearchRequestBuilder<JsonInput, JsonOutput> extends AbstractRequestBuilderToXContent<SearchRequest, SearchResponse, JsonInput, JsonOutput> {

    private SearchSourceBuilder sourceBuilder;

    public SearchRequestBuilder(Client client, JsonToString<JsonInput> jsonToString, StringToJson<JsonOutput> stringToJson) {
        super(client, new SearchRequest(new String[0]), jsonToString, stringToJson);
    }
View Full Code Here
44
45
46
47
48
49
50
51
    public MultiSearchRequestBuilder(Client client, JsonToString<JsonInput> jsonToString, StringToJson<JsonOutput> stringToJson) {
        super(client, new MultiSearchRequest(), jsonToString, stringToJson);
    }

    public MultiSearchRequestBuilder<JsonInput, JsonOutput> add(String index, String type, JsonInput source) {
        this.request.add(new SearchRequest().indices(index).types(type).source(jsonToString(source)));
        return this;
    }
View Full Code Here
49
50
51
52
53
54
55
56
        this.request.add(new SearchRequest().indices(index).types(type).source(jsonToString(source)));
        return this;
    }

    public MultiSearchRequestBuilder<JsonInput, JsonOutput> add(String index, JsonInput source) {
        this.request.add(new SearchRequest().indices(index).source(jsonToString(source)));
        return this;
    }
View Full Code Here
54
55
56
57
58
59
60
61
        this.request.add(new SearchRequest().indices(index).source(jsonToString(source)));
        return this;
    }

    public MultiSearchRequestBuilder<JsonInput, JsonOutput> add(JsonInput source) {
        this.request.add(new SearchRequest().indices(new String[0]).source(jsonToString(source)));
        return this;
    }
View Full Code Here
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
  private List<SearchHit> searchInternal(final XContentQueryBuilder query, final int maxResults) {
    final SearchResponse response = executeGet(new ClientCallback<SearchResponse>() {

      @Override
      public ActionFuture<SearchResponse> execute(final Client client) {
        final SearchRequest request = Requests.searchRequest().searchType(
            SearchType.DFS_QUERY_AND_FETCH);
        final SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
        sourceBuilder.query(query);

        sourceBuilder.size(maxResults);
        request.source(sourceBuilder);
        return client.search(request);
      }
    });
    return Arrays.asList(response.getHits().getHits());
View Full Code Here
100
101
102
103
104
105
106
107
108
109
110
111
  public void handleRequest(final RestRequest request, final RestChannel channel) {
    // Get the parameters
    final Map<String, List<String>> params = parseUriParams(request.uri());

    // generate the search request
    SearchRequest searchRequest = getSearchRequest(params, request);
    searchRequest.listenerThreaded(false);

    // execute the search
    client.search(searchRequest, new ActionListener<SearchResponse>() {
      @Override
      public void onResponse(SearchResponse response) {
View Full Code Here
287
288
289
290
291
292
293
294
295
296
297
      }
    }

    // Build the search Request
    String[] indices = RestActions.splitIndices(index);
    SearchRequest searchRequest = new SearchRequest(indices);
    searchRequest.extraSource(searchSourceBuilder);
    searchRequest.types(RestActions.splitTypes(type));

    return searchRequest;
  }
View Full Code Here
101
102
103
104
105
106
107
108
109
110
111
112
    public SQLRequest getSqlUpdateRequest() {
        return new SQLRequest("UPDATE countries SET population=? WHERE \"countryCode\"=?", new Object[]{ Math.abs(getRandom().nextInt()), "US" });
    }

    public SearchRequest getApiUpdateRequest() throws IOException {
        SearchRequest request = new SearchRequest(INDEX_NAME).types("default");
        request.source(
                XContentFactory.jsonBuilder()
                        .startObject()
                        .startObject("query")
                        .startObject("term")
                        .field("countryCode", "US")
View Full Code Here
139
140
141
142
143
144
145
            new Object[]{getGetId(queryPlannerEnabled)}
        );
    }

    public SearchRequest getApiSearchRequest() {
        return new SearchRequest(new String[]{INDEX_NAME}, searchSource).types("default");
    }
View Full Code Here
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
    • Copyright © 2018 www.massapicom. 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.