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

SearchSourceBuilder.searchSource介绍

[英]A static factory method to construct a new search source.
[中]构造新搜索源的静态工厂方法。

代码示例

代码示例来源：origin: Graylog2/graylog2-server

public void move(String source, String target) {
  final String query = SearchSourceBuilder.searchSource()
      .query(QueryBuilders.matchAllQuery())
      .size(350)

代码示例来源：origin: Graylog2/graylog2-server

.subAggregation(AggregationBuilders.max("ts_max").field(Message.FIELD_TIMESTAMP))
    .subAggregation(AggregationBuilders.terms("streams").field(Message.FIELD_STREAMS));
final String query = searchSource()
    .aggregation(builder)
    .size(0)

代码示例来源：origin: komoot/photon

public long count() {
    return this.esClient.search(Requests.searchRequest(indexName).types(indexType).source(SearchSourceBuilder.searchSource().size(0))).actionGet().getHits()
        .getTotalHits();
  }
}

代码示例来源：origin: com.wuyushuo/vplus-data

@Override
public SearchResponse selectIndex(List<IndexBuilder> batch) throws Exception {
  Optional.ofNullable(batch).orElseThrow(NullPointerException::new);
  SearchSourceBuilder source = SearchSourceBuilder.searchSource();
  source.query(
      QueryBuilders.boolQuery().must(
          QueryBuilders.termsQuery("_id", batch.stream().map(x -> x.getId()).collect(Collectors.toList()))
      )
  );
  SearchRequest request = new SearchRequest();
  request.indices(batch.stream().map(x -> x.getIndex()).collect(Collectors.toList()).toArray(new String[0]));
  request.types(batch.stream().map(x -> x.getType()).collect(Collectors.toList()).toArray(new String[0]));
  request.source(source);
  log.debug(request.toString());
  return client().search(request);
}

代码示例来源：origin: com.wuyushuo/vplus-data

public SearchHits search(String index, String type, Map<String, Object> fields, Condition condition, int page, int size) throws Exception {
  SearchSourceBuilder source = SearchSourceBuilder.searchSource();
  if(Condition.AND == condition){
    BoolQueryBuilder bool = QueryBuilders.boolQuery();
    Optional.ofNullable(fields).orElse(Maps.newHashMap()).forEach((k, v) ->{
      bool.must(QueryBuilders.matchPhraseQuery(k, v));
    });
    source.query(bool);
  }
  if(Condition.OR == condition){
    BoolQueryBuilder bool = QueryBuilders.boolQuery();
    Optional.ofNullable(fields).orElse(Maps.newHashMap()).forEach((k, v) ->{
      bool.should(QueryBuilders.matchPhraseQuery(k, v));
    });
    source.query(bool);
  }
  source.from((Math.abs(page)-1)*Math.abs(size)).size(Math.abs(size));
  SearchRequest request = new SearchRequest();
  request.indices(index).types(type);
  request.source(source);
  log.debug(request.toString());
  return result(client().search(request));
}

代码示例来源：origin: org.graylog2/graylog2-server

