forked from D-Net/dnet-hadoop
added filter on null value after map function
This commit is contained in:
parent
846ba30873
commit
c58db1c8ea
|
@ -185,6 +185,7 @@ public class PublicationToOaf implements Serializable {
|
||||||
.map(t -> {
|
.map(t -> {
|
||||||
return mapStructuredProperty(t, q, null);
|
return mapStructuredProperty(t, q, null);
|
||||||
})
|
})
|
||||||
|
.filter(s -> s!=null)
|
||||||
.collect(Collectors.toList()));
|
.collect(Collectors.toList()));
|
||||||
// Adding identifier
|
// Adding identifier
|
||||||
final String id = getStringValue(rootElement, "id");
|
final String id = getStringValue(rootElement, "id");
|
||||||
|
@ -376,7 +377,7 @@ public class PublicationToOaf implements Serializable {
|
||||||
.map(r -> {
|
.map(r -> {
|
||||||
return mapStructuredProperty(r, q, null);
|
return mapStructuredProperty(r, q, null);
|
||||||
})
|
})
|
||||||
.collect(Collectors.toList()));
|
.filter(s -> s!=null).collect(Collectors.toList()));
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue