Non necessary javaRdd conversion? #163

a24b9f8268/dhp-workflows/dhp-dedup-openaire/src/main/java/eu/dnetlib/dhp/oa/dedup/SparkCopyRelationsNoOpenorgs.java (L63)

Why is it necessary to convert to a javaRdd? Wouldn't be more straightforward defined as

spark
	.read()
	.textFile(relationPath)
	.map(patchRelFn(), Encoders.bean(Relation.class))
	.filter((FilterFunction<Relation>) x -> !isOpenorgs(x))
	.write()
	.mode(SaveMode.Overwrite)
	.json(outputPath);

https://code-repo.d4science.org/D-Net/dnet-hadoop/src/commit/a24b9f8268a3e36a5032d40a103793677ab1dd8b/dhp-workflows/dhp-dedup-openaire/src/main/java/eu/dnetlib/dhp/oa/dedup/SparkCopyRelationsNoOpenorgs.java#L63 Why is it necessary to convert to a javaRdd? Wouldn't be more straightforward defined as ``` spark .read() .textFile(relationPath) .map(patchRelFn(), Encoders.bean(Relation.class)) .filter((FilterFunction<Relation>) x -> !isOpenorgs(x)) .write() .mode(SaveMode.Overwrite) .json(outputPath); ```

Labels Milestones

Non necessary javaRdd conversion? #163