forked from D-Net/dnet-hadoop
added the normalization step to the doi from crossref
This commit is contained in:
parent
a5c1c0e90a
commit
3dd5701948
|
@ -1,6 +1,7 @@
|
|||
package eu.dnetlib.doiboost.crossref
|
||||
|
||||
import eu.dnetlib.dhp.application.ArgumentApplicationParser
|
||||
import eu.dnetlib.doiboost.DoiBoostMappingUtil
|
||||
import org.apache.commons.io.IOUtils
|
||||
import org.apache.hadoop.io.{IntWritable, Text}
|
||||
import org.apache.spark.SparkConf
|
||||
|
@ -22,7 +23,7 @@ object CrossrefDataset {
|
|||
lazy val json: json4s.JValue = parse(input)
|
||||
val ts:Long = (json \ "indexed" \ "timestamp").extract[Long]
|
||||
val doi:String = (json \ "DOI").extract[String]
|
||||
CrossrefDT(doi, input, ts)
|
||||
CrossrefDT(DoiBoostMappingUtil.normalizeDoi(doi), input, ts)
|
||||
|
||||
}
|
||||
|
||||
|
|
Loading…
Reference in New Issue