aboutsummaryrefslogtreecommitdiffstats
path: root/scalding
diff options
context:
space:
mode:
authorBryan Newbold <bnewbold@archive.org>2018-08-23 17:27:16 -0700
committerBryan Newbold <bnewbold@archive.org>2018-08-23 17:27:16 -0700
commit2ab704a09db06ab776bd4cf59974e5f65f5e7c38 (patch)
tree7dca7cdb002a62262fcc4e00b42411718a53d5bd /scalding
parent0fd0d3970f2c5c7bbdede25ac7d42decfda6609f (diff)
downloadsandcrawler-2ab704a09db06ab776bd4cf59974e5f65f5e7c38.tar.gz
sandcrawler-2ab704a09db06ab776bd4cf59974e5f65f5e7c38.zip
clean up indendation in ScoreJob.scala
Diffstat (limited to 'scalding')
-rw-r--r--scalding/src/main/scala/sandcrawler/ScoreJob.scala10
1 files changed, 5 insertions, 5 deletions
diff --git a/scalding/src/main/scala/sandcrawler/ScoreJob.scala b/scalding/src/main/scala/sandcrawler/ScoreJob.scala
index 6d9cecd..02714ab 100644
--- a/scalding/src/main/scala/sandcrawler/ScoreJob.scala
+++ b/scalding/src/main/scala/sandcrawler/ScoreJob.scala
@@ -19,12 +19,12 @@ class ScoreJob(args: Args) extends JobBase(args) {
.map { entry =>
val (slug : String, (features1 : ReduceFeatures, features2 : ReduceFeatures)) = entry
new ReduceOutput(
- slug,
- Scorable.computeSimilarity(features1, features2),
- features1.json,
- features2.json)
+ slug,
+ Scorable.computeSimilarity(features1, features2),
+ features1.json,
+ features2.json)
}
- //TypedTsv doesn't work over case classes.
+ // TypedTsv doesn't work over case classes.
.map { entry => (entry.slug, entry.score, entry.json1, entry.json2) }
.write(TypedTsv[(String, Int, String, String)](args("output")))
}