adapt transform processor

Signed-off-by: odubajDT <[email protected]>

Author: odubajDT

processor/transformprocessor/internal/logs/processor_test.go

@@ -408,7 +408,7 @@ func Test_ProcessLogs_LogContext(t *testing.T) {
 			},
 		},
 		{
-			statement: `merge_maps(attributes, ParseJSON("{\"json_test\":\"pass\"}"), "insert") where body == "operationA"`,
+			statement: `merge_maps(attributes, "insert", ParseJSON("{\"json_test\":\"pass\"}")) where body == "operationA"`,
 			want: func(td plog.Logs) {
 				td.ResourceLogs().At(0).ScopeLogs().At(0).LogRecords().At(0).Attributes().PutStr("json_test", "pass")
 			},
@@ -662,7 +662,7 @@ func Test_ProcessLogs_InferredLogContext(t *testing.T) {
 			},
 		},
 		{
-			statement: `merge_maps(log.attributes, ParseJSON("{\"json_test\":\"pass\"}"), "insert") where log.body == "operationA"`,
+			statement: `merge_maps(log.attributes, "insert", ParseJSON("{\"json_test\":\"pass\"}")) where log.body == "operationA"`,
 			want: func(td plog.Logs) {
 				td.ResourceLogs().At(0).ScopeLogs().At(0).LogRecords().At(0).Attributes().PutStr("json_test", "pass")
 			},

processor/transformprocessor/internal/metrics/processor_test.go

@@ -949,7 +949,7 @@ func Test_ProcessMetrics_DataPointContext(t *testing.T) {
 			},
 		},
 		{
-			statements: []string{`merge_maps(attributes, ParseJSON("{\"json_test\":\"pass\"}"), "insert") where metric.name == "operationA"`},
+			statements: []string{`merge_maps(attributes, "insert", ParseJSON("{\"json_test\":\"pass\"}")) where metric.name == "operationA"`},
 			want: func(td pmetric.Metrics) {
 				td.ResourceMetrics().At(0).ScopeMetrics().At(0).Metrics().At(0).Sum().DataPoints().At(0).Attributes().PutStr("json_test", "pass")
 				td.ResourceMetrics().At(0).ScopeMetrics().At(0).Metrics().At(0).Sum().DataPoints().At(1).Attributes().PutStr("json_test", "pass")
@@ -1392,7 +1392,7 @@ func Test_ProcessMetrics_InferredDataPointContext(t *testing.T) {
 			},
 		},
 		{
-			statements: []string{`merge_maps(datapoint.attributes, ParseJSON("{\"json_test\":\"pass\"}"), "insert") where metric.name == "operationA"`},
+			statements: []string{`merge_maps(datapoint.attributes, "insert", ParseJSON("{\"json_test\":\"pass\"}")) where metric.name == "operationA"`},
 			want: func(td pmetric.Metrics) {
 				td.ResourceMetrics().At(0).ScopeMetrics().At(0).Metrics().At(0).Sum().DataPoints().At(0).Attributes().PutStr("json_test", "pass")
 				td.ResourceMetrics().At(0).ScopeMetrics().At(0).Metrics().At(0).Sum().DataPoints().At(1).Attributes().PutStr("json_test", "pass")

processor/transformprocessor/internal/traces/processor_test.go

@@ -459,7 +459,7 @@ func Test_ProcessTraces_TraceContext(t *testing.T) {
 			},
 		},
 		{
-			statement: `merge_maps(attributes, ParseJSON("{\"json_test\":\"pass\"}"), "insert") where name == "operationA"`,
+			statement: `merge_maps(attributes, "insert", ParseJSON("{\"json_test\":\"pass\"}")) where name == "operationA"`,
 			want: func(td ptrace.Traces) {
 				td.ResourceSpans().At(0).ScopeSpans().At(0).Spans().At(0).Attributes().PutStr("json_test", "pass")
 			},
@@ -759,7 +759,7 @@ func Test_ProcessTraces_InferredTraceContext(t *testing.T) {
 			},
 		},
 		{
-			statement: `merge_maps(span.attributes, ParseJSON("{\"json_test\":\"pass\"}"), "insert") where span.name == "operationA"`,
+			statement: `merge_maps(span.attributes, "insert", ParseJSON("{\"json_test\":\"pass\"}")) where span.name == "operationA"`,
 			want: func(td ptrace.Traces) {
 				td.ResourceSpans().At(0).ScopeSpans().At(0).Spans().At(0).Attributes().PutStr("json_test", "pass")
 			},