summaryrefslogtreecommitdiff
path: root/core/src/test/java/org/elasticsearch/search/aggregations/metrics/AvgIT.java
diff options
context:
space:
mode:
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.java49
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);