diff options
author | Simon Willnauer <simonw@apache.org> | 2017-02-08 14:40:08 +0100 |
---|---|---|
committer | GitHub <noreply@github.com> | 2017-02-08 14:40:08 +0100 |
commit | ecb01c15b9a6645f22f153eb099a377e70e398c8 (patch) | |
tree | 6281a85417a51ac6265e44d93ff92322fee4b199 /core/src/test/java/org/elasticsearch/recovery | |
parent | 2d6d871f5c70b11c23a5b99b5e3a0bf0cff8c6b0 (diff) |
Fold InternalSearchHits and friends into their interfaces (#23042)
We have a bunch of interfaces that have only a single implementation
for 6 years now. These interfaces are pretty useless from a SW development
perspective and only add unnecessary abstractions. They also require
lots of casting in many places where we expect that there is only one
concrete implementation. This change removes the interfaces, makes
all of the classes final and removes the duplicate `foo` `getFoo` accessors
in favor of `getFoo` from these classes.
Diffstat (limited to 'core/src/test/java/org/elasticsearch/recovery')
-rw-r--r-- | core/src/test/java/org/elasticsearch/recovery/RecoveryWhileUnderLoadIT.java | 6 | ||||
-rw-r--r-- | core/src/test/java/org/elasticsearch/recovery/RelocationIT.java | 16 |
2 files changed, 11 insertions, 11 deletions
diff --git a/core/src/test/java/org/elasticsearch/recovery/RecoveryWhileUnderLoadIT.java b/core/src/test/java/org/elasticsearch/recovery/RecoveryWhileUnderLoadIT.java index d0dd969d0c..57249e186d 100644 --- a/core/src/test/java/org/elasticsearch/recovery/RecoveryWhileUnderLoadIT.java +++ b/core/src/test/java/org/elasticsearch/recovery/RecoveryWhileUnderLoadIT.java @@ -276,7 +276,7 @@ public class RecoveryWhileUnderLoadIT extends ESIntegTestCase { SearchResponse searchResponse = client().prepareSearch().setSize((int) numberOfDocs).setQuery(matchAllQuery()).addSort("id", SortOrder.ASC).get(); logSearchResponse(numberOfShards, numberOfDocs, i, searchResponse); iterationResults[i] = searchResponse; - if (searchResponse.getHits().totalHits() != numberOfDocs) { + if (searchResponse.getHits().getTotalHits() != numberOfDocs) { error = true; } } @@ -312,7 +312,7 @@ public class RecoveryWhileUnderLoadIT extends ESIntegTestCase { boolean errorOccurred = false; for (int i = 0; i < iterations; i++) { SearchResponse searchResponse = client().prepareSearch().setSize(0).setQuery(matchAllQuery()).get(); - if (searchResponse.getHits().totalHits() != numberOfDocs) { + if (searchResponse.getHits().getTotalHits() != numberOfDocs) { errorOccurred = true; } } @@ -337,7 +337,7 @@ public class RecoveryWhileUnderLoadIT extends ESIntegTestCase { if (searchResponse.getShardFailures() != null && searchResponse.getShardFailures().length > 0) { logger.info("iteration [{}] - shard failures: {}", iteration, Arrays.toString(searchResponse.getShardFailures())); } - logger.info("iteration [{}] - returned documents: {} (expected {})", iteration, searchResponse.getHits().totalHits(), numberOfDocs); + logger.info("iteration [{}] - returned documents: {} (expected {})", iteration, searchResponse.getHits().getTotalHits(), numberOfDocs); } private void refreshAndAssert() throws Exception { diff --git a/core/src/test/java/org/elasticsearch/recovery/RelocationIT.java b/core/src/test/java/org/elasticsearch/recovery/RelocationIT.java index f32688aaff..8848a61c97 100644 --- a/core/src/test/java/org/elasticsearch/recovery/RelocationIT.java +++ b/core/src/test/java/org/elasticsearch/recovery/RelocationIT.java @@ -165,7 +165,7 @@ public class RelocationIT extends ESIntegTestCase { logger.info("--> verifying count"); client().admin().indices().prepareRefresh().execute().actionGet(); - assertThat(client().prepareSearch("test").setSize(0).execute().actionGet().getHits().totalHits(), equalTo(20L)); + assertThat(client().prepareSearch("test").setSize(0).execute().actionGet().getHits().getTotalHits(), equalTo(20L)); logger.info("--> start another node"); final String node_2 = internalCluster().startNode(); @@ -182,7 +182,7 @@ public class RelocationIT extends ESIntegTestCase { logger.info("--> verifying count again..."); client().admin().indices().prepareRefresh().execute().actionGet(); - assertThat(client().prepareSearch("test").setSize(0).execute().actionGet().getHits().totalHits(), equalTo(20L)); + assertThat(client().prepareSearch("test").setSize(0).execute().actionGet().getHits().getTotalHits(), equalTo(20L)); } @TestLogging("org.elasticsearch.action.bulk:TRACE,org.elasticsearch.action.search:TRACE") @@ -256,14 +256,14 @@ public class RelocationIT extends ESIntegTestCase { logger.info("--> START search test round {}", i + 1); SearchHits hits = client().prepareSearch("test").setQuery(matchAllQuery()).setSize((int) indexer.totalIndexedDocs()).storedFields().execute().actionGet().getHits(); ranOnce = true; - if (hits.totalHits() != indexer.totalIndexedDocs()) { + if (hits.getTotalHits() != indexer.totalIndexedDocs()) { int[] hitIds = new int[(int) indexer.totalIndexedDocs()]; for (int hit = 0; hit < indexer.totalIndexedDocs(); hit++) { hitIds[hit] = hit + 1; } IntHashSet set = IntHashSet.from(hitIds); - for (SearchHit hit : hits.hits()) { - int id = Integer.parseInt(hit.id()); + for (SearchHit hit : hits.getHits()) { + int id = Integer.parseInt(hit.getId()); if (!set.remove(id)) { logger.error("Extra id [{}]", id); } @@ -272,7 +272,7 @@ public class RelocationIT extends ESIntegTestCase { logger.error("Missing id [{}]", value); }); } - assertThat(hits.totalHits(), equalTo(indexer.totalIndexedDocs())); + assertThat(hits.getTotalHits(), equalTo(indexer.totalIndexedDocs())); logger.info("--> DONE search test round {}", i + 1); } @@ -369,9 +369,9 @@ public class RelocationIT extends ESIntegTestCase { SearchResponse response = client.prepareSearch("test").setPreference("_local").setSize(0).get(); assertNoFailures(response); if (expectedCount < 0) { - expectedCount = response.getHits().totalHits(); + expectedCount = response.getHits().getTotalHits(); } else { - assertEquals(expectedCount, response.getHits().totalHits()); + assertEquals(expectedCount, response.getHits().getTotalHits()); } } |