Fixing map column merging for reverseResolve join.

aehrc · Dec 24, 2024 · e117280 · e117280
1 parent 77d2ef9
commit e117280
Showing 1 changed file with 3 additions and 4 deletions.
diff --git a/fhirpath/src/main/java/au/csiro/pathling/fhirpath/execution/MultiFhirPathEvaluator.java b/fhirpath/src/main/java/au/csiro/pathling/fhirpath/execution/MultiFhirPathEvaluator.java
@@ -408,10 +408,9 @@ private Dataset<Row> computeReverseJoin(@Nonnull final Dataset<Row> parentDatase
         );
 
     childResult.show();
-    final Dataset<Row> joinedDataset = parentDataset.join(childResult,
-            functions.col("key")
-                .equalTo(childResult.col(joinRoot.getChildKeyTag())),
-            "left_outer")
+    final Dataset<Row> joinedDataset = joinWithMapMerge(parentDataset, childResult,
+        functions.col("key")
+            .equalTo(childResult.col(joinRoot.getChildKeyTag())))
         .drop(joinRoot.getChildKeyTag());
     joinedDataset.show();
     return joinedDataset;