From 2c9172a3797dd218b5648c5390bf2dfb39d8e3a3 Mon Sep 17 00:00:00 2001 From: Ellen Spertus Date: Tue, 28 Aug 2018 08:45:04 -0700 Subject: restored code I inadvertantly removed when merging --- scalding/src/main/scala/sandcrawler/GrobidScorableDumpJob.scala | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/scalding/src/main/scala/sandcrawler/GrobidScorableDumpJob.scala b/scalding/src/main/scala/sandcrawler/GrobidScorableDumpJob.scala index d40410b..3146a6c 100644 --- a/scalding/src/main/scala/sandcrawler/GrobidScorableDumpJob.scala +++ b/scalding/src/main/scala/sandcrawler/GrobidScorableDumpJob.scala @@ -41,7 +41,10 @@ class GrobidScorableDumpJob(args: Args) extends JobBase(args) { GrobidScorable.jsonToMapFeatures(entry._1, entry._2) } .filterNot { entry => entry.isEmpty } - .map { entry => entry.get } + .map { entry => { + validGrobidRows.inc + entry.get + }} .groupBy { case MapFeatures(slug, json) => slug } .map { tuple => val (slug : String, features : MapFeatures) = tuple -- cgit v1.2.3