Revision 56507
Added by Miriam Baglioni over 3 years ago
| modules/dnet-mapreduce-jobs/trunk/src/main/java/eu/dnetlib/data/mapreduce/hbase/propagation/communitytoresult/CommunityToResultMapper.java | ||
|---|---|---|
| 92 | 92 |
// we fetch all the body updates |
| 93 | 93 |
for (final String o : stringMap.keySet()) {
|
| 94 | 94 |
if (o.startsWith("update_")) {
|
| 95 |
final OafProtos.Oaf update = OafProtos.Oaf.parseFrom(map.get(o));
|
|
| 95 |
final OafProtos.Oaf update = OafProtos.Oaf.parseFrom(stringMap.get(o));
|
|
| 96 | 96 |
contextIds.addAll(update.getEntity().getResult().getMetadata().getContextList() |
| 97 | 97 |
.stream() |
| 98 | 98 |
.map(ResultProtos.Result.Context::getId) |
Also available in: Unified diff
fixed type issue