Add merge in place and patch in place benches

Signed-off-by: Matthias Wahl <mwahl@wayfair.com>

bench/merge_assign_target.yaml

@@ -0,0 +1,25 @@
+# Test a realistic workflow including json encoding and decoding
+# and connect both the pass and the overflow output to the
+# blackhole to acount for the data
+---
+onramp:
+  - id: blaster
+    type: blaster
+    codec: json
+    config:
+      source: ./demo/data/data.json.xz
+
+offramp:
+  - id: blackhole
+    type: blackhole
+    codec: json
+    config:
+      warmup_secs: 10
+      stop_after_secs: 100
+      significant_figures: 2
+
+binding:
+  - id: bench
+    links:
+      "/onramp/blaster/{instance}/out": ["/pipeline/main/{instance}/in"]
+      "/pipeline/main/{instance}/out": ["/offramp/blackhole/{instance}/in"]

bench/merge_assign_target/main.trickle

@@ -0,0 +1,11 @@
+define script merge_assign_target
+script
+	let event = merge event of {"foo": "bar"} end;
+	emit event;
+end;
+
+create script merge_assign_target;
+
+select event from in into merge_assign_target;
+select event from merge_assign_target into out;
+select event from merge_assign_target/err into err;

bench/patch_assign_target.yaml

@@ -0,0 +1,25 @@
+# Test a realistic workflow including json encoding and decoding
+# and connect both the pass and the overflow output to the
+# blackhole to acount for the data
+---
+onramp:
+  - id: blaster
+    type: blaster
+    codec: json
+    config:
+      source: ./demo/data/data.json.xz
+
+offramp:
+  - id: blackhole
+    type: blackhole
+    codec: json
+    config:
+      warmup_secs: 10
+      stop_after_secs: 100
+      significant_figures: 2
+
+binding:
+  - id: bench
+    links:
+      "/onramp/blaster/{instance}/out": ["/pipeline/main/{instance}/in"]
+      "/pipeline/main/{instance}/out": ["/offramp/blackhole/{instance}/in"]

bench/patch_assign_target/main.trickle

@@ -0,0 +1,11 @@
+define script patch_assign_target
+script
+	let event = patch event of insert "foo" => "bar" end;
+	emit event;
+end;
+
+create script patch_assign_target;
+
+select event from in into patch_assign_target;
+select event from patch_assign_target into out;
+select event from patch_assign_target/err into err;