apm-data: Use representative count as event.success_count if available

docs/changelog/119995.yaml

@@ -0,0 +1,5 @@
+pr: 119995
+summary: Add representative count to apm-data plugin
+area: Ingest Node
+type: enhancement
+issues: []

x-pack/plugin/apm-data/src/main/resources/ingest-pipelines/traces-apm@pipeline.yaml

@@ -30,10 +30,10 @@ processors:
     field: ["event.duration"]
     ignore_failure: true
     ignore_missing: true
-- set:
-    if: ctx.event?.outcome == 'success'
-    field: event.success_count
-    value: 1
+- script:
+    if: ctx.event?.outcome == 'success' && ctx[ctx.processor?.event]?.representative_count != null
+    source: |
+        ctx.event.success_count = ctx[ctx.processor?.event]?.representative_count;
 - set:
     if: ctx.event?.outcome == 'failure'
     field: event.success_count

x-pack/plugin/apm-data/src/yamlRestTest/resources/rest-api-spec/test/20_traces_ingest.yml

@@ -80,7 +80,20 @@ setup:
           - '{"@timestamp": "2017-06-22", "event": {"outcome": "unknown"}}'
 
           - create: {}
-          - '{"@timestamp": "2017-06-22", "event": {"outcome": "success"}}'
+          - '{
+            "@timestamp": "2017-06-22",
+            "processor": {"event": "transaction"},
+            "event": {"outcome": "success"},
+            "transaction": {"representative_count": 2}
+          }'
+
+          - create: {}
+          - '{
+            "@timestamp": "2017-06-22",
+            "processor": {"event": "span"},
+            "event": {"outcome": "success"},
+            "span": {"representative_count": 3}
+          }'
 
           - create: {}
           - '{"@timestamp": "2017-06-22", "event": {"outcome": "failure"}}'
@@ -92,8 +105,9 @@ setup:
         index: traces-apm-testing
         body:
           fields: ["event.success_count"]
-  - length: { hits.hits: 4 }
+  - length: { hits.hits: 5 }
   - match: { hits.hits.0.fields: null }
   - match: { hits.hits.1.fields: null }
-  - match: { hits.hits.2.fields: {"event.success_count": [1]} }
-  - match: { hits.hits.3.fields: {"event.success_count": [0]} }
+  - match: { hits.hits.2.fields: {"event.success_count": [2]} }
+  - match: { hits.hits.3.fields: {"event.success_count": [3]} }
+  - match: { hits.hits.4.fields: {"event.success_count": [0]} }