public void move(String source, String target) {
  final String query = SearchSourceBuilder.searchSource()
      .query(QueryBuilders.matchAllQuery())
      .size(350)

代码示例来源：origin: tmobile/pacbot

.searchSource().fetchSource(Boolean.TRUE);

代码示例来源：origin: org.graylog2/graylog2-server

.subAggregation(AggregationBuilders.max("ts_max").field(Message.FIELD_TIMESTAMP))
    .subAggregation(AggregationBuilders.terms("streams").field(Message.FIELD_STREAMS));
final String query = searchSource()
    .aggregation(builder)
    .size(0)

代码示例来源：origin: com.floragunn/search-guard

protected MultiSearchRequest toMultiSearchRequest(final MultiGetRequest multiGetRequest) {
  final MultiSearchRequest msearch = new MultiSearchRequest();
  msearch.copyContextFrom(multiGetRequest);
  msearch.listenerThreaded(multiGetRequest.listenerThreaded());
  for (final Iterator<Item> iterator = multiGetRequest.iterator(); iterator.hasNext();) {
    final Item item = iterator.next();
    final SearchRequest st = new SearchRequest();
    st.routing(item.routing());
    st.indices(item.indices());
    st.types(item.type());
    st.listenerThreaded(false);
    st.preference(multiGetRequest.preference());
    st.source(SearchSourceBuilder.searchSource().query(new IdsQueryBuilder(item.type()).addIds(item.id())));
    msearch.add(st);
  }
  return msearch;
}

代码示例来源：origin: com.floragunn/search-guard

protected SearchRequest toSearchRequest(final RestRequest request) {
  final SearchRequest searchRequest = new SearchRequest();
  searchRequest.listenerThreaded(false);
  searchRequest.routing(request.param("routing"));
  searchRequest.copyContextFrom(request);
  searchRequest.preference(request.param("preference"));
  searchRequest.indices(request.param("index"));
  searchRequest.types(request.param("type"));
  searchRequest.source(SearchSourceBuilder.searchSource().query(
      new IdsQueryBuilder(request.param("type")).addIds(request.param("id"))));
  return searchRequest;
}

代码示例来源：origin: com.floragunn/search-guard

protected SearchRequest toSearchRequest(final GetRequest request) {
  final SearchRequest searchRequest = new SearchRequest();
  searchRequest.listenerThreaded(false);
  searchRequest.routing(request.routing());
  searchRequest.copyContextFrom(request);
  searchRequest.preference(request.preference());
  searchRequest.indices(request.indices());
  searchRequest.types(request.type());
  searchRequest.source(SearchSourceBuilder.searchSource().query(new IdsQueryBuilder(request.type()).addIds(request.id())));
  return searchRequest;
}

代码示例来源：origin: org.elasticsearch.plugin/lang-mustache-client

static SearchRequest convert(SearchTemplateRequest searchTemplateRequest, SearchTemplateResponse response, ScriptService scriptService,
                 NamedXContentRegistry xContentRegistry) throws IOException {
    Script script = new Script(searchTemplateRequest.getScriptType(),
      searchTemplateRequest.getScriptType() == ScriptType.STORED ? null : TEMPLATE_LANG, searchTemplateRequest.getScript(),
        searchTemplateRequest.getScriptParams() == null ? Collections.emptyMap() : searchTemplateRequest.getScriptParams());
    TemplateScript compiledScript = scriptService.compile(script, TemplateScript.CONTEXT).newInstance(script.getParams());
    String source = compiledScript.execute();
    response.setSource(new BytesArray(source));

    SearchRequest searchRequest = searchTemplateRequest.getRequest();
    if (searchTemplateRequest.isSimulate()) {
      return null;
    }

    try (XContentParser parser = XContentFactory.xContent(XContentType.JSON)
        .createParser(xContentRegistry, LoggingDeprecationHandler.INSTANCE, source)) {
      SearchSourceBuilder builder = SearchSourceBuilder.searchSource();
      builder.parseXContent(parser, false);
      builder.explain(searchTemplateRequest.isExplain());
      builder.profile(searchTemplateRequest.isProfile());
      searchRequest.source(builder);
    }
    return searchRequest;
  }
}

代码示例来源：origin: org.codelibs.elasticsearch.module/lang-mustache

static SearchRequest convert(SearchTemplateRequest searchTemplateRequest, SearchTemplateResponse response, ScriptService scriptService,
                 NamedXContentRegistry xContentRegistry) throws IOException {
    Script script = new Script(searchTemplateRequest.getScriptType(),
      searchTemplateRequest.getScriptType() == ScriptType.STORED ? null : TEMPLATE_LANG, searchTemplateRequest.getScript(),
        searchTemplateRequest.getScriptParams() == null ? Collections.emptyMap() : searchTemplateRequest.getScriptParams());
    TemplateScript compiledScript = scriptService.compile(script, TemplateScript.CONTEXT).newInstance(script.getParams());
    String source = compiledScript.execute();
    response.setSource(new BytesArray(source));

    SearchRequest searchRequest = searchTemplateRequest.getRequest();
    if (searchTemplateRequest.isSimulate()) {
      return null;
    }

    try (XContentParser parser = XContentFactory.xContent(XContentType.JSON)
        .createParser(xContentRegistry, LoggingDeprecationHandler.INSTANCE, source)) {
      SearchSourceBuilder builder = SearchSourceBuilder.searchSource();
      builder.parseXContent(parser, false);
      builder.explain(searchTemplateRequest.isExplain());
      builder.profile(searchTemplateRequest.isProfile());
      searchRequest.source(builder);
    }
    return searchRequest;
  }
}

代码示例来源：origin: com.floragunn/search-guard

st.listenerThreaded(false);
st.preference(request.param("preference"));
st.source(SearchSourceBuilder.searchSource().query(new IdsQueryBuilder(item.type()).addIds(item.id())));
msearch.add(st);

代码示例来源：origin: lmco/streamflow

SearchSourceBuilder searchBuilder = SearchSourceBuilder.searchSource()
    .query(query)
    .from((criteria.getPageNum() - 1) * criteria.getPageSize())