You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by al...@apache.org on 2015/04/08 17:21:28 UTC
flink git commit: [hotfix] Fix scaladoc in Table.scala Examples
Repository: flink
Updated Branches:
refs/heads/master 365cd4005 -> e48e76f46
[hotfix] Fix scaladoc in Table.scala Examples
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e48e76f4
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/e48e76f4
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/e48e76f4
Branch: refs/heads/master
Commit: e48e76f4660e7728ae0252736398c27e72841238
Parents: 365cd40
Author: Aljoscha Krettek <al...@gmail.com>
Authored: Wed Apr 8 17:20:29 2015 +0200
Committer: Aljoscha Krettek <al...@gmail.com>
Committed: Wed Apr 8 17:21:15 2015 +0200
----------------------------------------------------------------------
.../src/main/scala/org/apache/flink/api/table/Table.scala | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/e48e76f4/flink-staging/flink-table/src/main/scala/org/apache/flink/api/table/Table.scala
----------------------------------------------------------------------
diff --git a/flink-staging/flink-table/src/main/scala/org/apache/flink/api/table/Table.scala b/flink-staging/flink-table/src/main/scala/org/apache/flink/api/table/Table.scala
index 4e2e53e..b7a24aa 100644
--- a/flink-staging/flink-table/src/main/scala/org/apache/flink/api/table/Table.scala
+++ b/flink-staging/flink-table/src/main/scala/org/apache/flink/api/table/Table.scala
@@ -138,7 +138,7 @@ case class Table(private[flink] val operation: PlanNode) {
* Example:
*
* {{{
- * in.filter("name === 'Fred'")
+ * in.filter("name = 'Fred'")
* }}}
*/
def filter(predicate: String): Table = {
@@ -153,7 +153,7 @@ case class Table(private[flink] val operation: PlanNode) {
* Example:
*
* {{{
- * in.filter(name === "Fred")
+ * in.where('name === "Fred")
* }}}
*/
def where(predicate: Expression): Table = {
@@ -167,7 +167,7 @@ case class Table(private[flink] val operation: PlanNode) {
* Example:
*
* {{{
- * in.filter("name === 'Fred'")
+ * in.filter("name = 'Fred'")
* }}}
*/
def where(predicate: String): Table = {