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.