From feddc1887b37d9f1f1b097de3bb878b4aac5624b Mon Sep 17 00:00:00 2001 From: StephanEwen Date: Tue, 12 Nov 2013 12:07:33 +0100 Subject: [PATCH] Adjusted test to new output format names. --- .../scala/examples/wordcount/WordCountWithCount.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pact-scala/pact-scala-examples/src/main/scala/eu/stratosphere/scala/examples/wordcount/WordCountWithCount.scala b/pact-scala/pact-scala-examples/src/main/scala/eu/stratosphere/scala/examples/wordcount/WordCountWithCount.scala index d114c93d063..9f6866163fc 100644 --- a/pact-scala/pact-scala-examples/src/main/scala/eu/stratosphere/scala/examples/wordcount/WordCountWithCount.scala +++ b/pact-scala/pact-scala-examples/src/main/scala/eu/stratosphere/scala/examples/wordcount/WordCountWithCount.scala @@ -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) -- GitLab