[FLINK-1900] Fix Scala Table API Example in doc

scsha · Apr 17, 2015 · 8c5cd97 · 8c5cd97
1 parent 354922b
commit 8c5cd97
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/docs/table.md b/docs/table.md
@@ -55,7 +55,7 @@ import org.apache.flink.api.scala.table._
 case class WC(word: String, count: Int)
 val input = env.fromElements(WC("hello", 1), WC("hello", 1), WC("ciao", 1))
 val expr = input.toTable
-val result = expr.groupBy('word).select('word, 'count.sum).toSet[WC]
+val result = expr.groupBy('word).select('word, 'count.sum as count).toSet[WC]
 {% endhighlight %}
 
 The expression DSL uses Scala symbols to refer to field names and we use code generation to

diff --git a/...ging/flink-table/src/main/scala/org/apache/flink/api/java/table/JavaBatchTranslator.scala b/...ging/flink-table/src/main/scala/org/apache/flink/api/java/table/JavaBatchTranslator.scala
@@ -85,7 +85,7 @@ class JavaBatchTranslator extends PlanTranslator {
     val outputNames = outputType.getFieldNames.toSeq
 
     if (resultNames.toSet != outputNames.toSet) {
-      throw new ExpressionException(s"Expression result type $resultType does not have the same" +
+      throw new ExpressionException(s"Expression result type $resultType does not have the same " +
         s"fields as output type $outputType")
     }