diff --git a/plugins/ingest/src/main/java/org/elasticsearch/plugin/ingest/IngestPlugin.java b/plugins/ingest/src/main/java/org/elasticsearch/plugin/ingest/IngestPlugin.java index 2db3c9ec69d..af85765c416 100644 --- a/plugins/ingest/src/main/java/org/elasticsearch/plugin/ingest/IngestPlugin.java +++ b/plugins/ingest/src/main/java/org/elasticsearch/plugin/ingest/IngestPlugin.java @@ -50,7 +50,7 @@ import static org.elasticsearch.common.settings.Settings.settingsBuilder; public class IngestPlugin extends Plugin { public static final String PIPELINE_ID_PARAM_CONTEXT_KEY = "__pipeline_id__"; - public static final String PIPELINE_ID_PARAM = "pipeline_id"; + public static final String PIPELINE_ID_PARAM = "pipeline"; public static final String PIPELINE_ALREADY_PROCESSED = "ingest_already_processed"; public static final String NAME = "ingest"; public static final String NODE_INGEST_SETTING = "node.ingest"; diff --git a/plugins/ingest/src/test/resources/rest-api-spec/api/ingest.bulk.json b/plugins/ingest/src/test/resources/rest-api-spec/api/ingest.bulk.json index 5595c2007ff..ecd53ee496b 100644 --- a/plugins/ingest/src/test/resources/rest-api-spec/api/ingest.bulk.json +++ b/plugins/ingest/src/test/resources/rest-api-spec/api/ingest.bulk.json @@ -41,7 +41,7 @@ "type": "list", "description" : "Default comma-separated list of fields to return in the response for updates" }, - "pipeline_id" : { + "pipeline" : { "type" : "string", "description" : "The pipeline id to preprocess incoming documents with" } diff --git a/plugins/ingest/src/test/resources/rest-api-spec/api/ingest.index.json b/plugins/ingest/src/test/resources/rest-api-spec/api/ingest.index.json index 02dc30b2f3b..7420f69e45e 100644 --- a/plugins/ingest/src/test/resources/rest-api-spec/api/ingest.index.json +++ b/plugins/ingest/src/test/resources/rest-api-spec/api/ingest.index.json @@ -66,7 +66,7 @@ "options" : ["internal", "external", "external_gte", "force"], "description" : "Specific version type" }, - "pipeline_id" : { + "pipeline" : { "type" : "string", "description" : "The pipeline id to preprocess incoming documents with" } diff --git a/plugins/ingest/src/test/resources/rest-api-spec/test/ingest/30_grok.yaml b/plugins/ingest/src/test/resources/rest-api-spec/test/ingest/30_grok.yaml index 7c43273657c..e8a59d4ea65 100644 --- a/plugins/ingest/src/test/resources/rest-api-spec/test/ingest/30_grok.yaml +++ b/plugins/ingest/src/test/resources/rest-api-spec/test/ingest/30_grok.yaml @@ -22,7 +22,7 @@ index: test type: test id: 1 - pipeline_id: "my_pipeline" + pipeline: "my_pipeline" body: {field1: "123.42 400 "} - do: @@ -61,7 +61,7 @@ index: test type: test id: 1 - pipeline_id: "my_pipeline" + pipeline: "my_pipeline" body: {field1: ""} - do: @@ -98,7 +98,7 @@ index: test type: test id: 1 - pipeline_id: "my_pipeline" + pipeline: "my_pipeline" body: {field1: ""} - do: diff --git a/plugins/ingest/src/test/resources/rest-api-spec/test/ingest/40_geoip_processor.yaml b/plugins/ingest/src/test/resources/rest-api-spec/test/ingest/40_geoip_processor.yaml index d35898a59d5..d86eb25d4d4 100644 --- a/plugins/ingest/src/test/resources/rest-api-spec/test/ingest/40_geoip_processor.yaml +++ b/plugins/ingest/src/test/resources/rest-api-spec/test/ingest/40_geoip_processor.yaml @@ -21,7 +21,7 @@ index: test type: test id: 1 - pipeline_id: "my_pipeline" + pipeline: "my_pipeline" body: {field1: "128.101.101.101"} - do: @@ -65,7 +65,7 @@ index: test type: test id: 1 - pipeline_id: "my_pipeline" + pipeline: "my_pipeline" body: {field1: "128.101.101.101"} - do: @@ -110,7 +110,7 @@ index: test type: test id: 1 - pipeline_id: "my_pipeline" + pipeline: "my_pipeline" body: {field1: "128.101.101.101"} - do: diff --git a/plugins/ingest/src/test/resources/rest-api-spec/test/ingest/50_date_processor.yaml b/plugins/ingest/src/test/resources/rest-api-spec/test/ingest/50_date_processor.yaml index 5caad399d23..64354c8ac16 100644 --- a/plugins/ingest/src/test/resources/rest-api-spec/test/ingest/50_date_processor.yaml +++ b/plugins/ingest/src/test/resources/rest-api-spec/test/ingest/50_date_processor.yaml @@ -24,7 +24,7 @@ index: test type: test id: 1 - pipeline_id: "my_pipeline" + pipeline: "my_pipeline" body: {date_source_field: "12/06/2010"} - do: diff --git a/plugins/ingest/src/test/resources/rest-api-spec/test/ingest/60_mutate.yaml b/plugins/ingest/src/test/resources/rest-api-spec/test/ingest/60_mutate.yaml index a15bc440022..f1a324318e7 100644 --- a/plugins/ingest/src/test/resources/rest-api-spec/test/ingest/60_mutate.yaml +++ b/plugins/ingest/src/test/resources/rest-api-spec/test/ingest/60_mutate.yaml @@ -79,7 +79,7 @@ index: test type: test id: 1 - pipeline_id: "my_pipeline" + pipeline: "my_pipeline" body: { field_to_rename: "value", field_to_remove: "old_value", @@ -137,7 +137,7 @@ index: test type: test id: 1 - pipeline_id: "my_pipeline" + pipeline: "my_pipeline" body: {field: "value"} - do: diff --git a/plugins/ingest/src/test/resources/rest-api-spec/test/ingest/80_on_failure.yaml b/plugins/ingest/src/test/resources/rest-api-spec/test/ingest/80_on_failure.yaml index eeae210c2b5..e28d5ddaf94 100644 --- a/plugins/ingest/src/test/resources/rest-api-spec/test/ingest/80_on_failure.yaml +++ b/plugins/ingest/src/test/resources/rest-api-spec/test/ingest/80_on_failure.yaml @@ -42,7 +42,7 @@ index: test type: test id: 1 - pipeline_id: "my_pipeline" + pipeline: "my_pipeline" body: {field1: "123.42 400 "} - do: @@ -107,7 +107,7 @@ index: test type: test id: 1 - pipeline_id: "my_pipeline" + pipeline: "my_pipeline" body: {field1: "123.42 400 "} - do: diff --git a/qa/ingest-with-mustache/src/test/resources/rest-api-spec/test/ingest_mustache/10_pipeline_with_mustache_templates.yaml b/qa/ingest-with-mustache/src/test/resources/rest-api-spec/test/ingest_mustache/10_pipeline_with_mustache_templates.yaml index 52be7299e29..9c44d86feaf 100644 --- a/qa/ingest-with-mustache/src/test/resources/rest-api-spec/test/ingest_mustache/10_pipeline_with_mustache_templates.yaml +++ b/qa/ingest-with-mustache/src/test/resources/rest-api-spec/test/ingest_mustache/10_pipeline_with_mustache_templates.yaml @@ -32,7 +32,7 @@ index: test type: test id: 1 - pipeline_id: "my_pipeline_1" + pipeline: "my_pipeline_1" body: {} - do: @@ -112,7 +112,7 @@ index: test type: test id: 1 - pipeline_id: "my_pipeline_1" + pipeline: "my_pipeline_1" body: { metadata: "0", field1: "1", @@ -137,7 +137,7 @@ index: test type: test id: 1 - pipeline_id: "my_pipeline_2" + pipeline: "my_pipeline_2" body: { field1: "field2" } @@ -156,7 +156,7 @@ index: test type: test id: 1 - pipeline_id: "my_pipeline_3" + pipeline: "my_pipeline_3" body: { field_to_remove: "field2", field2: "2",