diff options
author | bnewbold <bnewbold@archive.org> | 2018-07-23 21:37:25 +0000 |
---|---|---|
committer | bnewbold <bnewbold@archive.org> | 2018-07-23 21:37:25 +0000 |
commit | c4db53036eac90841eb4f970b77db8c1677ef75b (patch) | |
tree | 04bb6c63aaccef2da813b19a0ee3c56f3c338a57 /scalding/src/test | |
parent | e2d5b35a8cb5eefafc12abe0394ec5f60ab87d79 (diff) | |
parent | 687693e96f5a55aa6d38450da0d10e95df2d9422 (diff) | |
download | sandcrawler-c4db53036eac90841eb4f970b77db8c1677ef75b.tar.gz sandcrawler-c4db53036eac90841eb4f970b77db8c1677ef75b.zip |
Merge branch 'scalastyle' into 'master'
Scalastyle
See merge request webgroup/sandcrawler!11
Diffstat (limited to 'scalding/src/test')
-rw-r--r-- | scalding/src/test/scala/sandcrawler/HBaseStatusCountTest.scala | 22 |
1 files changed, 11 insertions, 11 deletions
diff --git a/scalding/src/test/scala/sandcrawler/HBaseStatusCountTest.scala b/scalding/src/test/scala/sandcrawler/HBaseStatusCountTest.scala index 11ab1d0..d7689cd 100644 --- a/scalding/src/test/scala/sandcrawler/HBaseStatusCountTest.scala +++ b/scalding/src/test/scala/sandcrawler/HBaseStatusCountTest.scala @@ -48,18 +48,18 @@ class HBaseStatusCountTest extends FunSpec with TupleConversions { .arg("debug", "true") .source[Tuple](HBaseCountJob.getHBaseSource(testTable, testHost, "grobid0:status_code"), sampleData.map(l => new Tuple(l.map(s => {new ImmutableBytesWritable(s)}):_*))) - .sink[Tuple](TypedTsv[(Long, Long)](output)) { - outputBuffer => - it("should return a 2-element list.") { - assert(outputBuffer.size === 2) - } + .sink[Tuple](TypedTsv[(Long, Long)](output)) { + outputBuffer => + it("should return a 2-element list.") { + assert(outputBuffer.size === 2) + } - // Convert List[Tuple] to Map[Long, Long]. - val counts = outputBuffer.map(t => (t.getLong(0), t.getLong(1))).toMap - it("should have the appropriate number of each status type") { - assert(counts(statusType1) == statusType1Count) - assert(counts(statusType2) == statusType2Count) - } + // Convert List[Tuple] to Map[Long, Long]. + val counts = outputBuffer.map(t => (t.getLong(0), t.getLong(1))).toMap + it("should have the appropriate number of each status type") { + assert(counts(statusType1) == statusType1Count) + assert(counts(statusType2) == statusType2Count) + } } .run .finish |