Revision 56886
Added by Miriam Baglioni over 4 years ago
| modules/dnet-mapreduce-jobs/trunk/src/main/java/eu/dnetlib/data/mapreduce/hbase/propagation/communitythroughorganization/OrganizationMap.java | ||
|---|---|---|
| 1 | 1 |
package eu.dnetlib.data.mapreduce.hbase.propagation.communitythroughorganization; |
| 2 | 2 |
|
| 3 |
import java.util.ArrayList; |
|
| 3 | 4 |
import java.util.HashMap; |
| 4 | 5 |
import java.util.List; |
| 5 | 6 |
|
| ... | ... | |
| 8 | 9 |
public OrganizationMap(){
|
| 9 | 10 |
super(); |
| 10 | 11 |
} |
| 12 |
|
|
| 13 |
public List<String> get(String key){
|
|
| 14 |
|
|
| 15 |
if (super.get(key) == null){
|
|
| 16 |
return new ArrayList<>(); |
|
| 17 |
} |
|
| 18 |
return super.get(key); |
|
| 19 |
} |
|
| 11 | 20 |
} |
| modules/dnet-mapreduce-jobs/trunk/src/main/java/eu/dnetlib/data/mapreduce/hbase/propagation/communitythroughorganization/PropagationCommunityThroughOrganizationMapper.java | ||
|---|---|---|
| 74 | 74 |
|
| 75 | 75 |
private DedupedList getCommunityList(String organizationId, Set<String> relationTarget) {
|
| 76 | 76 |
DedupedList communityList = new DedupedList(); |
| 77 |
relationTarget.add(organizationId); |
|
| 78 | 77 |
relationTarget.stream().forEach(org -> communityList.addAll(organizationMap.get(org))); |
| 79 |
// communityList.addAll(organizationMap.get(organizationId));
|
|
| 78 |
communityList.addAll(organizationMap.get(organizationId)); |
|
| 80 | 79 |
return communityList; |
| 81 | 80 |
} |
| 82 | 81 |
|
Also available in: Unified diff
fix