added workaround to include B2FIND

This commit is contained in:
Miriam Baglioni 2023-06-05 08:14:22 +02:00
parent ff61dca84a
commit d9993ee5a2
1 changed files with 4 additions and 1 deletions

View File

@ -77,7 +77,10 @@ public class SelectEoscResultsJobStep1 implements Serializable {
.readPath(spark, inputPath, inputClazz)
.filter(
(FilterFunction<R>) r -> !r.getDataInfo().getDeletedbyinference() && !r.getDataInfo().getInvisible()
&& r.getContext().stream().anyMatch(c -> c.getId().equals("eosc")))
&& (r.getContext().stream().anyMatch(c -> c.getId().equals("eosc")) || r
.getCollectedfrom()
.stream()
.anyMatch(cf -> cf.getValue().equalsIgnoreCase("B2FIND"))))
.map(
(MapFunction<R, Result>) r -> (Result) ResultMapper