Examples of execute()

Examples of org.elasticsearch.action.get.GetRequestBuilder.execute()

463
464
465
466
467
468
469
470
471
472
473
      if (type != null) {
        grb.setType(type);
      }

      map = grb.execute().actionGet().getSource();
    } catch (Exception e) {
      logger.warn(null, e);
    }
    return map;
  }
View Full Code Here

Examples of org.elasticsearch.action.get.MultiGetRequestBuilder.execute()

172
173
174
175
176
177
178
179
180
181
182
        MultiGetRequest.Item i = new MultiGetRequest.Item(stripRouting(appid), null, id);
        i.routing(getRouting(appid, id));
        mgr.add(i);
      }

      MultiGetResponse response = mgr.execute().actionGet();
      for (MultiGetItemResponse multiGetItemResponse : response.getResponses()) {
        GetResponse res = multiGetItemResponse.getResponse();
        if (res.isExists() && !res.isSourceEmpty()) {
          list.add((P) Utils.setAnnotatedFields(res.getSource()));
        }
View Full Code Here

Examples of org.elasticsearch.action.index.IndexRequestBuilder.execute()

127
128
129
130
131
132
133
134
135
136
137
        Object document = extractDocumentFromMessage(exchange.getIn());

        if (!setIndexRequestSource(document, prepareIndex)) {
            throw new ExpectedBodyTypeException(exchange, XContentBuilder.class);
        }
        ListenableActionFuture<IndexResponse> future = prepareIndex.execute();
        IndexResponse response = future.actionGet();
        exchange.getIn().setBody(response.getId());
    }

    public void addToIndexUsingBulk(Client client, Exchange exchange) {
View Full Code Here

Examples of org.elasticsearch.action.mlt.MoreLikeThisRequestBuilder.execute()

643
644
645
646
647
648
649
650
651
652
653
    }
    if (query.getBoostTerms() != null) {
      requestBuilder.setBoostTerms(query.getBoostTerms());
    }

    SearchResponse response = requestBuilder.execute().actionGet();
    return resultsMapper.mapResults(response, clazz, query.getPageable());
  }

  private SearchResponse doSearch(SearchRequestBuilder searchRequest, SearchQuery searchQuery) {
    if (searchQuery.getFilter() != null) {
View Full Code Here

Examples of org.elasticsearch.action.percolate.PercolateRequestBuilder.execute()

735
736
737
738
739
740
741
742
743
744
745
            Logger.debug("Elasticsearch : Error when get percolator for ");
        }

        percolateRequestBuilder.setSource(doc);

        PercolateResponse percolateResponse = percolateRequestBuilder.execute().actionGet();
        if (percolateResponse == null) {
            return null;
        }
        List<String> matchedQueryIds = new ArrayList<String>();
        PercolateResponse.Match[] matches = percolateResponse.getMatches();
View Full Code Here

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

340
341
342
343
344
345
346
347
348
349
350
            if (idx_resultField != null && !"_source".equals(idx_resultField)) {
              req.addField(mappingRecord.get(CFG_idx_result_field));
            }
          }

          SearchResponse resp = req.execute().actionGet();

          if (resp.getHits().getTotalHits() > 0) {
            if (resp.getHits().getTotalHits() > 1) {
              String message = "More results found during lookup for value '" + sourceValue + "' using index field '"
                  + idxSf;
View Full Code Here

Examples of org.elasticsearch.action.suggest.SuggestRequestBuilder.execute()

983
984
985
986
987
988
989
990
991
992
993
  }

    public SuggestResponse suggest(SuggestBuilder.SuggestionBuilder<?> suggestion, String... indices) {
  SuggestRequestBuilder suggestRequestBuilder = client.prepareSuggest(indices);
  suggestRequestBuilder.addSuggestion(suggestion);
  return suggestRequestBuilder.execute().actionGet();
    }

    public SuggestResponse suggest(SuggestBuilder.SuggestionBuilder<?> suggestion, Class clazz) {
  return suggest(suggestion, retrieveIndexNameFromPersistentEntity(clazz));
    }
View Full Code Here

Examples of org.elasticsearch.action.update.UpdateRequestBuilder.execute()

457
458
459
460
461
462
463
464
465
466
467
          .setScriptParams(query.getUpdateRequest().scriptParams())
          .setScriptLang(query.getUpdateRequest().scriptLang());
    } else {
      updateRequestBuilder.setDoc(query.getUpdateRequest().doc());
    }
    return updateRequestBuilder.execute().actionGet();
  }

  @Override
  public void bulkIndex(List<IndexQuery> queries) {
    BulkRequestBuilder bulkRequest = client.prepareBulk();
View Full Code Here

Examples of org.elasticsearch.client.Client.execute()

82
83
84
85
86
87
88
89
90
91
92
        client1.execute(SQLAction.INSTANCE, new SQLRequest(
            "insert into t1 (id, string_field, " +
                "timestamp_field, byte_field) values (?, ?, ?, ?)", new Object[]{1, "With",
            "1970-01-01T00:00:00", 127})).actionGet();

        client2.execute(SQLAction.INSTANCE, new SQLRequest(
            "insert into t1 (id, string_field, timestamp_field, byte_field) values (?, ?, ?, ?)",
            new Object[]{2, "Without", "1970-01-01T01:00:00", Byte.MIN_VALUE})).actionGet();
        refresh();
        SQLResponse response = execute("select id, string_field, timestamp_field, byte_field from t1 order by id");
View Full Code Here

Examples of org.elasticsearch.client.action.admin.indices.analyze.AnalyzeRequestBuilder.execute()

97
98
99
100
101
102
103
104
105
106
107
        ).execute().actionGet();

        for (int i = 0; i < 10; i++) {
            final AnalyzeRequestBuilder requestBuilder = client.admin().indices().prepareAnalyze("test", "THIS IS A TEST");
            requestBuilder.setField("document.simple");
            AnalyzeResponse analyzeResponse = requestBuilder.execute().actionGet();
            assertThat(analyzeResponse.tokens().size(), equalTo(4));
            AnalyzeResponse.AnalyzeToken token = analyzeResponse.tokens().get(3);
            assertThat(token.term(), equalTo("test"));
            assertThat(token.startOffset(), equalTo(10));
            assertThat(token.endOffset(), equalTo(14));
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.