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 <[email protected]> Authored: Wed Apr 8 17:20:29 2015 +0200 Committer: Aljoscha Krettek <[email protected]> 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 = {
