added other counts
This commit is contained in:
parent
faa1c38b29
commit
f36f9c4fda
|
@ -49,9 +49,9 @@ class CheckRelation( args: Array[String], log: Logger) extends AbstractScalaAppl
|
||||||
val df = spark.read.text(path).as[String]
|
val df = spark.read.text(path).as[String]
|
||||||
|
|
||||||
val mapper = new ObjectMapper()
|
val mapper = new ObjectMapper()
|
||||||
// val total = df.count
|
val total = df.count
|
||||||
// val not_del_rel =df.map(s=> mapper.readValue(s, classOf[Relation])).as[Relation].filter(r => r.getDataInfo.getDeletedbyinference == false).count()
|
val not_del_rel =df.map(s=> mapper.readValue(s, classOf[Relation])).as[Relation].filter(r => r.getDataInfo.getDeletedbyinference == false).count()
|
||||||
// logger.warn(s"Total number of relations not deleted by Inference: $not_del_rel/$total")
|
logger.warn(s"Total number of relations not deleted by Inference: $not_del_rel/$total")
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
@ -61,7 +61,7 @@ class CheckRelation( args: Array[String], log: Logger) extends AbstractScalaAppl
|
||||||
.filter(r => filterRelations(r))
|
.filter(r => filterRelations(r))
|
||||||
.count()
|
.count()
|
||||||
|
|
||||||
logger.warn(s"Relation used by Scholexplorer $total_rels_from_scholexplorer")
|
logger.warn(s"Relation used by Scholexplorer $total_rels_from_scholexplorer/$not_del_rel")
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue