merge: #10734

10734: [Backport stable/8.1] Add activatedElementInstanceKeys to modification record template r=remcowesterhoud a=backport-action # Description Backport of #10733 to `stable/8.1`. relates to #10732 Co-authored-by: Remco Westerhoud <remco@westerhoud.nl>
camunda · Oct 17, 2022 · c5c8e69 · c5c8e69
2 parents 2d58ea0 + eaca172
commit c5c8e69
Show file tree

Hide file tree

Showing 3 changed files with 16 additions and 7 deletions.
diff --git a/...arch-exporter/src/main/resources/zeebe-record-process-instance-modification-template.json b/...arch-exporter/src/main/resources/zeebe-record-process-instance-modification-template.json
@@ -2,7 +2,9 @@
   "index_patterns": [
     "zeebe-record_process-instance-modification_*"
   ],
-  "composed_of": ["zeebe-record"],
+  "composed_of": [
+    "zeebe-record"
+  ],
   "priority": 20,
   "version": 1,
   "template": {
@@ -48,6 +50,9 @@
                   }
                 }
               }
+            },
+            "activatedElementInstanceKeys": {
+              "type": "long"
             }
           }
         }

diff --git a/...a/zeebe/protocol/impl/record/value/processinstance/ProcessInstanceModificationRecord.java b/...a/zeebe/protocol/impl/record/value/processinstance/ProcessInstanceModificationRecord.java
@@ -80,6 +80,13 @@ public List<ProcessInstanceModificationActivateInstructionValue> getActivateInst
         .toList();
   }
 
+  @Override
+  public Set<Long> getActivatedElementInstanceKeys() {
+    return activatedElementInstanceKeys.stream()
+        .map(LongValue::getValue)
+        .collect(Collectors.toSet());
+  }
+
   /** Returns true if this record has terminate instructions, otherwise false. */
   @JsonIgnore
   public boolean hasTerminateInstructions() {
@@ -104,12 +111,6 @@ public ProcessInstanceModificationRecord addActivateInstruction(
     return this;
   }
 
-  public Set<Long> getActivatedElementInstanceKeys() {
-    return activatedElementInstanceKeys.stream()
-        .map(LongValue::getValue)
-        .collect(Collectors.toSet());
-  }
-
   public ProcessInstanceModificationRecord addActivatedElementInstanceKey(final long key) {
     activatedElementInstanceKeys.add().setValue(key);
     return this;

diff --git a/...n/java/io/camunda/zeebe/protocol/record/value/ProcessInstanceModificationRecordValue.java b/...n/java/io/camunda/zeebe/protocol/record/value/ProcessInstanceModificationRecordValue.java
@@ -19,6 +19,7 @@
 import io.camunda.zeebe.protocol.record.RecordValue;
 import java.util.List;
 import java.util.Map;
+import java.util.Set;
 import org.immutables.value.Value;
 
 @Value.Immutable
@@ -32,6 +33,8 @@ public interface ProcessInstanceModificationRecordValue
   /** Returns a list of activate instructions (if available), or an empty list. */
   List<ProcessInstanceModificationActivateInstructionValue> getActivateInstructions();
 
+  Set<Long> getActivatedElementInstanceKeys();
+
   @Value.Immutable
   @ImmutableProtocol(
       builder = ImmutableProcessInstanceModificationTerminateInstructionValue.Builder.class)