aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
-rw-r--r--scalding/src/main/scala/sandcrawler/CrossrefScorable.scala3
1 files changed, 0 insertions, 3 deletions
diff --git a/scalding/src/main/scala/sandcrawler/CrossrefScorable.scala b/scalding/src/main/scala/sandcrawler/CrossrefScorable.scala
index a603e2d..0849aff 100644
--- a/scalding/src/main/scala/sandcrawler/CrossrefScorable.scala
+++ b/scalding/src/main/scala/sandcrawler/CrossrefScorable.scala
@@ -11,8 +11,6 @@ import parallelai.spyglass.hbase.HBaseSource
class CrossrefScorable extends Scorable {
def getFeaturesPipe(args : Args)(implicit flowDef : FlowDef, mode : Mode) = {
-// val crossrefSource = TextLine(args("crossref-input"))
-// val crossrefPipe : TypedPipe[MapFeatures] = crossrefSource
TextLine(args("crossref-input"))
.read
.toTypedPipe[String](new Fields("line"))
@@ -22,6 +20,5 @@ class CrossrefScorable extends Scorable {
case None => new MapFeatures(Scorable.NoSlug, json)
}
}
-// crossrefPipe
}
}