Package org.elasticsearch.search.query

Examples of org.elasticsearch.search.query.QuerySearchRequest

785
786
787
788
789
790
791
    private class SearchQueryByIdTransportHandler extends BaseTransportRequestHandler<QuerySearchRequest> {

        @Override
        public QuerySearchRequest newInstance() {
            return new QuerySearchRequest();
        }
View Full Code Here
842
843
844
845
846
847
848
    private class SearchQueryQueryFetchTransportHandler extends BaseTransportRequestHandler<QuerySearchRequest> {

        @Override
        public QuerySearchRequest newInstance() {
            return new QuerySearchRequest();
        }
View Full Code Here
85
86
87
88
89
90
91
92
93
            final AtomicInteger counter = new AtomicInteger(firstResults.asList().size());

            for (final AtomicArray.Entry<DfsSearchResult> entry : firstResults.asList()) {
                DfsSearchResult dfsResult = entry.value;
                DiscoveryNode node = nodes.get(dfsResult.shardTarget().nodeId());
                QuerySearchRequest querySearchRequest = new QuerySearchRequest(request, dfsResult.id(), dfs);
                executeSecondPhase(entry.index, dfsResult, counter, node, querySearchRequest);
            }
        }
View Full Code Here
94
95
96
97
98
99
100
101
102
            final AggregatedDfs dfs = searchPhaseController.aggregateDfs(firstResults);
            final AtomicInteger counter = new AtomicInteger(firstResults.asList().size());
            for (final AtomicArray.Entry<DfsSearchResult> entry : firstResults.asList()) {
                DfsSearchResult dfsResult = entry.value;
                DiscoveryNode node = nodes.get(dfsResult.shardTarget().nodeId());
                QuerySearchRequest querySearchRequest = new QuerySearchRequest(request, dfsResult.id(), dfs);
                executeQuery(entry.index, dfsResult, counter, querySearchRequest, node);
            }
        }
View Full Code Here
TOP

Related Classes of org.elasticsearch.search.query.QuerySearchRequest

  • org.elasticsearch.action.OriginalIndices
  • org.elasticsearch.action.search.type.TransportSearchDfsQueryAndFetchAction$AsyncAction
  • org.elasticsearch.action.search.type.TransportSearchDfsQueryThenFetchAction$AsyncAction
  • org.elasticsearch.search.action.SearchServiceTransportAction$SearchQueryByIdTransportHandler
  • org.elasticsearch.search.action.SearchServiceTransportAction$SearchQueryQueryFetchTransportHandler
  • org.elasticsearch.test.integration.search.embedded.SingleShardEmbeddedSearchTests
  • org.elasticsearch.test.integration.search.embedded.ThreeShardsEmbeddedSearchTests
  • org.elasticsearch.test.integration.search.embedded.ThreeShardsUnbalancedShardsEmbeddedSearchTests
    • 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.