diff options
Diffstat (limited to 'core/src/test/java/org/elasticsearch/search/aggregations/metrics/AvgIT.java')
-rw-r--r-- | core/src/test/java/org/elasticsearch/search/aggregations/metrics/AvgIT.java | 49 |
1 files changed, 21 insertions, 28 deletions
diff --git a/core/src/test/java/org/elasticsearch/search/aggregations/metrics/AvgIT.java b/core/src/test/java/org/elasticsearch/search/aggregations/metrics/AvgIT.java index db02d6ccb0..2ce78e451c 100644 --- a/core/src/test/java/org/elasticsearch/search/aggregations/metrics/AvgIT.java +++ b/core/src/test/java/org/elasticsearch/search/aggregations/metrics/AvgIT.java @@ -26,6 +26,7 @@ import org.elasticsearch.script.CompiledScript; import org.elasticsearch.script.ExecutableScript; import org.elasticsearch.script.LeafSearchScript; import org.elasticsearch.script.Script; +import org.elasticsearch.script.ScriptEngineRegistry; import org.elasticsearch.script.ScriptEngineService; import org.elasticsearch.script.ScriptModule; import org.elasticsearch.script.ScriptService.ScriptType; @@ -71,10 +72,10 @@ public class AvgIT extends AbstractNumericTestCase { SearchResponse searchResponse = client().prepareSearch("empty_bucket_idx") .setQuery(matchAllQuery()) - .addAggregation(histogram("histo").field("value").interval(1l).minDocCount(0).subAggregation(avg("avg"))) + .addAggregation(histogram("histo").field("value").interval(1L).minDocCount(0).subAggregation(avg("avg"))) .execute().actionGet(); - assertThat(searchResponse.getHits().getTotalHits(), equalTo(2l)); + assertThat(searchResponse.getHits().getTotalHits(), equalTo(2L)); Histogram histo = searchResponse.getAggregations().get("histo"); assertThat(histo, notNullValue()); Histogram.Bucket bucket = histo.getBuckets().get(1); @@ -93,7 +94,7 @@ public class AvgIT extends AbstractNumericTestCase { .addAggregation(avg("avg").field("value")) .execute().actionGet(); - assertThat(searchResponse.getHits().getTotalHits(), equalTo(0l)); + assertThat(searchResponse.getHits().getTotalHits(), equalTo(0L)); Avg avg = searchResponse.getAggregations().get("avg"); assertThat(avg, notNullValue()); @@ -127,7 +128,7 @@ public class AvgIT extends AbstractNumericTestCase { Global global = searchResponse.getAggregations().get("global"); assertThat(global, notNullValue()); assertThat(global.getName(), equalTo("global")); - assertThat(global.getDocCount(), equalTo(10l)); + assertThat(global.getDocCount(), equalTo(10L)); assertThat(global.getAggregations(), notNullValue()); assertThat(global.getAggregations().asMap().size(), equalTo(1)); @@ -332,7 +333,7 @@ public class AvgIT extends AbstractNumericTestCase { } public void onModule(ScriptModule module) { - module.addScriptEngine(ExtractFieldScriptEngine.class); + module.addScriptEngine(new ScriptEngineRegistry.ScriptEngineRegistration(ExtractFieldScriptEngine.class, ExtractFieldScriptEngine.TYPES)); } } @@ -344,22 +345,24 @@ public class AvgIT extends AbstractNumericTestCase { public static final String NAME = "extract_field"; + public static final List<String> TYPES = Collections.singletonList(NAME); + @Override public void close() throws IOException { } @Override - public String[] types() { - return new String[] { NAME }; + public List<String> getTypes() { + return TYPES; } @Override - public String[] extensions() { - return types(); + public List<String> getExtensions() { + return TYPES; } @Override - public boolean sandboxed() { + public boolean isSandboxed() { return true; } @@ -388,12 +391,6 @@ public class AvgIT extends AbstractNumericTestCase { final LeafSearchLookup leafLookup = lookup.getLeafSearchLookup(context); return new LeafSearchScript() { - - @Override - public Object unwrap(Object value) { - return null; - } - @Override public void setNextVar(String name, Object value) { } @@ -468,7 +465,7 @@ public class AvgIT extends AbstractNumericTestCase { } public void onModule(ScriptModule module) { - module.addScriptEngine(FieldValueScriptEngine.class); + module.addScriptEngine(new ScriptEngineRegistry.ScriptEngineRegistration(FieldValueScriptEngine.class, FieldValueScriptEngine.TYPES)); } } @@ -480,22 +477,24 @@ public class AvgIT extends AbstractNumericTestCase { public static final String NAME = "field_value"; + public static final List<String> TYPES = Collections.singletonList(NAME); + @Override public void close() throws IOException { } @Override - public String[] types() { - return new String[] { NAME }; + public List<String> getTypes() { + return TYPES; } @Override - public String[] extensions() { - return types(); + public List<String> getExtensions() { + return TYPES; } @Override - public boolean sandboxed() { + public boolean isSandboxed() { return true; } @@ -526,12 +525,6 @@ public class AvgIT extends AbstractNumericTestCase { final LeafSearchLookup leafLookup = lookup.getLeafSearchLookup(context); return new LeafSearchScript() { - - @Override - public Object unwrap(Object value) { - throw new UnsupportedOperationException(); - } - @Override public void setNextVar(String name, Object value) { vars.put(name, value); |