diff --git a/dhp-workflows/dhp-graph-provision/src/main/java/eu/dnetlib/dhp/graph/GraphJoiner.java b/dhp-workflows/dhp-graph-provision/src/main/java/eu/dnetlib/dhp/graph/GraphJoiner.java index 246613ce4..29492cb90 100644 --- a/dhp-workflows/dhp-graph-provision/src/main/java/eu/dnetlib/dhp/graph/GraphJoiner.java +++ b/dhp-workflows/dhp-graph-provision/src/main/java/eu/dnetlib/dhp/graph/GraphJoiner.java @@ -46,7 +46,7 @@ import static eu.dnetlib.dhp.graph.utils.GraphMappingUtils.asRelatedEntity; * 3) we only need a subset of fields from the related entities, so we introduce a distinction between E_source = S * and E_target = T. Objects in T are heavily pruned by all the unnecessary information * - * 4) perform the join as (((T join R) union S) groupby S.id) yield S -> [ ] + * 4) perform the join as (((T.id join R.target) union S) groupby S.id) yield S -> [ ] */ public class GraphJoiner implements Serializable {