From 8d372f1be74effa827b2b3d2d444babe4dce036c Mon Sep 17 00:00:00 2001 From: "miriam.baglioni" Date: Tue, 21 Jun 2022 14:23:40 +0200 Subject: [PATCH] refactoring --- .../src/main/java/eu/dnetlib/dhp/bulktag/SparkBulkTagJob.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/dhp-workflows/dhp-enrichment/src/main/java/eu/dnetlib/dhp/bulktag/SparkBulkTagJob.java b/dhp-workflows/dhp-enrichment/src/main/java/eu/dnetlib/dhp/bulktag/SparkBulkTagJob.java index ad1e8721a..982e8ea75 100644 --- a/dhp-workflows/dhp-enrichment/src/main/java/eu/dnetlib/dhp/bulktag/SparkBulkTagJob.java +++ b/dhp-workflows/dhp-enrichment/src/main/java/eu/dnetlib/dhp/bulktag/SparkBulkTagJob.java @@ -103,7 +103,7 @@ public class SparkBulkTagJob { ResultTagger resultTagger = new ResultTagger(); readPath(spark, inputPath, resultClazz) .map(patchResult(), Encoders.bean(resultClazz)) - .filter(Objects::nonNull) + .filter(Objects::nonNull) .map( (MapFunction) value -> resultTagger .enrichContextCriteria(