Revision 56875
Added by Miriam Baglioni about 5 years ago
modules/dnet-mapreduce-jobs/trunk/src/main/java/eu/dnetlib/data/mapreduce/hbase/propagation/communitythroughorganization/PropagationCommunityThroughOrganizationFileReducer.java | ||
---|---|---|
74 | 74 |
resultIds.stream().forEach(result -> { |
75 | 75 |
try { |
76 | 76 |
final ResultProtos.Result.Metadata.Builder metadata = ResultProtos.Result.Metadata.newBuilder(); |
77 |
communities.stream().forEach(community->metadata.addContext(Utils.getContext(community, ORGANIZATION_COMMUNITY_TRUST, CLASS_ORGANIZATION_ID, DATA_INFO_TYPE))); |
|
77 |
communities.stream().forEach(community->metadata.addContext(Utils.getContext(community, ORGANIZATION_COMMUNITY_TRUST, CLASS_ORGANIZATION_ID, DATA_INFO_TYPE,CLASS_ORGANIZATION_NAME)));
|
|
78 | 78 |
|
79 | 79 |
String keyString = Bytes.toString(key.get()); |
80 | 80 |
keyOut.set(keyString); |
Also available in: Unified diff
fixed error