removed the hack to insert B2FIND results in the dump
This commit is contained in:
parent
e9766bd25b
commit
000c88dd79
|
@ -77,11 +77,7 @@ public class SelectEoscResultsJobStep1 implements Serializable {
|
||||||
.readPath(spark, inputPath, inputClazz)
|
.readPath(spark, inputPath, inputClazz)
|
||||||
.filter(
|
.filter(
|
||||||
(FilterFunction<R>) r -> !r.getDataInfo().getDeletedbyinference() && !r.getDataInfo().getInvisible()
|
(FilterFunction<R>) r -> !r.getDataInfo().getDeletedbyinference() && !r.getDataInfo().getInvisible()
|
||||||
&& (r.getContext().stream().anyMatch(c -> c.getId().equals("eosc")) || r
|
&& r.getContext().stream().anyMatch(c -> c.getId().equals("eosc")))
|
||||||
.getCollectedfrom()
|
|
||||||
.stream()
|
|
||||||
.anyMatch(cf -> cf.getValue().equalsIgnoreCase("B2FIND"))))
|
|
||||||
|
|
||||||
.map(
|
.map(
|
||||||
(MapFunction<R, Result>) r -> (Result) ResultMapper
|
(MapFunction<R, Result>) r -> (Result) ResultMapper
|
||||||
.map(r, communityMap),
|
.map(r, communityMap),
|
||||||
|
|
Loading…
Reference in New Issue