forked from D-Net/dnet-hadoop
[Cleaning] drop alternate identifiers with empty values
This commit is contained in:
parent
a0837ac357
commit
3becaa5539
|
@ -155,12 +155,14 @@ public class CleaningFunctions {
|
||||||
final Set<StructuredProperty> pids =
|
final Set<StructuredProperty> pids =
|
||||||
pid
|
pid
|
||||||
.stream()
|
.stream()
|
||||||
|
.filter(Objects::nonNull)
|
||||||
.filter(p -> StringUtils.isNotBlank(p.getValue()))
|
.filter(p -> StringUtils.isNotBlank(p.getValue()))
|
||||||
.collect(Collectors.toCollection(HashSet::new));
|
.collect(Collectors.toCollection(HashSet::new));
|
||||||
|
|
||||||
Optional.ofNullable(i.getAlternateIdentifier())
|
Optional.ofNullable(i.getAlternateIdentifier())
|
||||||
.ifPresent(altId -> {
|
.ifPresent(altId -> {
|
||||||
final Set<StructuredProperty> altIds = altId.stream()
|
final Set<StructuredProperty> altIds = altId.stream()
|
||||||
|
.filter(Objects::nonNull)
|
||||||
.filter(p -> StringUtils.isNotBlank(p.getValue()))
|
.filter(p -> StringUtils.isNotBlank(p.getValue()))
|
||||||
.collect(Collectors.toCollection(HashSet::new));
|
.collect(Collectors.toCollection(HashSet::new));
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue