Compare commits

...

2 Commits

Author SHA1 Message Date
miconis 3f2d3253e4 Merge branch 'stable_ids' into deduptesting 2020-11-05 15:52:57 +01:00
miconis 1699d41d39 relations for openorgs: not it choose only one master 2020-11-05 15:48:42 +01:00
1 changed files with 4 additions and 5 deletions

View File

@ -128,12 +128,11 @@ public class SparkPrepareOrgRels extends AbstractSparkAction {
List<String> ids = sortIds(l); List<String> ids = sortIds(l);
List<Tuple3<String, String, String>> rels = new ArrayList<>(); List<Tuple3<String, String, String>> rels = new ArrayList<>();
for (String source : ids) { String source = ids.get(0);
if (source.contains("openorgs____") || ids.indexOf(source) == 0) for (String target : ids) {
for (String target : ids) { rels.add(new Tuple3<>(source, target, groupId));
rels.add(new Tuple3<>(source, target, groupId));
}
} }
return rels.iterator(); return rels.iterator();
}) })
.rdd(), .rdd(),