aboutsummaryrefslogtreecommitdiffstats
path: root/scalding/src/main/scala
diff options
context:
space:
mode:
authorBryan Newbold <bnewbold@archive.org>2019-08-10 19:50:18 -0700
committerBryan Newbold <bnewbold@archive.org>2019-08-10 20:20:34 -0700
commit952457f9fae1cc25cdeeefc00e19ae20cf86c659 (patch)
tree8ab838ef7aa211cbbeb6dab4ee941d52e97da484 /scalding/src/main/scala
parentea9e8990139973d6f5fdf52a470bf6516c7d8c2f (diff)
downloadsandcrawler-952457f9fae1cc25cdeeefc00e19ae20cf86c659.tar.gz
sandcrawler-952457f9fae1cc25cdeeefc00e19ae20cf86c659.zip
please command for groupworksfatcat
Diffstat (limited to 'scalding/src/main/scala')
-rw-r--r--scalding/src/main/scala/sandcrawler/GroupFatcatWorksJob.scala (renamed from scalding/src/main/scala/sandcrawler/ScoreSelfFatcat.scala)2
1 files changed, 1 insertions, 1 deletions
diff --git a/scalding/src/main/scala/sandcrawler/ScoreSelfFatcat.scala b/scalding/src/main/scala/sandcrawler/GroupFatcatWorksJob.scala
index d1a94fe..46d2038 100644
--- a/scalding/src/main/scala/sandcrawler/ScoreSelfFatcat.scala
+++ b/scalding/src/main/scala/sandcrawler/GroupFatcatWorksJob.scala
@@ -7,7 +7,7 @@ import com.twitter.scalding.TypedPipe
import com.twitter.scalding.TypedTsv
import parallelai.spyglass.base.JobBase
-class ScoreSelfFatcatJob(args: Args) extends JobBase(args) {
+class GroupFatcatWorksJob(args: Args) extends JobBase(args) {
val fatcatRowCount = Stat("fatcat-rows-filtered", "sandcrawler")
val joinedRowCount = Stat("joined-rows", "sandcrawler")