diff --git a/examples/kubernetes/otel-collector-config.yml b/examples/kubernetes/otel-collector-config.yml
index 684ce7aecba6..7d2665a86567 100644
--- a/examples/kubernetes/otel-collector-config.yml
+++ b/examples/kubernetes/otel-collector-config.yml
@@ -14,18 +14,18 @@ receivers:
         id: get-format
         routes:
           - output: parser-docker
-            expr: '$$body matches "^\\{"'
+            expr: 'body matches "^\\{"'
           - output: parser-crio
-            expr: '$$body matches "^[^ Z]+ "'
+            expr: 'body matches "^[^ Z]+ "'
           - output: parser-containerd
-            expr: '$$body matches "^[^ Z]+Z"'
+            expr: 'body matches "^[^ Z]+Z"'
       # Parse CRI-O format
       - type: regex_parser
         id: parser-crio
         regex: '^(?P<time>[^ Z]+) (?P<stream>stdout|stderr) (?P<logtag>[^ ]*) (?P<log>.*)$'
         output: extract_metadata_from_filepath
         timestamp:
-          parse_from: time
+          parse_from: body.time
           layout_type: gotime
           layout: '2006-01-02T15:04:05.000000000-07:00'
       # Parse CRI-Containerd format
@@ -34,36 +34,42 @@ receivers:
         regex: '^(?P<time>[^ ^Z]+Z) (?P<stream>stdout|stderr) (?P<logtag>[^ ]*) (?P<log>.*)$'
         output: extract_metadata_from_filepath
         timestamp:
-          parse_from: time
+          parse_from: body.time
           layout: '%Y-%m-%dT%H:%M:%S.%LZ'
       # Parse Docker format
       - type: json_parser
         id: parser-docker
         output: extract_metadata_from_filepath
         timestamp:
-          parse_from: time
+          parse_from: body.time
           layout: '%Y-%m-%dT%H:%M:%S.%LZ'
       # Extract metadata from file path
       - type: regex_parser
         id: extract_metadata_from_filepath
         regex: '^.*\/(?P<namespace>[^_]+)_(?P<pod_name>[^_]+)_(?P<uid>[a-f0-9\-]{36})\/(?P<container_name>[^\._]+)\/(?P<restart_count>\d+)\.log$'
-        parse_from: $$attributes["file.path"]
+        parse_from: attributes["file.path"]
       # Move out attributes to Attributes
-      - type: metadata
-        attributes:
-          stream: 'EXPR($.stream)'
-          k8s.container.name: 'EXPR($.container_name)'
-          k8s.namespace.name: 'EXPR($.namespace)'
-          k8s.pod.name: 'EXPR($.pod_name)'
-          k8s.container.restart_count: 'EXPR($.restart_count)'
-          k8s.pod.uid: 'EXPR($.uid)'
-      # Clean up log body
-      - type: restructure
-        id: clean-up-log-body
-        ops:
-          - move:
-              from: log
-              to: $
+      - type: move
+        from: body.stream
+        to: attributes["log.iostream"]
+      - type: move
+        from: body.container_name
+        to: attributes["k8s.container.name"]
+      - type: move
+        from: body.namespace
+        to: attributes["k8s.namespace.name"]
+      - type: move
+        from: body.pod_name
+        to: attributes["k8s.pod.name"]
+      - type: move
+        from: body.restart_count
+        to: attributes["k8s.container.restart_count"]
+      - type: move
+        from: body.uid
+        to: attributes["k8s.pod.uid"]
+      - type: move
+        from: body.log
+        to: body
 exporters:
   logging:
     loglevel: debug
diff --git a/examples/kubernetes/otel-collector.yaml b/examples/kubernetes/otel-collector.yaml
index a61a91976831..2ba90582165a 100644
--- a/examples/kubernetes/otel-collector.yaml
+++ b/examples/kubernetes/otel-collector.yaml
@@ -21,18 +21,18 @@ data:
             id: get-format
             routes:
               - output: parser-docker
-                expr: '$$body matches "^\\{"'
+                expr: 'body matches "^\\{"'
               - output: parser-crio
-                expr: '$$body matches "^[^ Z]+ "'
+                expr: 'body matches "^[^ Z]+ "'
               - output: parser-containerd
-                expr: '$$body matches "^[^ Z]+Z"'
+                expr: 'body matches "^[^ Z]+Z"'
           # Parse CRI-O format
           - type: regex_parser
             id: parser-crio
             regex: '^(?P<time>[^ Z]+) (?P<stream>stdout|stderr) (?P<logtag>[^ ]*) (?P<log>.*)$'
             output: extract_metadata_from_filepath
             timestamp:
-              parse_from: time
+              parse_from: body.time
               layout_type: gotime
               layout: '2006-01-02T15:04:05.000000000-07:00'
           # Parse CRI-Containerd format
@@ -41,39 +41,42 @@ data:
             regex: '^(?P<time>[^ ^Z]+Z) (?P<stream>stdout|stderr) (?P<logtag>[^ ]*) (?P<log>.*)$'
             output: extract_metadata_from_filepath
             timestamp:
-              parse_from: time
+              parse_from: body.time
               layout: '%Y-%m-%dT%H:%M:%S.%LZ'
           # Parse Docker format
           - type: json_parser
             id: parser-docker
             output: extract_metadata_from_filepath
             timestamp:
-              parse_from: time
+              parse_from:  body.time
               layout: '%Y-%m-%dT%H:%M:%S.%LZ'
           # Extract metadata from file path
           - type: regex_parser
             id: extract_metadata_from_filepath
             regex: '^.*\/(?P<namespace>[^_]+)_(?P<pod_name>[^_]+)_(?P<uid>[a-f0-9\-]{36})\/(?P<container_name>[^\._]+)\/(?P<restart_count>\d+)\.log$'
-            parse_from: $$attributes["file.path"]
+            parse_from: attributes["log.file.path"]
           # Move out attributes to Attributes
-          - type: metadata
-            attributes:
-              stream: 'EXPR($.stream)'
-              k8s.container.name: 'EXPR($.container_name)'
-              k8s.namespace.name: 'EXPR($.namespace)'
-              k8s.pod.name: 'EXPR($.pod_name)'
-              k8s.container.restart_count: 'EXPR($.restart_count)'
-              k8s.pod.uid: 'EXPR($.uid)'
-          # tag the resource level attribute in metadata
-            resource:
-              k8s.pod.uid: 'EXPR($.uid)'
-          # Clean up log body
-          - type: restructure
-            id: clean-up-log-body
-            ops:
-              - move:
-                  from: log
-                  to: $
+          - type: move
+            from: body.stream
+            to: attributes["log.iostream"]
+          - type: move
+            from: body.container_name
+            to: attributes["k8s.container.name"]
+          - type: move
+            from: body.namespace
+            to: attributes["k8s.namespace.name"]
+          - type: move
+            from: body.pod_name
+            to: attributes["k8s.pod.name"]
+          - type: move
+            from: body.restart_count
+            to: attributes["k8s.container.restart_count"]
+          - type: move
+            from: body.uid
+            to: attributes["k8s.pod.uid"]
+          - type: move
+            from: body.log
+            to: body
 
     processors:
       # k8sattributes processor to get the metadata from K8s