You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by se...@apache.org on 2015/07/29 14:19:31 UTC

flink git commit: [docs] Updated method documentation. Changed .isEqualTo(..) to .equalsTo(..)

Repository: flink
Updated Branches:
  refs/heads/master ada9037be -> 3e49daf26


[docs] Updated method documentation. Changed .isEqualTo(..) to .equalsTo(..)

This close #909


Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/3e49daf2
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/3e49daf2
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/3e49daf2

Branch: refs/heads/master
Commit: 3e49daf26b1b7d78e2ae846f40051bb7cfa7ab84
Parents: ada9037
Author: Peter Schrott <pe...@gmail.com>
Authored: Tue Jul 14 10:39:58 2015 +0200
Committer: Stephan Ewen <se...@apache.org>
Committed: Wed Jul 29 14:18:46 2015 +0200

----------------------------------------------------------------------
 .../main/scala/org/apache/flink/api/scala/joinDataSet.scala  | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/3e49daf2/flink-scala/src/main/scala/org/apache/flink/api/scala/joinDataSet.scala
----------------------------------------------------------------------
diff --git a/flink-scala/src/main/scala/org/apache/flink/api/scala/joinDataSet.scala b/flink-scala/src/main/scala/org/apache/flink/api/scala/joinDataSet.scala
index ce9d6e6..0ed74f4 100644
--- a/flink-scala/src/main/scala/org/apache/flink/api/scala/joinDataSet.scala
+++ b/flink-scala/src/main/scala/org/apache/flink/api/scala/joinDataSet.scala
@@ -40,7 +40,7 @@ import scala.reflect.ClassTag
  * {{{
  *   val left = ...
  *   val right = ...
- *   val joinResult = left.join(right).where(0, 2).isEqualTo(0, 1) {
+ *   val joinResult = left.join(right).where(0, 2).equalTo(0, 1) {
  *     (left, right) => new MyJoinResult(left, right)
  *   }
  * }}}
@@ -49,7 +49,7 @@ import scala.reflect.ClassTag
  * {{{
  *   val left = ...
  *   val right = ...
- *   val joinResult = left.join(right).where({_._1}).isEqualTo({_._1) {
+ *   val joinResult = left.join(right).where({_._1}).equalTo({_._1) {
  *     (left, right) => new MyJoinResult(left, right)
  *   }
  * }}}
@@ -210,12 +210,12 @@ class JoinDataSet[L, R](
 
 /**
  * An unfinished join operation that results from [[DataSet.join()]] The keys for the left and right
- * side must be specified using first `where` and then `isEqualTo`. For example:
+ * side must be specified using first `where` and then `equalTo`. For example:
  *
  * {{{
  *   val left = ...
  *   val right = ...
- *   val joinResult = left.join(right).where(...).isEqualTo(...)
+ *   val joinResult = left.join(right).where(...).equalTo(...)
  * }}}
  * @tparam L The type of the left input of the join.
  * @tparam R The type of the right input of the join.