forked from D-Net/dnet-hadoop
Compare commits
2 Commits
beta
...
deduptesti
Author | SHA1 | Date |
---|---|---|
miconis | 3f2d3253e4 | |
miconis | 1699d41d39 |
|
@ -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(),
|
||||||
|
|
Loading…
Reference in New Issue