|
@@ -30,7 +30,6 @@ import org.elasticsearch.common.xcontent.json.JsonXContent;
|
|
|
import org.elasticsearch.ingest.AbstractProcessor;
|
|
|
import org.elasticsearch.ingest.IngestDocument;
|
|
|
import org.elasticsearch.ingest.Processor;
|
|
|
-import org.elasticsearch.script.DeprecationMap;
|
|
|
import org.elasticsearch.script.IngestScript;
|
|
|
import org.elasticsearch.script.Script;
|
|
|
import org.elasticsearch.script.ScriptException;
|
|
@@ -38,7 +37,6 @@ import org.elasticsearch.script.ScriptService;
|
|
|
|
|
|
import java.io.InputStream;
|
|
|
import java.util.Arrays;
|
|
|
-import java.util.Collections;
|
|
|
import java.util.Map;
|
|
|
|
|
|
import static org.elasticsearch.ingest.ConfigurationUtils.newConfigurationException;
|
|
@@ -48,9 +46,6 @@ import static org.elasticsearch.ingest.ConfigurationUtils.newConfigurationExcept
|
|
|
*/
|
|
|
public final class ScriptProcessor extends AbstractProcessor {
|
|
|
|
|
|
- private static final Map<String, String> DEPRECATIONS =
|
|
|
- Collections.singletonMap("_type", "[types removal] Looking up doc types [_type] in scripts is deprecated.");
|
|
|
-
|
|
|
public static final String TYPE = "script";
|
|
|
|
|
|
private final Script script;
|
|
@@ -77,8 +72,7 @@ public final class ScriptProcessor extends AbstractProcessor {
|
|
|
@Override
|
|
|
public IngestDocument execute(IngestDocument document) {
|
|
|
IngestScript.Factory factory = scriptService.compile(script, IngestScript.CONTEXT);
|
|
|
- factory.newInstance(script.getParams()).execute(
|
|
|
- new DeprecationMap(document.getSourceAndMetadata(), DEPRECATIONS, "script_processor"));
|
|
|
+ factory.newInstance(script.getParams()).execute(document.getSourceAndMetadata());
|
|
|
CollectionUtils.ensureNoSelfReferences(document.getSourceAndMetadata(), "ingest script");
|
|
|
return document;
|
|
|
}
|