diff options
| author | Bryan Newbold <bnewbold@archive.org> | 2019-08-10 19:50:18 -0700 |
|---|---|---|
| committer | Bryan Newbold <bnewbold@archive.org> | 2019-08-10 20:20:34 -0700 |
| commit | 952457f9fae1cc25cdeeefc00e19ae20cf86c659 (patch) | |
| tree | 8ab838ef7aa211cbbeb6dab4ee941d52e97da484 /scalding | |
| parent | ea9e8990139973d6f5fdf52a470bf6516c7d8c2f (diff) | |
| download | sandcrawler-952457f9fae1cc25cdeeefc00e19ae20cf86c659.tar.gz sandcrawler-952457f9fae1cc25cdeeefc00e19ae20cf86c659.zip | |
please command for groupworksfatcat
Diffstat (limited to 'scalding')
| -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") |