spyros
/
dnet-hadoop
forked from D-Net/dnet-hadoop
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

use mergeFrom method to add the new community contexts

This commit is contained in:
Miriam Baglioni 2020-04-17 17:13:18 +02:00
parent 264c82f21e
commit 5cd092114f
1 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
dhp-workflows/dhp-propagation/src/main/java/eu/dnetlib/dhp/resulttocommunityfromorganization/SparkResultToCommunityFromOrganizationJob2.java
View File

@ -98,15 +98,20 @@ public class SparkResultToCommunityFromOrganizationJob2 {
if(rcl.isPresent()){ if(rcl.isPresent()){
ArrayList<String> communitySet = rcl.get().getCommunityList(); ArrayList<String> communitySet = rcl.get().getCommunityList();
List<String> contextList = ret.getContext().stream().map(con -> con.getId()).collect(Collectors.toList()); List<String> contextList = ret.getContext().stream().map(con -> con.getId()).collect(Collectors.toList());
Result res = new Result();
res.setId(ret.getId());
List<Context> propagatedContexts = new ArrayList<>();
for(String cId:communitySet){ for(String cId:communitySet){
if(!contextList.contains(cId)){ if(!contextList.contains(cId)){
Context newContext = new Context(); Context newContext = new Context();
newContext.setId(cId); newContext.setId(cId);
newContext.setDataInfo(Arrays.asList(getDataInfo(PROPAGATION_DATA_INFO_TYPE, newContext.setDataInfo(Arrays.asList(getDataInfo(PROPAGATION_DATA_INFO_TYPE,
PROPAGATION_RESULT_COMMUNITY_ORGANIZATION_CLASS_ID, PROPAGATION_RESULT_COMMUNITY_ORGANIZATION_CLASS_NAME))); PROPAGATION_RESULT_COMMUNITY_ORGANIZATION_CLASS_ID, PROPAGATION_RESULT_COMMUNITY_ORGANIZATION_CLASS_NAME)));
ret.getContext().add(newContext); propagatedContexts.add(newContext);
} }
} }
res.setContext(propagatedContexts);
ret.mergeFrom(res);
} }
return ret; return ret;
}, Encoders.bean(resultClazz)) }, Encoders.bean(resultClazz))