Examples of totalHits()

Examples of org.elasticsearch.search.SearchHits.totalHits()

210
211
212
213
214
215
216
217
218
219
220
            FetchSearchResult fetchResult = nodeToSearchService.get(shardTarget.nodeId()).executeFetchPhase(new FetchSearchRequest(queryResults.get(shardTarget).queryResult().id(), docIds));
            fetchResults.put(fetchResult.shardTarget(), fetchResult.initCounter());
        }

        SearchHits hits = searchPhaseController.merge(sortedShardList, queryResults, fetchResults).hits();
        assertThat(hits.totalHits(), equalTo(100l));
        assertThat(hits.hits().length, equalTo(60));
        for (int i = 0; i < 60; i++) {
            SearchHit hit = hits.hits()[i];
//            System.out.println(hit.explanation());
            assertThat("id[" + hit.id() + "]", hit.id(), equalTo(Integer.toString(i)));
View Full Code Here

Examples of org.elasticsearch.search.SearchHits.totalHits()

237
238
239
240
241
242
243
244
245
246
247
            FetchSearchResult fetchResult = nodeToSearchService.get(shardTarget.nodeId()).executeFetchPhase(new FetchSearchRequest(queryResults.get(shardTarget).queryResult().id(), docIds));
            fetchResults.put(fetchResult.shardTarget(), fetchResult.initCounter());
        }

        hits = searchPhaseController.merge(sortedShardList, queryResults, fetchResults).hits();
        assertThat(hits.totalHits(), equalTo(100l));
        assertThat(hits.hits().length, equalTo(40));
        for (int i = 0; i < 40; i++) {
            SearchHit hit = hits.hits()[i];
            assertThat("id[" + hit.id() + "]", hit.id(), equalTo(Integer.toString(i + 60)));
        }
View Full Code Here

Examples of org.elasticsearch.search.SearchHits.totalHits()

263
264
265
266
267
268
269
270
271
272
273
            FetchSearchResult fetchResult = nodeToSearchService.get(shardTarget.nodeId()).executeFetchPhase(new FetchSearchRequest(queryResults.get(shardTarget).queryResult().id(), docIds));
            fetchResults.put(fetchResult.shardTarget(), fetchResult.initCounter());
        }

        hits = searchPhaseController.merge(sortedShardList, queryResults, fetchResults).hits();
        assertThat(hits.totalHits(), equalTo(100l));
        assertThat(hits.hits().length, equalTo(0));
    }

    @Test public void testQueryAndFetch() {
        SearchSourceBuilder sourceBuilder = searchSource()
View Full Code Here

Examples of org.elasticsearch.search.SearchHits.totalHits()

291
292
293
294
295
296
297
298
299
300
301

        ShardDoc[] sortedShardList = searchPhaseController.sortDocs(queryFetchResults.values());
        SearchHits hits = searchPhaseController.merge(sortedShardList, queryFetchResults, queryFetchResults).hits();

        assertThat(hits.totalHits(), equalTo(100l));
        assertThat(hits.hits().length, equalTo(60)); // 60 results, with size 20, since we have 3 shards
        for (int i = 0; i < 60; i++) {
            SearchHit hit = hits.hits()[i];
//            System.out.println(hit.id() + " " + hit.explanation());
//            assertThat("id[" + hit.id() + "]", hit.id(), equalTo(Integer.toString(100 - i - 1)));
View Full Code Here

Examples of org.elasticsearch.search.SearchHits.totalHits()

310
311
312
313
314
315
316
317
318
319
320
        }
        queryFetchResults = scrollQueryFetchResults;

        sortedShardList = searchPhaseController.sortDocs(queryFetchResults.values());
        hits = searchPhaseController.merge(sortedShardList, queryFetchResults, queryFetchResults).hits();
        assertThat(hits.totalHits(), equalTo(100l));
        assertThat(hits.hits().length, equalTo(40));
        for (int i = 0; i < 40; i++) {
            SearchHit hit = hits.hits()[i];
//            System.out.println(hit.id() + " " + hit.explanation());
            // we don't do perfect sorting when it comes to scroll with Query+Fetch
View Full Code Here

Examples of org.elasticsearch.search.SearchHits.totalHits()

143
144
145
146
147
148
149
150
151
152
153
            fetchResults.put(fetchResult.shardTarget(), fetchResult.initCounter());
        }

        SearchHits hits = searchPhaseController.merge(sortedShardList, queryResults, fetchResults).hits();

        assertThat(hits.totalHits(), equalTo(100l));
        assertThat(hits.hits().length, equalTo(60));
        for (int i = 0; i < 60; i++) {
            SearchHit hit = hits.hits()[i];
//            System.out.println(hit.explanation());
            assertThat("id[" + hit.id() + "]", hit.id(), equalTo(Integer.toString(100 - i - 1)));
View Full Code Here

Examples of org.elasticsearch.search.SearchHits.totalHits()

170
171
172
173
174
175
176
177
178
179
180
            FetchSearchResult fetchResult = nodeToSearchService.get(shardTarget.nodeId()).executeFetchPhase(new FetchSearchRequest(queryResults.get(shardTarget).queryResult().id(), docIds));
            fetchResults.put(fetchResult.shardTarget(), fetchResult.initCounter());
        }

        hits = searchPhaseController.merge(sortedShardList, queryResults, fetchResults).hits();
        assertThat(hits.totalHits(), equalTo(100l));
        assertThat(hits.hits().length, equalTo(40));
        for (int i = 0; i < 40; i++) {
            SearchHit hit = hits.hits()[i];
            assertThat("id[" + hit.id() + "]", hit.id(), equalTo(Integer.toString(100 - 60 - 1 - i)));
        }
View Full Code Here

Examples of org.elasticsearch.search.SearchHits.totalHits()

71
72
73
74
75
76
77
78
79
80
81
                };
            }

            @Override
            public long totalHits() {
                return hits.totalHits();
            }
        };
    }

    @Override public String scrollId() {
View Full Code Here

Examples of org.elasticsearch.search.SearchHits.totalHits()

404
405
406
407
408
409
410
411
412
413
414
    @Test
    public void testLetUpdateFailButMergeToGetCorrectRetweetCount() throws IOException {
        twSearch.testUpdate(createTweet(1L, "text", "peter"));
        SearchHits h = twSearch.query(new TweetQuery()).hits();
        assertEquals(1, h.totalHits());

        Collection<Integer> res = twSearch.bulkUpdate(
                Arrays.asList(createTweet(1L, "text", "peter").setRetweetCount(1).setVersion(10)),
                twSearch.getIndexName());
        assertEquals(1, res.size());
View Full Code Here

Examples of org.elasticsearch.search.SearchHits.totalHits()

425
426
427
428
429
430
431
432
433
434
435
    @Test
    public void testVersionCollision() throws IOException {
        twSearch.testUpdate(createTweet(1L, "text", "peter"));
        SearchHits h = twSearch.query(new TweetQuery()).hits();
        assertEquals(1, h.totalHits());

        Collection<Integer> res = twSearch.bulkUpdate(
                Arrays.asList(createTweet(1L, "text", "peter").setRetweetCount(1).setVersion(h.hits()[0].getVersion())),
                twSearch.getIndexName());
        assertEquals(0, res.size());
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.