提交 feddc188 编写于 作者: S StephanEwen

Adjusted test to new output format names.

上级 6cdc38b5
......@@ -41,7 +41,7 @@ class WordCountWithCount extends WordCount {
val words = input flatMap { _.toLowerCase().split("""\W+""") filter { _ != "" } }
val counts = words groupBy { x => x } count()
val output = counts.write(wordsOutput, DelimitedOutputFormat(formatOutput.tupled))
val output = counts.write(wordsOutput, CsvOutputFormat[(String, Int)]("\n", " "))
val plan = new ScalaPlan(Seq(output), "Word Count")
plan.setDefaultParallelism(numSubTasks)
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册