Merge pull request #15815 from nik9000/xlint2
Remove a few more Xlint skips
This commit is contained in:
commit
439832d0b3
|
@ -35,6 +35,3 @@ dependencyLicenses {
|
||||||
mapping from: /asm-.*/, to: 'asm'
|
mapping from: /asm-.*/, to: 'asm'
|
||||||
}
|
}
|
||||||
|
|
||||||
compileJava.options.compilerArgs << '-Xlint:-rawtypes'
|
|
||||||
compileTestJava.options.compilerArgs << '-Xlint:-rawtypes'
|
|
||||||
|
|
||||||
|
|
|
@ -19,6 +19,10 @@
|
||||||
|
|
||||||
package org.elasticsearch.script.expression;
|
package org.elasticsearch.script.expression;
|
||||||
|
|
||||||
|
import java.io.IOException;
|
||||||
|
import java.util.Map;
|
||||||
|
import java.util.Objects;
|
||||||
|
|
||||||
import org.apache.lucene.index.LeafReaderContext;
|
import org.apache.lucene.index.LeafReaderContext;
|
||||||
import org.apache.lucene.queries.function.FunctionValues;
|
import org.apache.lucene.queries.function.FunctionValues;
|
||||||
import org.apache.lucene.queries.function.ValueSource;
|
import org.apache.lucene.queries.function.ValueSource;
|
||||||
|
@ -26,10 +30,6 @@ import org.elasticsearch.index.fielddata.AtomicFieldData;
|
||||||
import org.elasticsearch.index.fielddata.AtomicNumericFieldData;
|
import org.elasticsearch.index.fielddata.AtomicNumericFieldData;
|
||||||
import org.elasticsearch.index.fielddata.IndexFieldData;
|
import org.elasticsearch.index.fielddata.IndexFieldData;
|
||||||
|
|
||||||
import java.io.IOException;
|
|
||||||
import java.util.Map;
|
|
||||||
import java.util.Objects;
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* A ValueSource to create FunctionValues to get the count of the number of values in a field for a document.
|
* A ValueSource to create FunctionValues to get the count of the number of values in a field for a document.
|
||||||
*/
|
*/
|
||||||
|
@ -43,6 +43,7 @@ public class CountMethodValueSource extends ValueSource {
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
|
@SuppressWarnings("rawtypes") // ValueSource uses a rawtype
|
||||||
public FunctionValues getValues(Map context, LeafReaderContext leaf) throws IOException {
|
public FunctionValues getValues(Map context, LeafReaderContext leaf) throws IOException {
|
||||||
AtomicFieldData leafData = fieldData.load(leaf);
|
AtomicFieldData leafData = fieldData.load(leaf);
|
||||||
assert(leafData instanceof AtomicNumericFieldData);
|
assert(leafData instanceof AtomicNumericFieldData);
|
||||||
|
|
|
@ -19,6 +19,10 @@
|
||||||
|
|
||||||
package org.elasticsearch.script.expression;
|
package org.elasticsearch.script.expression;
|
||||||
|
|
||||||
|
import java.io.IOException;
|
||||||
|
import java.util.Map;
|
||||||
|
import java.util.Objects;
|
||||||
|
|
||||||
import org.apache.lucene.index.LeafReaderContext;
|
import org.apache.lucene.index.LeafReaderContext;
|
||||||
import org.apache.lucene.queries.function.FunctionValues;
|
import org.apache.lucene.queries.function.FunctionValues;
|
||||||
import org.elasticsearch.index.fielddata.AtomicFieldData;
|
import org.elasticsearch.index.fielddata.AtomicFieldData;
|
||||||
|
@ -26,10 +30,6 @@ import org.elasticsearch.index.fielddata.AtomicNumericFieldData;
|
||||||
import org.elasticsearch.index.fielddata.IndexFieldData;
|
import org.elasticsearch.index.fielddata.IndexFieldData;
|
||||||
import org.elasticsearch.search.MultiValueMode;
|
import org.elasticsearch.search.MultiValueMode;
|
||||||
|
|
||||||
import java.io.IOException;
|
|
||||||
import java.util.Map;
|
|
||||||
import java.util.Objects;
|
|
||||||
|
|
||||||
class DateMethodValueSource extends FieldDataValueSource {
|
class DateMethodValueSource extends FieldDataValueSource {
|
||||||
|
|
||||||
protected final String methodName;
|
protected final String methodName;
|
||||||
|
@ -45,6 +45,7 @@ class DateMethodValueSource extends FieldDataValueSource {
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
|
@SuppressWarnings("rawtypes") // ValueSource uses a rawtype
|
||||||
public FunctionValues getValues(Map context, LeafReaderContext leaf) throws IOException {
|
public FunctionValues getValues(Map context, LeafReaderContext leaf) throws IOException {
|
||||||
AtomicFieldData leafData = fieldData.load(leaf);
|
AtomicFieldData leafData = fieldData.load(leaf);
|
||||||
assert(leafData instanceof AtomicNumericFieldData);
|
assert(leafData instanceof AtomicNumericFieldData);
|
||||||
|
|
|
@ -19,6 +19,10 @@
|
||||||
|
|
||||||
package org.elasticsearch.script.expression;
|
package org.elasticsearch.script.expression;
|
||||||
|
|
||||||
|
import java.io.IOException;
|
||||||
|
import java.util.Map;
|
||||||
|
import java.util.Objects;
|
||||||
|
|
||||||
import org.apache.lucene.index.LeafReaderContext;
|
import org.apache.lucene.index.LeafReaderContext;
|
||||||
import org.apache.lucene.queries.function.FunctionValues;
|
import org.apache.lucene.queries.function.FunctionValues;
|
||||||
import org.apache.lucene.queries.function.ValueSource;
|
import org.apache.lucene.queries.function.ValueSource;
|
||||||
|
@ -27,10 +31,6 @@ import org.elasticsearch.index.fielddata.AtomicNumericFieldData;
|
||||||
import org.elasticsearch.index.fielddata.IndexFieldData;
|
import org.elasticsearch.index.fielddata.IndexFieldData;
|
||||||
import org.elasticsearch.search.MultiValueMode;
|
import org.elasticsearch.search.MultiValueMode;
|
||||||
|
|
||||||
import java.io.IOException;
|
|
||||||
import java.util.Map;
|
|
||||||
import java.util.Objects;
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* A {@link ValueSource} wrapper for field data.
|
* A {@link ValueSource} wrapper for field data.
|
||||||
*/
|
*/
|
||||||
|
@ -67,6 +67,7 @@ class FieldDataValueSource extends ValueSource {
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
|
@SuppressWarnings("rawtypes") // ValueSource uses a rawtype
|
||||||
public FunctionValues getValues(Map context, LeafReaderContext leaf) throws IOException {
|
public FunctionValues getValues(Map context, LeafReaderContext leaf) throws IOException {
|
||||||
AtomicFieldData leafData = fieldData.load(leaf);
|
AtomicFieldData leafData = fieldData.load(leaf);
|
||||||
assert(leafData instanceof AtomicNumericFieldData);
|
assert(leafData instanceof AtomicNumericFieldData);
|
||||||
|
|
|
@ -19,13 +19,13 @@
|
||||||
|
|
||||||
package org.elasticsearch.script.expression;
|
package org.elasticsearch.script.expression;
|
||||||
|
|
||||||
|
import java.io.IOException;
|
||||||
|
import java.util.Map;
|
||||||
|
|
||||||
import org.apache.lucene.index.LeafReaderContext;
|
import org.apache.lucene.index.LeafReaderContext;
|
||||||
import org.apache.lucene.queries.function.FunctionValues;
|
import org.apache.lucene.queries.function.FunctionValues;
|
||||||
import org.apache.lucene.queries.function.ValueSource;
|
import org.apache.lucene.queries.function.ValueSource;
|
||||||
|
|
||||||
import java.io.IOException;
|
|
||||||
import java.util.Map;
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* A {@link ValueSource} which has a stub {@link FunctionValues} that holds a dynamically replaceable constant double.
|
* A {@link ValueSource} which has a stub {@link FunctionValues} that holds a dynamically replaceable constant double.
|
||||||
*/
|
*/
|
||||||
|
@ -37,6 +37,7 @@ class ReplaceableConstValueSource extends ValueSource {
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
|
@SuppressWarnings("rawtypes") // ValueSource uses a rawtype
|
||||||
public FunctionValues getValues(Map map, LeafReaderContext atomicReaderContext) throws IOException {
|
public FunctionValues getValues(Map map, LeafReaderContext atomicReaderContext) throws IOException {
|
||||||
return fv;
|
return fv;
|
||||||
}
|
}
|
||||||
|
|
|
@ -19,6 +19,12 @@
|
||||||
|
|
||||||
package org.elasticsearch.script.expression;
|
package org.elasticsearch.script.expression;
|
||||||
|
|
||||||
|
import java.util.Collection;
|
||||||
|
import java.util.Collections;
|
||||||
|
import java.util.HashMap;
|
||||||
|
import java.util.List;
|
||||||
|
import java.util.Map;
|
||||||
|
|
||||||
import org.apache.lucene.expressions.Expression;
|
import org.apache.lucene.expressions.Expression;
|
||||||
import org.apache.lucene.expressions.js.JavascriptCompiler;
|
import org.apache.lucene.expressions.js.JavascriptCompiler;
|
||||||
import org.elasticsearch.action.search.SearchPhaseExecutionException;
|
import org.elasticsearch.action.search.SearchPhaseExecutionException;
|
||||||
|
@ -47,12 +53,6 @@ import org.elasticsearch.search.sort.SortOrder;
|
||||||
import org.elasticsearch.test.ESIntegTestCase;
|
import org.elasticsearch.test.ESIntegTestCase;
|
||||||
import org.elasticsearch.test.hamcrest.ElasticsearchAssertions;
|
import org.elasticsearch.test.hamcrest.ElasticsearchAssertions;
|
||||||
|
|
||||||
import java.util.Collection;
|
|
||||||
import java.util.Collections;
|
|
||||||
import java.util.HashMap;
|
|
||||||
import java.util.List;
|
|
||||||
import java.util.Map;
|
|
||||||
|
|
||||||
import static org.elasticsearch.search.aggregations.AggregationBuilders.histogram;
|
import static org.elasticsearch.search.aggregations.AggregationBuilders.histogram;
|
||||||
import static org.elasticsearch.search.aggregations.AggregationBuilders.sum;
|
import static org.elasticsearch.search.aggregations.AggregationBuilders.sum;
|
||||||
import static org.elasticsearch.search.aggregations.pipeline.PipelineAggregatorBuilders.bucketScript;
|
import static org.elasticsearch.search.aggregations.pipeline.PipelineAggregatorBuilders.bucketScript;
|
||||||
|
@ -121,7 +121,7 @@ public class MoreExpressionTests extends ESIntegTestCase {
|
||||||
client().prepareIndex("test", "doc", "1").setSource("text", "hello goodbye"),
|
client().prepareIndex("test", "doc", "1").setSource("text", "hello goodbye"),
|
||||||
client().prepareIndex("test", "doc", "2").setSource("text", "hello hello hello goodbye"),
|
client().prepareIndex("test", "doc", "2").setSource("text", "hello hello hello goodbye"),
|
||||||
client().prepareIndex("test", "doc", "3").setSource("text", "hello hello goodebye"));
|
client().prepareIndex("test", "doc", "3").setSource("text", "hello hello goodebye"));
|
||||||
ScoreFunctionBuilder score = ScoreFunctionBuilders.scriptFunction(new Script("1 / _score", ScriptType.INLINE, "expression", null));
|
ScoreFunctionBuilder<?> score = ScoreFunctionBuilders.scriptFunction(new Script("1 / _score", ScriptType.INLINE, "expression", null));
|
||||||
SearchRequestBuilder req = client().prepareSearch().setIndices("test");
|
SearchRequestBuilder req = client().prepareSearch().setIndices("test");
|
||||||
req.setQuery(QueryBuilders.functionScoreQuery(QueryBuilders.termQuery("text", "hello"), score).boostMode(CombineFunction.REPLACE));
|
req.setQuery(QueryBuilders.functionScoreQuery(QueryBuilders.termQuery("text", "hello"), score).boostMode(CombineFunction.REPLACE));
|
||||||
req.setSearchType(SearchType.DFS_QUERY_THEN_FETCH); // make sure DF is consistent
|
req.setSearchType(SearchType.DFS_QUERY_THEN_FETCH); // make sure DF is consistent
|
||||||
|
|
|
@ -30,6 +30,3 @@ dependencies {
|
||||||
dependencyLicenses {
|
dependencyLicenses {
|
||||||
mapping from: /lucene-.*/, to: 'lucene'
|
mapping from: /lucene-.*/, to: 'lucene'
|
||||||
}
|
}
|
||||||
|
|
||||||
compileJava.options.compilerArgs << "-Xlint:-rawtypes,-unchecked"
|
|
||||||
|
|
||||||
|
|
|
@ -19,6 +19,9 @@
|
||||||
|
|
||||||
package org.elasticsearch.index.analysis;
|
package org.elasticsearch.index.analysis;
|
||||||
|
|
||||||
|
import java.util.Arrays;
|
||||||
|
import java.util.HashSet;
|
||||||
|
|
||||||
import org.apache.commons.codec.Encoder;
|
import org.apache.commons.codec.Encoder;
|
||||||
import org.apache.commons.codec.language.Caverphone1;
|
import org.apache.commons.codec.language.Caverphone1;
|
||||||
import org.apache.commons.codec.language.Caverphone2;
|
import org.apache.commons.codec.language.Caverphone2;
|
||||||
|
@ -43,9 +46,6 @@ import org.elasticsearch.index.analysis.phonetic.HaasePhonetik;
|
||||||
import org.elasticsearch.index.analysis.phonetic.KoelnerPhonetik;
|
import org.elasticsearch.index.analysis.phonetic.KoelnerPhonetik;
|
||||||
import org.elasticsearch.index.analysis.phonetic.Nysiis;
|
import org.elasticsearch.index.analysis.phonetic.Nysiis;
|
||||||
|
|
||||||
import java.util.Arrays;
|
|
||||||
import java.util.HashSet;
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
*
|
*
|
||||||
*/
|
*/
|
||||||
|
@ -122,7 +122,7 @@ public class PhoneticTokenFilterFactory extends AbstractTokenFilterFactory {
|
||||||
if (encoder == null) {
|
if (encoder == null) {
|
||||||
if (ruletype != null && nametype != null) {
|
if (ruletype != null && nametype != null) {
|
||||||
if (languageset != null) {
|
if (languageset != null) {
|
||||||
final LanguageSet languages = LanguageSet.from(new HashSet(Arrays.asList(languageset)));
|
final LanguageSet languages = LanguageSet.from(new HashSet<>(Arrays.asList(languageset)));
|
||||||
return new BeiderMorseFilter(tokenStream, new PhoneticEngine(nametype, ruletype, true), languages);
|
return new BeiderMorseFilter(tokenStream, new PhoneticEngine(nametype, ruletype, true), languages);
|
||||||
}
|
}
|
||||||
return new BeiderMorseFilter(tokenStream, new PhoneticEngine(nametype, ruletype, true));
|
return new BeiderMorseFilter(tokenStream, new PhoneticEngine(nametype, ruletype, true));
|
||||||
|
|
|
@ -19,9 +19,6 @@
|
||||||
|
|
||||||
package org.elasticsearch.index.analysis.phonetic;
|
package org.elasticsearch.index.analysis.phonetic;
|
||||||
|
|
||||||
import org.apache.commons.codec.EncoderException;
|
|
||||||
import org.apache.commons.codec.StringEncoder;
|
|
||||||
|
|
||||||
import java.util.ArrayList;
|
import java.util.ArrayList;
|
||||||
import java.util.Arrays;
|
import java.util.Arrays;
|
||||||
import java.util.HashSet;
|
import java.util.HashSet;
|
||||||
|
@ -31,6 +28,9 @@ import java.util.Set;
|
||||||
import java.util.regex.Matcher;
|
import java.util.regex.Matcher;
|
||||||
import java.util.regex.Pattern;
|
import java.util.regex.Pattern;
|
||||||
|
|
||||||
|
import org.apache.commons.codec.EncoderException;
|
||||||
|
import org.apache.commons.codec.StringEncoder;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Kölner Phonetik
|
* Kölner Phonetik
|
||||||
*
|
*
|
||||||
|
@ -49,13 +49,13 @@ public class KoelnerPhonetik implements StringEncoder {
|
||||||
private static final String[] POSTEL_VARIATIONS_REPLACEMENTS = {"OWN", "AUN", "RW", "RB", "RSK", "WSK"};
|
private static final String[] POSTEL_VARIATIONS_REPLACEMENTS = {"OWN", "AUN", "RW", "RB", "RSK", "WSK"};
|
||||||
private Pattern[] variationsPatterns;
|
private Pattern[] variationsPatterns;
|
||||||
private boolean primary = false;
|
private boolean primary = false;
|
||||||
private final Set<Character> csz = new HashSet(Arrays.asList(
|
private final Set<Character> csz = new HashSet<>(Arrays.asList(
|
||||||
'C', 'S', 'Z'));
|
'C', 'S', 'Z'));
|
||||||
private final Set<Character> ckq = new HashSet(Arrays.asList(
|
private final Set<Character> ckq = new HashSet<>(Arrays.asList(
|
||||||
'C', 'K', 'Q'));
|
'C', 'K', 'Q'));
|
||||||
private final Set<Character> aouhkxq = new HashSet(Arrays.asList(
|
private final Set<Character> aouhkxq = new HashSet<>(Arrays.asList(
|
||||||
'A', 'O', 'U', 'H', 'K', 'X', 'Q'));
|
'A', 'O', 'U', 'H', 'K', 'X', 'Q'));
|
||||||
private final Set<Character> ahkloqrux = new HashSet(Arrays.asList(
|
private final Set<Character> ahkloqrux = new HashSet<>(Arrays.asList(
|
||||||
'A', 'H', 'K', 'L', 'O', 'Q', 'R', 'U', 'X'));
|
'A', 'H', 'K', 'L', 'O', 'Q', 'R', 'U', 'X'));
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
@ -139,10 +139,10 @@ public class KoelnerPhonetik implements StringEncoder {
|
||||||
|
|
||||||
private List<String> partition(String str) {
|
private List<String> partition(String str) {
|
||||||
String primaryForm = str;
|
String primaryForm = str;
|
||||||
List<String> parts = new ArrayList();
|
List<String> parts = new ArrayList<>();
|
||||||
parts.add(primaryForm.replaceAll("[^\\p{L}\\p{N}]", ""));
|
parts.add(primaryForm.replaceAll("[^\\p{L}\\p{N}]", ""));
|
||||||
if (!primary) {
|
if (!primary) {
|
||||||
List<String> tmpParts = new ArrayList();
|
List<String> tmpParts = new ArrayList<>();
|
||||||
tmpParts.addAll((Arrays.asList(str.split("[\\p{Z}\\p{C}\\p{P}]"))));
|
tmpParts.addAll((Arrays.asList(str.split("[\\p{Z}\\p{C}\\p{P}]"))));
|
||||||
int numberOfParts = tmpParts.size();
|
int numberOfParts = tmpParts.size();
|
||||||
while (tmpParts.size() > 0) {
|
while (tmpParts.size() > 0) {
|
||||||
|
@ -156,9 +156,9 @@ public class KoelnerPhonetik implements StringEncoder {
|
||||||
tmpParts.remove(0);
|
tmpParts.remove(0);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
List<String> variations = new ArrayList();
|
List<String> variations = new ArrayList<>();
|
||||||
for (int i = 0; i < parts.size(); i++) {
|
for (int i = 0; i < parts.size(); i++) {
|
||||||
List variation = getVariations(parts.get(i));
|
List<String> variation = getVariations(parts.get(i));
|
||||||
if (variation != null) {
|
if (variation != null) {
|
||||||
variations.addAll(variation);
|
variations.addAll(variation);
|
||||||
}
|
}
|
||||||
|
@ -166,9 +166,9 @@ public class KoelnerPhonetik implements StringEncoder {
|
||||||
return variations;
|
return variations;
|
||||||
}
|
}
|
||||||
|
|
||||||
private List getVariations(String str) {
|
private List<String> getVariations(String str) {
|
||||||
int position = 0;
|
int position = 0;
|
||||||
List<String> variations = new ArrayList();
|
List<String> variations = new ArrayList<>();
|
||||||
variations.add("");
|
variations.add("");
|
||||||
while (position < str.length()) {
|
while (position < str.length()) {
|
||||||
int i = 0;
|
int i = 0;
|
||||||
|
@ -182,7 +182,7 @@ public class KoelnerPhonetik implements StringEncoder {
|
||||||
}
|
}
|
||||||
if (substPos >= position) {
|
if (substPos >= position) {
|
||||||
i--;
|
i--;
|
||||||
List<String> varNew = new ArrayList();
|
List<String> varNew = new ArrayList<>();
|
||||||
String prevPart = str.substring(position, substPos);
|
String prevPart = str.substring(position, substPos);
|
||||||
for (int ii = 0; ii < variations.size(); ii++) {
|
for (int ii = 0; ii < variations.size(); ii++) {
|
||||||
String tmp = variations.get(ii);
|
String tmp = variations.get(ii);
|
||||||
|
|
|
@ -25,8 +25,6 @@ esplugin {
|
||||||
// no unit tests
|
// no unit tests
|
||||||
test.enabled = false
|
test.enabled = false
|
||||||
|
|
||||||
compileJava.options.compilerArgs << "-Xlint:-rawtypes"
|
|
||||||
|
|
||||||
configurations {
|
configurations {
|
||||||
exampleFixture
|
exampleFixture
|
||||||
}
|
}
|
||||||
|
|
|
@ -19,6 +19,10 @@
|
||||||
|
|
||||||
package org.elasticsearch.plugin.example;
|
package org.elasticsearch.plugin.example;
|
||||||
|
|
||||||
|
import java.util.ArrayList;
|
||||||
|
import java.util.Collection;
|
||||||
|
import java.util.Collections;
|
||||||
|
|
||||||
import org.elasticsearch.common.component.LifecycleComponent;
|
import org.elasticsearch.common.component.LifecycleComponent;
|
||||||
import org.elasticsearch.common.inject.AbstractModule;
|
import org.elasticsearch.common.inject.AbstractModule;
|
||||||
import org.elasticsearch.common.inject.Module;
|
import org.elasticsearch.common.inject.Module;
|
||||||
|
@ -28,10 +32,6 @@ import org.elasticsearch.plugins.Plugin;
|
||||||
import org.elasticsearch.repositories.RepositoriesModule;
|
import org.elasticsearch.repositories.RepositoriesModule;
|
||||||
import org.elasticsearch.rest.action.cat.AbstractCatAction;
|
import org.elasticsearch.rest.action.cat.AbstractCatAction;
|
||||||
|
|
||||||
import java.util.ArrayList;
|
|
||||||
import java.util.Collection;
|
|
||||||
import java.util.Collections;
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Example of a plugin.
|
* Example of a plugin.
|
||||||
*/
|
*/
|
||||||
|
@ -59,6 +59,7 @@ public class JvmExamplePlugin extends Plugin {
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
|
@SuppressWarnings("rawtypes") // Plugin use a rawtype
|
||||||
public Collection<Class<? extends LifecycleComponent>> nodeServices() {
|
public Collection<Class<? extends LifecycleComponent>> nodeServices() {
|
||||||
Collection<Class<? extends LifecycleComponent>> services = new ArrayList<>();
|
Collection<Class<? extends LifecycleComponent>> services = new ArrayList<>();
|
||||||
return services;
|
return services;
|
||||||
|
|
|
@ -26,13 +26,9 @@ dependencies {
|
||||||
compile 'org.mozilla:rhino:1.7.7'
|
compile 'org.mozilla:rhino:1.7.7'
|
||||||
}
|
}
|
||||||
|
|
||||||
compileJava.options.compilerArgs << "-Xlint:-rawtypes,-unchecked"
|
|
||||||
compileTestJava.options.compilerArgs << "-Xlint:-rawtypes,-unchecked"
|
|
||||||
|
|
||||||
integTest {
|
integTest {
|
||||||
cluster {
|
cluster {
|
||||||
systemProperty 'es.script.inline', 'on'
|
systemProperty 'es.script.inline', 'on'
|
||||||
systemProperty 'es.script.indexed', 'on'
|
systemProperty 'es.script.indexed', 'on'
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -19,6 +19,18 @@
|
||||||
|
|
||||||
package org.elasticsearch.script.javascript;
|
package org.elasticsearch.script.javascript;
|
||||||
|
|
||||||
|
import java.io.IOException;
|
||||||
|
import java.net.MalformedURLException;
|
||||||
|
import java.net.URL;
|
||||||
|
import java.security.AccessControlContext;
|
||||||
|
import java.security.AccessController;
|
||||||
|
import java.security.CodeSource;
|
||||||
|
import java.security.PrivilegedAction;
|
||||||
|
import java.security.cert.Certificate;
|
||||||
|
import java.util.List;
|
||||||
|
import java.util.Map;
|
||||||
|
import java.util.concurrent.atomic.AtomicLong;
|
||||||
|
|
||||||
import org.apache.lucene.index.LeafReaderContext;
|
import org.apache.lucene.index.LeafReaderContext;
|
||||||
import org.apache.lucene.search.Scorer;
|
import org.apache.lucene.search.Scorer;
|
||||||
import org.elasticsearch.SpecialPermission;
|
import org.elasticsearch.SpecialPermission;
|
||||||
|
@ -49,18 +61,6 @@ import org.mozilla.javascript.ScriptableObject;
|
||||||
import org.mozilla.javascript.SecurityController;
|
import org.mozilla.javascript.SecurityController;
|
||||||
import org.mozilla.javascript.WrapFactory;
|
import org.mozilla.javascript.WrapFactory;
|
||||||
|
|
||||||
import java.io.IOException;
|
|
||||||
import java.net.MalformedURLException;
|
|
||||||
import java.net.URL;
|
|
||||||
import java.security.AccessControlContext;
|
|
||||||
import java.security.AccessController;
|
|
||||||
import java.security.CodeSource;
|
|
||||||
import java.security.PrivilegedAction;
|
|
||||||
import java.security.cert.Certificate;
|
|
||||||
import java.util.List;
|
|
||||||
import java.util.Map;
|
|
||||||
import java.util.concurrent.atomic.AtomicLong;
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
*
|
*
|
||||||
*/
|
*/
|
||||||
|
@ -348,12 +348,14 @@ public class JavaScriptScriptEngineService extends AbstractComponent implements
|
||||||
setJavaPrimitiveWrap(false); // RingoJS does that..., claims its annoying...
|
setJavaPrimitiveWrap(false); // RingoJS does that..., claims its annoying...
|
||||||
}
|
}
|
||||||
|
|
||||||
public Scriptable wrapAsJavaObject(Context cx, Scriptable scope, Object javaObject, Class staticType) {
|
@Override
|
||||||
|
@SuppressWarnings("unchecked")
|
||||||
|
public Scriptable wrapAsJavaObject(Context cx, Scriptable scope, Object javaObject, Class<?> staticType) {
|
||||||
if (javaObject instanceof Map) {
|
if (javaObject instanceof Map) {
|
||||||
return NativeMap.wrap(scope, (Map) javaObject);
|
return NativeMap.wrap(scope, (Map<Object, Object>) javaObject);
|
||||||
}
|
}
|
||||||
if (javaObject instanceof List) {
|
if (javaObject instanceof List) {
|
||||||
return NativeList.wrap(scope, (List) javaObject, staticType);
|
return NativeList.wrap(scope, (List<Object>) javaObject, staticType);
|
||||||
}
|
}
|
||||||
return super.wrapAsJavaObject(cx, scope, javaObject, staticType);
|
return super.wrapAsJavaObject(cx, scope, javaObject, staticType);
|
||||||
}
|
}
|
||||||
|
|
|
@ -19,12 +19,12 @@
|
||||||
|
|
||||||
package org.elasticsearch.script.javascript.support;
|
package org.elasticsearch.script.javascript.support;
|
||||||
|
|
||||||
import org.mozilla.javascript.Scriptable;
|
|
||||||
import org.mozilla.javascript.Wrapper;
|
|
||||||
|
|
||||||
import java.util.Iterator;
|
import java.util.Iterator;
|
||||||
import java.util.Map;
|
import java.util.Map;
|
||||||
|
|
||||||
|
import org.mozilla.javascript.Scriptable;
|
||||||
|
import org.mozilla.javascript.Wrapper;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Wrapper for exposing maps in Rhino scripts.
|
* Wrapper for exposing maps in Rhino scripts.
|
||||||
*
|
*
|
||||||
|
@ -55,26 +55,17 @@ public class NativeMap implements Scriptable, Wrapper {
|
||||||
this.map = map;
|
this.map = map;
|
||||||
}
|
}
|
||||||
|
|
||||||
/* (non-Javadoc)
|
@Override
|
||||||
* @see org.mozilla.javascript.Wrapper#unwrap()
|
|
||||||
*/
|
|
||||||
|
|
||||||
public Object unwrap() {
|
public Object unwrap() {
|
||||||
return map;
|
return map;
|
||||||
}
|
}
|
||||||
|
|
||||||
/* (non-Javadoc)
|
@Override
|
||||||
* @see org.mozilla.javascript.Scriptable#getClassName()
|
|
||||||
*/
|
|
||||||
|
|
||||||
public String getClassName() {
|
public String getClassName() {
|
||||||
return "NativeMap";
|
return "NativeMap";
|
||||||
}
|
}
|
||||||
|
|
||||||
/* (non-Javadoc)
|
@Override
|
||||||
* @see org.mozilla.javascript.Scriptable#get(java.lang.String, org.mozilla.javascript.Scriptable)
|
|
||||||
*/
|
|
||||||
|
|
||||||
public Object get(String name, Scriptable start) {
|
public Object get(String name, Scriptable start) {
|
||||||
// get the property from the underlying QName map
|
// get the property from the underlying QName map
|
||||||
if ("length".equals(name)) {
|
if ("length".equals(name)) {
|
||||||
|
@ -84,69 +75,47 @@ public class NativeMap implements Scriptable, Wrapper {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
/* (non-Javadoc)
|
@Override
|
||||||
* @see org.mozilla.javascript.Scriptable#get(int, org.mozilla.javascript.Scriptable)
|
|
||||||
*/
|
|
||||||
|
|
||||||
public Object get(int index, Scriptable start) {
|
public Object get(int index, Scriptable start) {
|
||||||
Object value = null;
|
Object value = null;
|
||||||
int i = 0;
|
int i = 0;
|
||||||
Iterator itrValues = map.values().iterator();
|
Iterator<Object> itrValues = map.values().iterator();
|
||||||
while (i++ <= index && itrValues.hasNext()) {
|
while (i++ <= index && itrValues.hasNext()) {
|
||||||
value = itrValues.next();
|
value = itrValues.next();
|
||||||
}
|
}
|
||||||
return value;
|
return value;
|
||||||
}
|
}
|
||||||
|
|
||||||
/* (non-Javadoc)
|
@Override
|
||||||
* @see org.mozilla.javascript.Scriptable#has(java.lang.String, org.mozilla.javascript.Scriptable)
|
|
||||||
*/
|
|
||||||
|
|
||||||
public boolean has(String name, Scriptable start) {
|
public boolean has(String name, Scriptable start) {
|
||||||
// locate the property in the underlying map
|
// locate the property in the underlying map
|
||||||
return map.containsKey(name);
|
return map.containsKey(name);
|
||||||
}
|
}
|
||||||
|
|
||||||
/* (non-Javadoc)
|
@Override
|
||||||
* @see org.mozilla.javascript.Scriptable#has(int, org.mozilla.javascript.Scriptable)
|
|
||||||
*/
|
|
||||||
|
|
||||||
public boolean has(int index, Scriptable start) {
|
public boolean has(int index, Scriptable start) {
|
||||||
return (index >= 0 && map.values().size() > index);
|
return (index >= 0 && map.values().size() > index);
|
||||||
}
|
}
|
||||||
|
|
||||||
/* (non-Javadoc)
|
@Override
|
||||||
* @see org.mozilla.javascript.Scriptable#put(java.lang.String, org.mozilla.javascript.Scriptable, java.lang.Object)
|
|
||||||
*/
|
|
||||||
|
|
||||||
@SuppressWarnings("unchecked")
|
|
||||||
public void put(String name, Scriptable start, Object value) {
|
public void put(String name, Scriptable start, Object value) {
|
||||||
map.put(name, value);
|
map.put(name, value);
|
||||||
}
|
}
|
||||||
|
|
||||||
/* (non-Javadoc)
|
@Override
|
||||||
* @see org.mozilla.javascript.Scriptable#put(int, org.mozilla.javascript.Scriptable, java.lang.Object)
|
|
||||||
*/
|
|
||||||
|
|
||||||
public void put(int index, Scriptable start, Object value) {
|
public void put(int index, Scriptable start, Object value) {
|
||||||
// TODO: implement?
|
// TODO: implement?
|
||||||
}
|
}
|
||||||
|
|
||||||
/* (non-Javadoc)
|
@Override
|
||||||
* @see org.mozilla.javascript.Scriptable#delete(java.lang.String)
|
|
||||||
*/
|
|
||||||
|
|
||||||
public void delete(String name) {
|
public void delete(String name) {
|
||||||
map.remove(name);
|
map.remove(name);
|
||||||
}
|
}
|
||||||
|
|
||||||
/* (non-Javadoc)
|
@Override
|
||||||
* @see org.mozilla.javascript.Scriptable#delete(int)
|
|
||||||
*/
|
|
||||||
|
|
||||||
public void delete(int index) {
|
public void delete(int index) {
|
||||||
int i = 0;
|
int i = 0;
|
||||||
Iterator itrKeys = map.keySet().iterator();
|
Iterator<Object> itrKeys = map.keySet().iterator();
|
||||||
while (i <= index && itrKeys.hasNext()) {
|
while (i <= index && itrKeys.hasNext()) {
|
||||||
Object key = itrKeys.next();
|
Object key = itrKeys.next();
|
||||||
if (i == index) {
|
if (i == index) {
|
||||||
|
@ -156,58 +125,37 @@ public class NativeMap implements Scriptable, Wrapper {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
/* (non-Javadoc)
|
@Override
|
||||||
* @see org.mozilla.javascript.Scriptable#getPrototype()
|
|
||||||
*/
|
|
||||||
|
|
||||||
public Scriptable getPrototype() {
|
public Scriptable getPrototype() {
|
||||||
return this.prototype;
|
return this.prototype;
|
||||||
}
|
}
|
||||||
|
|
||||||
/* (non-Javadoc)
|
@Override
|
||||||
* @see org.mozilla.javascript.Scriptable#setPrototype(org.mozilla.javascript.Scriptable)
|
|
||||||
*/
|
|
||||||
|
|
||||||
public void setPrototype(Scriptable prototype) {
|
public void setPrototype(Scriptable prototype) {
|
||||||
this.prototype = prototype;
|
this.prototype = prototype;
|
||||||
}
|
}
|
||||||
|
|
||||||
/* (non-Javadoc)
|
@Override
|
||||||
* @see org.mozilla.javascript.Scriptable#getParentScope()
|
|
||||||
*/
|
|
||||||
|
|
||||||
public Scriptable getParentScope() {
|
public Scriptable getParentScope() {
|
||||||
return this.parentScope;
|
return this.parentScope;
|
||||||
}
|
}
|
||||||
|
|
||||||
/* (non-Javadoc)
|
@Override
|
||||||
* @see org.mozilla.javascript.Scriptable#setParentScope(org.mozilla.javascript.Scriptable)
|
|
||||||
*/
|
|
||||||
|
|
||||||
public void setParentScope(Scriptable parent) {
|
public void setParentScope(Scriptable parent) {
|
||||||
this.parentScope = parent;
|
this.parentScope = parent;
|
||||||
}
|
}
|
||||||
|
|
||||||
/* (non-Javadoc)
|
@Override
|
||||||
* @see org.mozilla.javascript.Scriptable#getIds()
|
|
||||||
*/
|
|
||||||
|
|
||||||
public Object[] getIds() {
|
public Object[] getIds() {
|
||||||
return map.keySet().toArray();
|
return map.keySet().toArray();
|
||||||
}
|
}
|
||||||
|
|
||||||
/* (non-Javadoc)
|
@Override
|
||||||
* @see org.mozilla.javascript.Scriptable#getDefaultValue(java.lang.Class)
|
public Object getDefaultValue(Class<?> hint) {
|
||||||
*/
|
|
||||||
|
|
||||||
public Object getDefaultValue(Class hint) {
|
|
||||||
return null;
|
return null;
|
||||||
}
|
}
|
||||||
|
|
||||||
/* (non-Javadoc)
|
@Override
|
||||||
* @see org.mozilla.javascript.Scriptable#hasInstance(org.mozilla.javascript.Scriptable)
|
|
||||||
*/
|
|
||||||
|
|
||||||
public boolean hasInstance(Scriptable value) {
|
public boolean hasInstance(Scriptable value) {
|
||||||
if (!(value instanceof Wrapper))
|
if (!(value instanceof Wrapper))
|
||||||
return false;
|
return false;
|
||||||
|
|
|
@ -19,13 +19,6 @@
|
||||||
|
|
||||||
package org.elasticsearch.script.javascript.support;
|
package org.elasticsearch.script.javascript.support;
|
||||||
|
|
||||||
import org.mozilla.javascript.Context;
|
|
||||||
import org.mozilla.javascript.IdScriptableObject;
|
|
||||||
import org.mozilla.javascript.NativeArray;
|
|
||||||
import org.mozilla.javascript.ScriptRuntime;
|
|
||||||
import org.mozilla.javascript.Scriptable;
|
|
||||||
import org.mozilla.javascript.Wrapper;
|
|
||||||
|
|
||||||
import java.util.ArrayList;
|
import java.util.ArrayList;
|
||||||
import java.util.Collection;
|
import java.util.Collection;
|
||||||
import java.util.Date;
|
import java.util.Date;
|
||||||
|
@ -33,6 +26,13 @@ import java.util.HashMap;
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
import java.util.Map;
|
import java.util.Map;
|
||||||
|
|
||||||
|
import org.mozilla.javascript.Context;
|
||||||
|
import org.mozilla.javascript.IdScriptableObject;
|
||||||
|
import org.mozilla.javascript.NativeArray;
|
||||||
|
import org.mozilla.javascript.ScriptRuntime;
|
||||||
|
import org.mozilla.javascript.Scriptable;
|
||||||
|
import org.mozilla.javascript.Wrapper;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Value Converter to marshal objects between Java and Javascript.
|
* Value Converter to marshal objects between Java and Javascript.
|
||||||
*
|
*
|
||||||
|
@ -126,6 +126,7 @@ public final class ScriptValueConverter {
|
||||||
value = list;
|
value = list;
|
||||||
} else if (value instanceof Map) {
|
} else if (value instanceof Map) {
|
||||||
// ensure each value in the Map is unwrapped (which may have been an unwrapped NativeMap!)
|
// ensure each value in the Map is unwrapped (which may have been an unwrapped NativeMap!)
|
||||||
|
@SuppressWarnings("unchecked")
|
||||||
Map<Object, Object> map = (Map<Object, Object>) value;
|
Map<Object, Object> map = (Map<Object, Object>) value;
|
||||||
Map<Object, Object> copyMap = new HashMap<Object, Object>(map.size());
|
Map<Object, Object> copyMap = new HashMap<Object, Object>(map.size());
|
||||||
for (Object key : map.keySet()) {
|
for (Object key : map.keySet()) {
|
||||||
|
@ -157,6 +158,7 @@ public final class ScriptValueConverter {
|
||||||
Context.getCurrentContext(), scope, TYPE_DATE, new Object[]{date.getTime()});
|
Context.getCurrentContext(), scope, TYPE_DATE, new Object[]{date.getTime()});
|
||||||
} else if (value instanceof Collection) {
|
} else if (value instanceof Collection) {
|
||||||
// recursively convert each value in the collection
|
// recursively convert each value in the collection
|
||||||
|
@SuppressWarnings("unchecked")
|
||||||
Collection<Object> collection = (Collection<Object>) value;
|
Collection<Object> collection = (Collection<Object>) value;
|
||||||
Object[] array = new Object[collection.size()];
|
Object[] array = new Object[collection.size()];
|
||||||
int index = 0;
|
int index = 0;
|
||||||
|
@ -166,7 +168,9 @@ public final class ScriptValueConverter {
|
||||||
// convert array to a native JavaScript Array
|
// convert array to a native JavaScript Array
|
||||||
value = Context.getCurrentContext().newArray(scope, array);
|
value = Context.getCurrentContext().newArray(scope, array);
|
||||||
} else if (value instanceof Map) {
|
} else if (value instanceof Map) {
|
||||||
value = NativeMap.wrap(scope, (Map) value);
|
@SuppressWarnings("unchecked")
|
||||||
|
Map<Object, Object> map = (Map<Object, Object>) value;
|
||||||
|
value = NativeMap.wrap(scope, map);
|
||||||
}
|
}
|
||||||
|
|
||||||
// simple numbers, strings and booleans are wrapped automatically by Rhino
|
// simple numbers, strings and booleans are wrapped automatically by Rhino
|
||||||
|
|
|
@ -19,12 +19,12 @@
|
||||||
|
|
||||||
package org.elasticsearch.script.javascript.support;
|
package org.elasticsearch.script.javascript.support;
|
||||||
|
|
||||||
import org.mozilla.javascript.Scriptable;
|
|
||||||
|
|
||||||
import java.util.Iterator;
|
import java.util.Iterator;
|
||||||
import java.util.LinkedHashMap;
|
import java.util.LinkedHashMap;
|
||||||
import java.util.Map;
|
import java.util.Map;
|
||||||
|
|
||||||
|
import org.mozilla.javascript.Scriptable;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Implementation of a Scriptable Map. This is the best choice for maps that want to represent
|
* Implementation of a Scriptable Map. This is the best choice for maps that want to represent
|
||||||
* JavaScript associative arrays - allowing access via key and integer index. It maintains and
|
* JavaScript associative arrays - allowing access via key and integer index. It maintains and
|
||||||
|
@ -53,6 +53,7 @@ public class ScriptableLinkedHashMap<K, V> extends LinkedHashMap<K, V> implement
|
||||||
/**
|
/**
|
||||||
* @see org.mozilla.javascript.Scriptable#getClassName()
|
* @see org.mozilla.javascript.Scriptable#getClassName()
|
||||||
*/
|
*/
|
||||||
|
@Override
|
||||||
public String getClassName() {
|
public String getClassName() {
|
||||||
return "ScriptableMap";
|
return "ScriptableMap";
|
||||||
}
|
}
|
||||||
|
@ -60,6 +61,7 @@ public class ScriptableLinkedHashMap<K, V> extends LinkedHashMap<K, V> implement
|
||||||
/**
|
/**
|
||||||
* @see org.mozilla.javascript.Scriptable#get(java.lang.String, org.mozilla.javascript.Scriptable)
|
* @see org.mozilla.javascript.Scriptable#get(java.lang.String, org.mozilla.javascript.Scriptable)
|
||||||
*/
|
*/
|
||||||
|
@Override
|
||||||
public Object get(String name, Scriptable start) {
|
public Object get(String name, Scriptable start) {
|
||||||
// get the property from the underlying QName map
|
// get the property from the underlying QName map
|
||||||
if ("length".equals(name)) {
|
if ("length".equals(name)) {
|
||||||
|
@ -72,10 +74,11 @@ public class ScriptableLinkedHashMap<K, V> extends LinkedHashMap<K, V> implement
|
||||||
/**
|
/**
|
||||||
* @see org.mozilla.javascript.Scriptable#get(int, org.mozilla.javascript.Scriptable)
|
* @see org.mozilla.javascript.Scriptable#get(int, org.mozilla.javascript.Scriptable)
|
||||||
*/
|
*/
|
||||||
|
@Override
|
||||||
public Object get(int index, Scriptable start) {
|
public Object get(int index, Scriptable start) {
|
||||||
Object value = null;
|
Object value = null;
|
||||||
int i = 0;
|
int i = 0;
|
||||||
Iterator itrValues = this.values().iterator();
|
Iterator<V> itrValues = this.values().iterator();
|
||||||
while (i++ <= index && itrValues.hasNext()) {
|
while (i++ <= index && itrValues.hasNext()) {
|
||||||
value = itrValues.next();
|
value = itrValues.next();
|
||||||
}
|
}
|
||||||
|
@ -85,6 +88,7 @@ public class ScriptableLinkedHashMap<K, V> extends LinkedHashMap<K, V> implement
|
||||||
/**
|
/**
|
||||||
* @see org.mozilla.javascript.Scriptable#has(java.lang.String, org.mozilla.javascript.Scriptable)
|
* @see org.mozilla.javascript.Scriptable#has(java.lang.String, org.mozilla.javascript.Scriptable)
|
||||||
*/
|
*/
|
||||||
|
@Override
|
||||||
public boolean has(String name, Scriptable start) {
|
public boolean has(String name, Scriptable start) {
|
||||||
// locate the property in the underlying map
|
// locate the property in the underlying map
|
||||||
return containsKey(name);
|
return containsKey(name);
|
||||||
|
@ -93,6 +97,7 @@ public class ScriptableLinkedHashMap<K, V> extends LinkedHashMap<K, V> implement
|
||||||
/**
|
/**
|
||||||
* @see org.mozilla.javascript.Scriptable#has(int, org.mozilla.javascript.Scriptable)
|
* @see org.mozilla.javascript.Scriptable#has(int, org.mozilla.javascript.Scriptable)
|
||||||
*/
|
*/
|
||||||
|
@Override
|
||||||
public boolean has(int index, Scriptable start) {
|
public boolean has(int index, Scriptable start) {
|
||||||
return (index >= 0 && this.values().size() > index);
|
return (index >= 0 && this.values().size() > index);
|
||||||
}
|
}
|
||||||
|
@ -100,6 +105,7 @@ public class ScriptableLinkedHashMap<K, V> extends LinkedHashMap<K, V> implement
|
||||||
/**
|
/**
|
||||||
* @see org.mozilla.javascript.Scriptable#put(java.lang.String, org.mozilla.javascript.Scriptable, java.lang.Object)
|
* @see org.mozilla.javascript.Scriptable#put(java.lang.String, org.mozilla.javascript.Scriptable, java.lang.Object)
|
||||||
*/
|
*/
|
||||||
|
@Override
|
||||||
@SuppressWarnings("unchecked")
|
@SuppressWarnings("unchecked")
|
||||||
public void put(String name, Scriptable start, Object value) {
|
public void put(String name, Scriptable start, Object value) {
|
||||||
// add the property to the underlying QName map
|
// add the property to the underlying QName map
|
||||||
|
@ -109,6 +115,7 @@ public class ScriptableLinkedHashMap<K, V> extends LinkedHashMap<K, V> implement
|
||||||
/**
|
/**
|
||||||
* @see org.mozilla.javascript.Scriptable#put(int, org.mozilla.javascript.Scriptable, java.lang.Object)
|
* @see org.mozilla.javascript.Scriptable#put(int, org.mozilla.javascript.Scriptable, java.lang.Object)
|
||||||
*/
|
*/
|
||||||
|
@Override
|
||||||
public void put(int index, Scriptable start, Object value) {
|
public void put(int index, Scriptable start, Object value) {
|
||||||
// TODO: implement?
|
// TODO: implement?
|
||||||
}
|
}
|
||||||
|
@ -116,6 +123,7 @@ public class ScriptableLinkedHashMap<K, V> extends LinkedHashMap<K, V> implement
|
||||||
/**
|
/**
|
||||||
* @see org.mozilla.javascript.Scriptable#delete(java.lang.String)
|
* @see org.mozilla.javascript.Scriptable#delete(java.lang.String)
|
||||||
*/
|
*/
|
||||||
|
@Override
|
||||||
public void delete(String name) {
|
public void delete(String name) {
|
||||||
// remove the property from the underlying QName map
|
// remove the property from the underlying QName map
|
||||||
remove(name);
|
remove(name);
|
||||||
|
@ -124,9 +132,10 @@ public class ScriptableLinkedHashMap<K, V> extends LinkedHashMap<K, V> implement
|
||||||
/**
|
/**
|
||||||
* @see org.mozilla.javascript.Scriptable#delete(int)
|
* @see org.mozilla.javascript.Scriptable#delete(int)
|
||||||
*/
|
*/
|
||||||
|
@Override
|
||||||
public void delete(int index) {
|
public void delete(int index) {
|
||||||
int i = 0;
|
int i = 0;
|
||||||
Iterator itrKeys = this.keySet().iterator();
|
Iterator<K> itrKeys = this.keySet().iterator();
|
||||||
while (i <= index && itrKeys.hasNext()) {
|
while (i <= index && itrKeys.hasNext()) {
|
||||||
Object key = itrKeys.next();
|
Object key = itrKeys.next();
|
||||||
if (i == index) {
|
if (i == index) {
|
||||||
|
@ -139,6 +148,7 @@ public class ScriptableLinkedHashMap<K, V> extends LinkedHashMap<K, V> implement
|
||||||
/**
|
/**
|
||||||
* @see org.mozilla.javascript.Scriptable#getPrototype()
|
* @see org.mozilla.javascript.Scriptable#getPrototype()
|
||||||
*/
|
*/
|
||||||
|
@Override
|
||||||
public Scriptable getPrototype() {
|
public Scriptable getPrototype() {
|
||||||
return this.prototype;
|
return this.prototype;
|
||||||
}
|
}
|
||||||
|
@ -146,6 +156,7 @@ public class ScriptableLinkedHashMap<K, V> extends LinkedHashMap<K, V> implement
|
||||||
/**
|
/**
|
||||||
* @see org.mozilla.javascript.Scriptable#setPrototype(org.mozilla.javascript.Scriptable)
|
* @see org.mozilla.javascript.Scriptable#setPrototype(org.mozilla.javascript.Scriptable)
|
||||||
*/
|
*/
|
||||||
|
@Override
|
||||||
public void setPrototype(Scriptable prototype) {
|
public void setPrototype(Scriptable prototype) {
|
||||||
this.prototype = prototype;
|
this.prototype = prototype;
|
||||||
}
|
}
|
||||||
|
@ -153,6 +164,7 @@ public class ScriptableLinkedHashMap<K, V> extends LinkedHashMap<K, V> implement
|
||||||
/**
|
/**
|
||||||
* @see org.mozilla.javascript.Scriptable#getParentScope()
|
* @see org.mozilla.javascript.Scriptable#getParentScope()
|
||||||
*/
|
*/
|
||||||
|
@Override
|
||||||
public Scriptable getParentScope() {
|
public Scriptable getParentScope() {
|
||||||
return this.parentScope;
|
return this.parentScope;
|
||||||
}
|
}
|
||||||
|
@ -160,6 +172,7 @@ public class ScriptableLinkedHashMap<K, V> extends LinkedHashMap<K, V> implement
|
||||||
/**
|
/**
|
||||||
* @see org.mozilla.javascript.Scriptable#setParentScope(org.mozilla.javascript.Scriptable)
|
* @see org.mozilla.javascript.Scriptable#setParentScope(org.mozilla.javascript.Scriptable)
|
||||||
*/
|
*/
|
||||||
|
@Override
|
||||||
public void setParentScope(Scriptable parent) {
|
public void setParentScope(Scriptable parent) {
|
||||||
this.parentScope = parent;
|
this.parentScope = parent;
|
||||||
}
|
}
|
||||||
|
@ -167,6 +180,7 @@ public class ScriptableLinkedHashMap<K, V> extends LinkedHashMap<K, V> implement
|
||||||
/**
|
/**
|
||||||
* @see org.mozilla.javascript.Scriptable#getIds()
|
* @see org.mozilla.javascript.Scriptable#getIds()
|
||||||
*/
|
*/
|
||||||
|
@Override
|
||||||
public Object[] getIds() {
|
public Object[] getIds() {
|
||||||
return keySet().toArray();
|
return keySet().toArray();
|
||||||
}
|
}
|
||||||
|
@ -174,13 +188,15 @@ public class ScriptableLinkedHashMap<K, V> extends LinkedHashMap<K, V> implement
|
||||||
/**
|
/**
|
||||||
* @see org.mozilla.javascript.Scriptable#getDefaultValue(java.lang.Class)
|
* @see org.mozilla.javascript.Scriptable#getDefaultValue(java.lang.Class)
|
||||||
*/
|
*/
|
||||||
public Object getDefaultValue(Class hint) {
|
@Override
|
||||||
|
public Object getDefaultValue(Class<?> hint) {
|
||||||
return null;
|
return null;
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @see org.mozilla.javascript.Scriptable#hasInstance(org.mozilla.javascript.Scriptable)
|
* @see org.mozilla.javascript.Scriptable#hasInstance(org.mozilla.javascript.Scriptable)
|
||||||
*/
|
*/
|
||||||
|
@Override
|
||||||
public boolean hasInstance(Scriptable instance) {
|
public boolean hasInstance(Scriptable instance) {
|
||||||
return instance instanceof ScriptableLinkedHashMap;
|
return instance instanceof ScriptableLinkedHashMap;
|
||||||
}
|
}
|
||||||
|
|
|
@ -19,14 +19,14 @@
|
||||||
|
|
||||||
package org.elasticsearch.script.javascript.support;
|
package org.elasticsearch.script.javascript.support;
|
||||||
|
|
||||||
import org.mozilla.javascript.Scriptable;
|
|
||||||
import org.mozilla.javascript.Wrapper;
|
|
||||||
|
|
||||||
import java.util.Collection;
|
import java.util.Collection;
|
||||||
import java.util.Iterator;
|
import java.util.Iterator;
|
||||||
import java.util.Map;
|
import java.util.Map;
|
||||||
import java.util.Set;
|
import java.util.Set;
|
||||||
|
|
||||||
|
import org.mozilla.javascript.Scriptable;
|
||||||
|
import org.mozilla.javascript.Wrapper;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Implementation of a Scriptable Map. This is the best choice where you want values to be
|
* Implementation of a Scriptable Map. This is the best choice where you want values to be
|
||||||
* persisted directly to an underlying map supplied on construction. The class automatically
|
* persisted directly to an underlying map supplied on construction. The class automatically
|
||||||
|
@ -37,8 +37,8 @@ import java.util.Set;
|
||||||
*
|
*
|
||||||
*
|
*
|
||||||
*/
|
*/
|
||||||
public class ScriptableWrappedMap implements ScriptableMap, Wrapper {
|
public class ScriptableWrappedMap implements ScriptableMap<Object, Object>, Wrapper {
|
||||||
private Map map;
|
private Map<Object, Object> map;
|
||||||
private Scriptable parentScope;
|
private Scriptable parentScope;
|
||||||
private Scriptable prototype;
|
private Scriptable prototype;
|
||||||
|
|
||||||
|
@ -54,38 +54,29 @@ public class ScriptableWrappedMap implements ScriptableMap, Wrapper {
|
||||||
/**
|
/**
|
||||||
* Construct
|
* Construct
|
||||||
*/
|
*/
|
||||||
public ScriptableWrappedMap(Map map) {
|
public ScriptableWrappedMap(Map<Object, Object> map) {
|
||||||
this.map = map;
|
this.map = map;
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Construct
|
* Construct
|
||||||
*/
|
*/
|
||||||
public ScriptableWrappedMap(Scriptable scope, Map map) {
|
public ScriptableWrappedMap(Scriptable scope, Map<Object, Object> map) {
|
||||||
this.parentScope = scope;
|
this.parentScope = scope;
|
||||||
this.map = map;
|
this.map = map;
|
||||||
}
|
}
|
||||||
|
|
||||||
/* (non-Javadoc)
|
@Override
|
||||||
* @see org.mozilla.javascript.Wrapper#unwrap()
|
|
||||||
*/
|
|
||||||
|
|
||||||
public Object unwrap() {
|
public Object unwrap() {
|
||||||
return map;
|
return map;
|
||||||
}
|
}
|
||||||
|
|
||||||
/* (non-Javadoc)
|
@Override
|
||||||
* @see org.mozilla.javascript.Scriptable#getClassName()
|
|
||||||
*/
|
|
||||||
|
|
||||||
public String getClassName() {
|
public String getClassName() {
|
||||||
return "ScriptableWrappedMap";
|
return "ScriptableWrappedMap";
|
||||||
}
|
}
|
||||||
|
|
||||||
/* (non-Javadoc)
|
@Override
|
||||||
* @see org.mozilla.javascript.Scriptable#get(java.lang.String, org.mozilla.javascript.Scriptable)
|
|
||||||
*/
|
|
||||||
|
|
||||||
public Object get(String name, Scriptable start) {
|
public Object get(String name, Scriptable start) {
|
||||||
// get the property from the underlying QName map
|
// get the property from the underlying QName map
|
||||||
if ("length".equals(name)) {
|
if ("length".equals(name)) {
|
||||||
|
@ -95,69 +86,47 @@ public class ScriptableWrappedMap implements ScriptableMap, Wrapper {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
/* (non-Javadoc)
|
@Override
|
||||||
* @see org.mozilla.javascript.Scriptable#get(int, org.mozilla.javascript.Scriptable)
|
|
||||||
*/
|
|
||||||
|
|
||||||
public Object get(int index, Scriptable start) {
|
public Object get(int index, Scriptable start) {
|
||||||
Object value = null;
|
Object value = null;
|
||||||
int i = 0;
|
int i = 0;
|
||||||
Iterator itrValues = map.values().iterator();
|
Iterator<Object> itrValues = map.values().iterator();
|
||||||
while (i++ <= index && itrValues.hasNext()) {
|
while (i++ <= index && itrValues.hasNext()) {
|
||||||
value = itrValues.next();
|
value = itrValues.next();
|
||||||
}
|
}
|
||||||
return ScriptValueConverter.wrapValue(this.parentScope != null ? this.parentScope : start, value);
|
return ScriptValueConverter.wrapValue(this.parentScope != null ? this.parentScope : start, value);
|
||||||
}
|
}
|
||||||
|
|
||||||
/* (non-Javadoc)
|
@Override
|
||||||
* @see org.mozilla.javascript.Scriptable#has(java.lang.String, org.mozilla.javascript.Scriptable)
|
|
||||||
*/
|
|
||||||
|
|
||||||
public boolean has(String name, Scriptable start) {
|
public boolean has(String name, Scriptable start) {
|
||||||
// locate the property in the underlying map
|
// locate the property in the underlying map
|
||||||
return map.containsKey(name);
|
return map.containsKey(name);
|
||||||
}
|
}
|
||||||
|
|
||||||
/* (non-Javadoc)
|
@Override
|
||||||
* @see org.mozilla.javascript.Scriptable#has(int, org.mozilla.javascript.Scriptable)
|
|
||||||
*/
|
|
||||||
|
|
||||||
public boolean has(int index, Scriptable start) {
|
public boolean has(int index, Scriptable start) {
|
||||||
return (index >= 0 && map.values().size() > index);
|
return (index >= 0 && map.values().size() > index);
|
||||||
}
|
}
|
||||||
|
|
||||||
/* (non-Javadoc)
|
@Override
|
||||||
* @see org.mozilla.javascript.Scriptable#put(java.lang.String, org.mozilla.javascript.Scriptable, java.lang.Object)
|
|
||||||
*/
|
|
||||||
|
|
||||||
@SuppressWarnings("unchecked")
|
|
||||||
public void put(String name, Scriptable start, Object value) {
|
public void put(String name, Scriptable start, Object value) {
|
||||||
map.put(name, ScriptValueConverter.unwrapValue(value));
|
map.put(name, ScriptValueConverter.unwrapValue(value));
|
||||||
}
|
}
|
||||||
|
|
||||||
/* (non-Javadoc)
|
@Override
|
||||||
* @see org.mozilla.javascript.Scriptable#put(int, org.mozilla.javascript.Scriptable, java.lang.Object)
|
|
||||||
*/
|
|
||||||
|
|
||||||
public void put(int index, Scriptable start, Object value) {
|
public void put(int index, Scriptable start, Object value) {
|
||||||
// TODO: implement?
|
// TODO: implement?
|
||||||
}
|
}
|
||||||
|
|
||||||
/* (non-Javadoc)
|
@Override
|
||||||
* @see org.mozilla.javascript.Scriptable#delete(java.lang.String)
|
|
||||||
*/
|
|
||||||
|
|
||||||
public void delete(String name) {
|
public void delete(String name) {
|
||||||
map.remove(name);
|
map.remove(name);
|
||||||
}
|
}
|
||||||
|
|
||||||
/* (non-Javadoc)
|
@Override
|
||||||
* @see org.mozilla.javascript.Scriptable#delete(int)
|
|
||||||
*/
|
|
||||||
|
|
||||||
public void delete(int index) {
|
public void delete(int index) {
|
||||||
int i = 0;
|
int i = 0;
|
||||||
Iterator itrKeys = map.keySet().iterator();
|
Iterator<Object> itrKeys = map.keySet().iterator();
|
||||||
while (i <= index && itrKeys.hasNext()) {
|
while (i <= index && itrKeys.hasNext()) {
|
||||||
Object key = itrKeys.next();
|
Object key = itrKeys.next();
|
||||||
if (i == index) {
|
if (i == index) {
|
||||||
|
@ -167,58 +136,37 @@ public class ScriptableWrappedMap implements ScriptableMap, Wrapper {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
/* (non-Javadoc)
|
@Override
|
||||||
* @see org.mozilla.javascript.Scriptable#getPrototype()
|
|
||||||
*/
|
|
||||||
|
|
||||||
public Scriptable getPrototype() {
|
public Scriptable getPrototype() {
|
||||||
return this.prototype;
|
return this.prototype;
|
||||||
}
|
}
|
||||||
|
|
||||||
/* (non-Javadoc)
|
@Override
|
||||||
* @see org.mozilla.javascript.Scriptable#setPrototype(org.mozilla.javascript.Scriptable)
|
|
||||||
*/
|
|
||||||
|
|
||||||
public void setPrototype(Scriptable prototype) {
|
public void setPrototype(Scriptable prototype) {
|
||||||
this.prototype = prototype;
|
this.prototype = prototype;
|
||||||
}
|
}
|
||||||
|
|
||||||
/* (non-Javadoc)
|
@Override
|
||||||
* @see org.mozilla.javascript.Scriptable#getParentScope()
|
|
||||||
*/
|
|
||||||
|
|
||||||
public Scriptable getParentScope() {
|
public Scriptable getParentScope() {
|
||||||
return this.parentScope;
|
return this.parentScope;
|
||||||
}
|
}
|
||||||
|
|
||||||
/* (non-Javadoc)
|
@Override
|
||||||
* @see org.mozilla.javascript.Scriptable#setParentScope(org.mozilla.javascript.Scriptable)
|
|
||||||
*/
|
|
||||||
|
|
||||||
public void setParentScope(Scriptable parent) {
|
public void setParentScope(Scriptable parent) {
|
||||||
this.parentScope = parent;
|
this.parentScope = parent;
|
||||||
}
|
}
|
||||||
|
|
||||||
/* (non-Javadoc)
|
@Override
|
||||||
* @see org.mozilla.javascript.Scriptable#getIds()
|
|
||||||
*/
|
|
||||||
|
|
||||||
public Object[] getIds() {
|
public Object[] getIds() {
|
||||||
return map.keySet().toArray();
|
return map.keySet().toArray();
|
||||||
}
|
}
|
||||||
|
|
||||||
/* (non-Javadoc)
|
@Override
|
||||||
* @see org.mozilla.javascript.Scriptable#getDefaultValue(java.lang.Class)
|
public Object getDefaultValue(Class<?> hint) {
|
||||||
*/
|
|
||||||
|
|
||||||
public Object getDefaultValue(Class hint) {
|
|
||||||
return null;
|
return null;
|
||||||
}
|
}
|
||||||
|
|
||||||
/* (non-Javadoc)
|
@Override
|
||||||
* @see org.mozilla.javascript.Scriptable#hasInstance(org.mozilla.javascript.Scriptable)
|
|
||||||
*/
|
|
||||||
|
|
||||||
public boolean hasInstance(Scriptable value) {
|
public boolean hasInstance(Scriptable value) {
|
||||||
if (!(value instanceof Wrapper))
|
if (!(value instanceof Wrapper))
|
||||||
return false;
|
return false;
|
||||||
|
@ -226,106 +174,66 @@ public class ScriptableWrappedMap implements ScriptableMap, Wrapper {
|
||||||
return Map.class.isInstance(instance);
|
return Map.class.isInstance(instance);
|
||||||
}
|
}
|
||||||
|
|
||||||
/* (non-Javadoc)
|
@Override
|
||||||
* @see java.util.Map#clear()
|
|
||||||
*/
|
|
||||||
|
|
||||||
public void clear() {
|
public void clear() {
|
||||||
this.map.clear();
|
this.map.clear();
|
||||||
}
|
}
|
||||||
|
|
||||||
/* (non-Javadoc)
|
@Override
|
||||||
* @see java.util.Map#containsKey(java.lang.Object)
|
|
||||||
*/
|
|
||||||
|
|
||||||
public boolean containsKey(Object key) {
|
public boolean containsKey(Object key) {
|
||||||
return this.map.containsKey(key);
|
return this.map.containsKey(key);
|
||||||
}
|
}
|
||||||
|
|
||||||
/* (non-Javadoc)
|
@Override
|
||||||
* @see java.util.Map#containsValue(java.lang.Object)
|
|
||||||
*/
|
|
||||||
|
|
||||||
public boolean containsValue(Object value) {
|
public boolean containsValue(Object value) {
|
||||||
return this.map.containsValue(value);
|
return this.map.containsValue(value);
|
||||||
}
|
}
|
||||||
|
|
||||||
/* (non-Javadoc)
|
@Override
|
||||||
* @see java.util.Map#entrySet()
|
public Set<Map.Entry<Object, Object>> entrySet() {
|
||||||
*/
|
|
||||||
|
|
||||||
public Set entrySet() {
|
|
||||||
return this.map.entrySet();
|
return this.map.entrySet();
|
||||||
}
|
}
|
||||||
|
|
||||||
/* (non-Javadoc)
|
@Override
|
||||||
* @see java.util.Map#get(java.lang.Object)
|
|
||||||
*/
|
|
||||||
|
|
||||||
public Object get(Object key) {
|
public Object get(Object key) {
|
||||||
return this.map.get(key);
|
return this.map.get(key);
|
||||||
}
|
}
|
||||||
|
|
||||||
/* (non-Javadoc)
|
@Override
|
||||||
* @see java.util.Map#isEmpty()
|
|
||||||
*/
|
|
||||||
|
|
||||||
public boolean isEmpty() {
|
public boolean isEmpty() {
|
||||||
return (this.map.size() == 0);
|
return (this.map.size() == 0);
|
||||||
}
|
}
|
||||||
|
|
||||||
/* (non-Javadoc)
|
@Override
|
||||||
* @see java.util.Map#keySet()
|
public Set<Object> keySet() {
|
||||||
*/
|
|
||||||
|
|
||||||
public Set keySet() {
|
|
||||||
return this.map.keySet();
|
return this.map.keySet();
|
||||||
}
|
}
|
||||||
|
|
||||||
/* (non-Javadoc)
|
@Override
|
||||||
* @see java.util.Map#put(java.lang.Object, java.lang.Object)
|
|
||||||
*/
|
|
||||||
|
|
||||||
public Object put(Object key, Object value) {
|
public Object put(Object key, Object value) {
|
||||||
return this.map.put(key, value);
|
return this.map.put(key, value);
|
||||||
}
|
}
|
||||||
|
|
||||||
/* (non-Javadoc)
|
@Override
|
||||||
* @see java.util.Map#putAll(java.util.Map)
|
public void putAll(Map<? extends Object, ? extends Object> t) {
|
||||||
*/
|
|
||||||
|
|
||||||
public void putAll(Map t) {
|
|
||||||
this.map.putAll(t);
|
this.map.putAll(t);
|
||||||
}
|
}
|
||||||
|
|
||||||
/* (non-Javadoc)
|
@Override
|
||||||
* @see java.util.Map#remove(java.lang.Object)
|
|
||||||
*/
|
|
||||||
|
|
||||||
public Object remove(Object key) {
|
public Object remove(Object key) {
|
||||||
return this.map.remove(key);
|
return this.map.remove(key);
|
||||||
}
|
}
|
||||||
|
|
||||||
/* (non-Javadoc)
|
@Override
|
||||||
* @see java.util.Map#size()
|
|
||||||
*/
|
|
||||||
|
|
||||||
public int size() {
|
public int size() {
|
||||||
return this.map.size();
|
return this.map.size();
|
||||||
}
|
}
|
||||||
|
|
||||||
/* (non-Javadoc)
|
@Override
|
||||||
* @see java.util.Map#values()
|
public Collection<Object> values() {
|
||||||
*/
|
|
||||||
|
|
||||||
public Collection values() {
|
|
||||||
return this.map.values();
|
return this.map.values();
|
||||||
}
|
}
|
||||||
|
|
||||||
/* (non-Javadoc)
|
|
||||||
* @see java.lang.Object#toString()
|
|
||||||
*/
|
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public String toString() {
|
public String toString() {
|
||||||
return (this.map != null ? this.map.toString() : super.toString());
|
return (this.map != null ? this.map.toString() : super.toString());
|
||||||
|
|
|
@ -19,6 +19,12 @@
|
||||||
|
|
||||||
package org.elasticsearch.script.javascript;
|
package org.elasticsearch.script.javascript;
|
||||||
|
|
||||||
|
import java.util.Arrays;
|
||||||
|
import java.util.Collections;
|
||||||
|
import java.util.HashMap;
|
||||||
|
import java.util.List;
|
||||||
|
import java.util.Map;
|
||||||
|
|
||||||
import org.elasticsearch.common.collect.MapBuilder;
|
import org.elasticsearch.common.collect.MapBuilder;
|
||||||
import org.elasticsearch.common.settings.Settings;
|
import org.elasticsearch.common.settings.Settings;
|
||||||
import org.elasticsearch.script.CompiledScript;
|
import org.elasticsearch.script.CompiledScript;
|
||||||
|
@ -28,12 +34,6 @@ import org.elasticsearch.test.ESTestCase;
|
||||||
import org.junit.After;
|
import org.junit.After;
|
||||||
import org.junit.Before;
|
import org.junit.Before;
|
||||||
|
|
||||||
import java.util.Arrays;
|
|
||||||
import java.util.Collections;
|
|
||||||
import java.util.HashMap;
|
|
||||||
import java.util.List;
|
|
||||||
import java.util.Map;
|
|
||||||
|
|
||||||
import static org.hamcrest.Matchers.equalTo;
|
import static org.hamcrest.Matchers.equalTo;
|
||||||
import static org.hamcrest.Matchers.instanceOf;
|
import static org.hamcrest.Matchers.instanceOf;
|
||||||
|
|
||||||
|
@ -59,6 +59,7 @@ public class JavaScriptScriptEngineTests extends ESTestCase {
|
||||||
assertThat(((Number) o).intValue(), equalTo(3));
|
assertThat(((Number) o).intValue(), equalTo(3));
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@SuppressWarnings("unchecked")
|
||||||
public void testMapAccess() {
|
public void testMapAccess() {
|
||||||
Map<String, Object> vars = new HashMap<String, Object>();
|
Map<String, Object> vars = new HashMap<String, Object>();
|
||||||
|
|
||||||
|
@ -75,15 +76,17 @@ public class JavaScriptScriptEngineTests extends ESTestCase {
|
||||||
assertThat(((String) o), equalTo("2"));
|
assertThat(((String) o), equalTo("2"));
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@SuppressWarnings("unchecked")
|
||||||
public void testJavaScriptObjectToMap() {
|
public void testJavaScriptObjectToMap() {
|
||||||
Map<String, Object> vars = new HashMap<String, Object>();
|
Map<String, Object> vars = new HashMap<String, Object>();
|
||||||
Object o = se.executable(new CompiledScript(ScriptService.ScriptType.INLINE, "testJavaScriptObjectToMap", "js",
|
Object o = se.executable(new CompiledScript(ScriptService.ScriptType.INLINE, "testJavaScriptObjectToMap", "js",
|
||||||
se.compile("var obj1 = {}; obj1.prop1 = 'value1'; obj1.obj2 = {}; obj1.obj2.prop2 = 'value2'; obj1", Collections.emptyMap())), vars).run();
|
se.compile("var obj1 = {}; obj1.prop1 = 'value1'; obj1.obj2 = {}; obj1.obj2.prop2 = 'value2'; obj1", Collections.emptyMap())), vars).run();
|
||||||
Map obj1 = (Map) o;
|
Map<String, Object> obj1 = (Map<String, Object>) o;
|
||||||
assertThat((String) obj1.get("prop1"), equalTo("value1"));
|
assertThat((String) obj1.get("prop1"), equalTo("value1"));
|
||||||
assertThat((String) ((Map<String, Object>) obj1.get("obj2")).get("prop2"), equalTo("value2"));
|
assertThat((String) ((Map<String, Object>) obj1.get("obj2")).get("prop2"), equalTo("value2"));
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@SuppressWarnings("unchecked")
|
||||||
public void testJavaScriptObjectMapInter() {
|
public void testJavaScriptObjectMapInter() {
|
||||||
Map<String, Object> vars = new HashMap<String, Object>();
|
Map<String, Object> vars = new HashMap<String, Object>();
|
||||||
Map<String, Object> ctx = new HashMap<String, Object>();
|
Map<String, Object> ctx = new HashMap<String, Object>();
|
||||||
|
@ -102,6 +105,7 @@ public class JavaScriptScriptEngineTests extends ESTestCase {
|
||||||
assertThat((String) ((Map<String, Object>) ctx.get("obj2")).get("prop2"), equalTo("value2"));
|
assertThat((String) ((Map<String, Object>) ctx.get("obj2")).get("prop2"), equalTo("value2"));
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@SuppressWarnings("unchecked")
|
||||||
public void testJavaScriptInnerArrayCreation() {
|
public void testJavaScriptInnerArrayCreation() {
|
||||||
Map<String, Object> ctx = new HashMap<String, Object>();
|
Map<String, Object> ctx = new HashMap<String, Object>();
|
||||||
Map<String, Object> doc = new HashMap<String, Object>();
|
Map<String, Object> doc = new HashMap<String, Object>();
|
||||||
|
@ -115,9 +119,10 @@ public class JavaScriptScriptEngineTests extends ESTestCase {
|
||||||
|
|
||||||
Map<String, Object> unwrap = (Map<String, Object>) script.unwrap(ctx);
|
Map<String, Object> unwrap = (Map<String, Object>) script.unwrap(ctx);
|
||||||
|
|
||||||
assertThat(((Map) unwrap.get("doc")).get("field1"), instanceOf(List.class));
|
assertThat(((Map<String, Object>) unwrap.get("doc")).get("field1"), instanceOf(List.class));
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@SuppressWarnings("unchecked")
|
||||||
public void testAccessListInScript() {
|
public void testAccessListInScript() {
|
||||||
Map<String, Object> vars = new HashMap<String, Object>();
|
Map<String, Object> vars = new HashMap<String, Object>();
|
||||||
Map<String, Object> obj2 = MapBuilder.<String, Object>newMapBuilder().put("prop2", "value2").map();
|
Map<String, Object> obj2 = MapBuilder.<String, Object>newMapBuilder().put("prop2", "value2").map();
|
||||||
|
|
|
@ -26,9 +26,6 @@ dependencies {
|
||||||
compile 'org.python:jython-standalone:2.7.0'
|
compile 'org.python:jython-standalone:2.7.0'
|
||||||
}
|
}
|
||||||
|
|
||||||
compileJava.options.compilerArgs << "-Xlint:-unchecked"
|
|
||||||
compileTestJava.options.compilerArgs << "-Xlint:-unchecked"
|
|
||||||
|
|
||||||
integTest {
|
integTest {
|
||||||
cluster {
|
cluster {
|
||||||
systemProperty 'es.script.inline', 'on'
|
systemProperty 'es.script.inline', 'on'
|
||||||
|
|
|
@ -19,6 +19,11 @@
|
||||||
|
|
||||||
package org.elasticsearch.script.python;
|
package org.elasticsearch.script.python;
|
||||||
|
|
||||||
|
import java.util.Arrays;
|
||||||
|
import java.util.Collections;
|
||||||
|
import java.util.HashMap;
|
||||||
|
import java.util.Map;
|
||||||
|
|
||||||
import org.elasticsearch.common.collect.MapBuilder;
|
import org.elasticsearch.common.collect.MapBuilder;
|
||||||
import org.elasticsearch.common.settings.Settings;
|
import org.elasticsearch.common.settings.Settings;
|
||||||
import org.elasticsearch.script.CompiledScript;
|
import org.elasticsearch.script.CompiledScript;
|
||||||
|
@ -28,11 +33,6 @@ import org.elasticsearch.test.ESTestCase;
|
||||||
import org.junit.After;
|
import org.junit.After;
|
||||||
import org.junit.Before;
|
import org.junit.Before;
|
||||||
|
|
||||||
import java.util.Arrays;
|
|
||||||
import java.util.Collections;
|
|
||||||
import java.util.HashMap;
|
|
||||||
import java.util.Map;
|
|
||||||
|
|
||||||
import static org.hamcrest.Matchers.equalTo;
|
import static org.hamcrest.Matchers.equalTo;
|
||||||
import static org.hamcrest.Matchers.instanceOf;
|
import static org.hamcrest.Matchers.instanceOf;
|
||||||
|
|
||||||
|
@ -58,6 +58,7 @@ public class PythonScriptEngineTests extends ESTestCase {
|
||||||
assertThat(((Number) o).intValue(), equalTo(3));
|
assertThat(((Number) o).intValue(), equalTo(3));
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@SuppressWarnings("unchecked")
|
||||||
public void testMapAccess() {
|
public void testMapAccess() {
|
||||||
Map<String, Object> vars = new HashMap<String, Object>();
|
Map<String, Object> vars = new HashMap<String, Object>();
|
||||||
|
|
||||||
|
@ -74,6 +75,7 @@ public class PythonScriptEngineTests extends ESTestCase {
|
||||||
assertThat(((String) o), equalTo("2"));
|
assertThat(((String) o), equalTo("2"));
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@SuppressWarnings("unchecked")
|
||||||
public void testObjectMapInter() {
|
public void testObjectMapInter() {
|
||||||
Map<String, Object> vars = new HashMap<String, Object>();
|
Map<String, Object> vars = new HashMap<String, Object>();
|
||||||
Map<String, Object> ctx = new HashMap<String, Object>();
|
Map<String, Object> ctx = new HashMap<String, Object>();
|
||||||
|
@ -92,6 +94,7 @@ public class PythonScriptEngineTests extends ESTestCase {
|
||||||
assertThat((String) ((Map<String, Object>) ctx.get("obj2")).get("prop2"), equalTo("value2"));
|
assertThat((String) ((Map<String, Object>) ctx.get("obj2")).get("prop2"), equalTo("value2"));
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@SuppressWarnings("unchecked")
|
||||||
public void testAccessListInScript() {
|
public void testAccessListInScript() {
|
||||||
Map<String, Object> vars = new HashMap<String, Object>();
|
Map<String, Object> vars = new HashMap<String, Object>();
|
||||||
Map<String, Object> obj2 = MapBuilder.<String, Object>newMapBuilder().put("prop2", "value2").map();
|
Map<String, Object> obj2 = MapBuilder.<String, Object>newMapBuilder().put("prop2", "value2").map();
|
||||||
|
|
|
@ -21,5 +21,3 @@ esplugin {
|
||||||
description 'The Mapper Murmur3 plugin allows to compute hashes of a field\'s values at index-time and to store them in the index.'
|
description 'The Mapper Murmur3 plugin allows to compute hashes of a field\'s values at index-time and to store them in the index.'
|
||||||
classname 'org.elasticsearch.plugin.mapper.MapperMurmur3Plugin'
|
classname 'org.elasticsearch.plugin.mapper.MapperMurmur3Plugin'
|
||||||
}
|
}
|
||||||
|
|
||||||
compileJava.options.compilerArgs << "-Xlint:-rawtypes"
|
|
||||||
|
|
|
@ -19,6 +19,10 @@
|
||||||
|
|
||||||
package org.elasticsearch.index.mapper.murmur3;
|
package org.elasticsearch.index.mapper.murmur3;
|
||||||
|
|
||||||
|
import java.io.IOException;
|
||||||
|
import java.util.List;
|
||||||
|
import java.util.Map;
|
||||||
|
|
||||||
import org.apache.lucene.document.Field;
|
import org.apache.lucene.document.Field;
|
||||||
import org.apache.lucene.index.IndexOptions;
|
import org.apache.lucene.index.IndexOptions;
|
||||||
import org.apache.lucene.util.BytesRef;
|
import org.apache.lucene.util.BytesRef;
|
||||||
|
@ -35,10 +39,6 @@ import org.elasticsearch.index.mapper.ParseContext;
|
||||||
import org.elasticsearch.index.mapper.core.LongFieldMapper;
|
import org.elasticsearch.index.mapper.core.LongFieldMapper;
|
||||||
import org.elasticsearch.index.mapper.core.NumberFieldMapper;
|
import org.elasticsearch.index.mapper.core.NumberFieldMapper;
|
||||||
|
|
||||||
import java.io.IOException;
|
|
||||||
import java.util.List;
|
|
||||||
import java.util.Map;
|
|
||||||
|
|
||||||
import static org.elasticsearch.index.mapper.core.TypeParsers.parseNumberField;
|
import static org.elasticsearch.index.mapper.core.TypeParsers.parseNumberField;
|
||||||
|
|
||||||
public class Murmur3FieldMapper extends LongFieldMapper {
|
public class Murmur3FieldMapper extends LongFieldMapper {
|
||||||
|
@ -93,8 +93,7 @@ public class Murmur3FieldMapper extends LongFieldMapper {
|
||||||
|
|
||||||
public static class TypeParser implements Mapper.TypeParser {
|
public static class TypeParser implements Mapper.TypeParser {
|
||||||
@Override
|
@Override
|
||||||
@SuppressWarnings("unchecked")
|
public Mapper.Builder<?, ?> parse(String name, Map<String, Object> node, ParserContext parserContext) throws MapperParsingException {
|
||||||
public Mapper.Builder parse(String name, Map<String, Object> node, ParserContext parserContext) throws MapperParsingException {
|
|
||||||
Builder builder = new Builder(name);
|
Builder builder = new Builder(name);
|
||||||
|
|
||||||
// tweaking these settings is no longer allowed, the entire purpose of murmur3 fields is to store a hash
|
// tweaking these settings is no longer allowed, the entire purpose of murmur3 fields is to store a hash
|
||||||
|
|
Loading…
Reference in New Issue