summaryrefslogtreecommitdiff
path: root/core/src/test/java/org/elasticsearch/search/aggregations/BaseAggregationTestCase.java
diff options
context:
space:
mode:
authorIsabel Drost-Fromm <isabel.drostfromm@elasticsearch.com>2016-03-29 11:04:02 +0200
committerIsabel Drost-Fromm <isabel.drostfromm@elasticsearch.com>2016-03-29 11:04:02 +0200
commit407e2cdcf93475e2b326228eaf169fa2572d7d8b (patch)
tree3810be0a7ec51b990fef5b2f7a9cb1ecf3557b10 /core/src/test/java/org/elasticsearch/search/aggregations/BaseAggregationTestCase.java
parent5dd481bfe3ef81a59217f7809ca51dc4f31b893e (diff)
parentc7bdfb1126d47442f7e12f996eecbb7fab315c2d (diff)
Merge branch 'master' into deprecation/sort-option-reverse-removal
Conflicts: core/src/main/java/org/elasticsearch/search/sort/ScoreSortBuilder.java core/src/test/java/org/elasticsearch/search/sort/FieldSortBuilderTests.java
Diffstat (limited to 'core/src/test/java/org/elasticsearch/search/aggregations/BaseAggregationTestCase.java')
-rw-r--r--core/src/test/java/org/elasticsearch/search/aggregations/BaseAggregationTestCase.java9
1 files changed, 3 insertions, 6 deletions
diff --git a/core/src/test/java/org/elasticsearch/search/aggregations/BaseAggregationTestCase.java b/core/src/test/java/org/elasticsearch/search/aggregations/BaseAggregationTestCase.java
index 4a12072da4..0d65bb2bf6 100644
--- a/core/src/test/java/org/elasticsearch/search/aggregations/BaseAggregationTestCase.java
+++ b/core/src/test/java/org/elasticsearch/search/aggregations/BaseAggregationTestCase.java
@@ -252,9 +252,8 @@ public abstract class BaseAggregationTestCase<AB extends AggregatorBuilder<AB>>
try (BytesStreamOutput output = new BytesStreamOutput()) {
testAgg.writeTo(output);
try (StreamInput in = new NamedWriteableAwareStreamInput(StreamInput.wrap(output.bytes()), namedWriteableRegistry)) {
- AggregatorBuilder prototype = (AggregatorBuilder) namedWriteableRegistry.getPrototype(AggregatorBuilder.class,
- testAgg.getWriteableName());
- AggregatorBuilder deserializedQuery = prototype.readFrom(in);
+ AggregatorBuilder deserializedQuery = namedWriteableRegistry.getReader(AggregatorBuilder.class, testAgg.getWriteableName())
+ .read(in);
assertEquals(deserializedQuery, testAgg);
assertEquals(deserializedQuery.hashCode(), testAgg.hashCode());
assertNotSame(deserializedQuery, testAgg);
@@ -294,10 +293,8 @@ public abstract class BaseAggregationTestCase<AB extends AggregatorBuilder<AB>>
try (BytesStreamOutput output = new BytesStreamOutput()) {
agg.writeTo(output);
try (StreamInput in = new NamedWriteableAwareStreamInput(StreamInput.wrap(output.bytes()), namedWriteableRegistry)) {
- AggregatorBuilder prototype = (AggregatorBuilder) namedWriteableRegistry.getPrototype(AggregatorBuilder.class,
- agg.getWriteableName());
@SuppressWarnings("unchecked")
- AB secondAgg = (AB) prototype.readFrom(in);
+ AB secondAgg = (AB) namedWriteableRegistry.getReader(AggregatorBuilder.class, agg.getWriteableName()).read(in);
return secondAgg;
}
}