You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by fh...@apache.org on 2016/05/13 22:25:29 UTC
flink git commit: [FLINK-3912] [docs] Fix errors in Batch Scala API
Documentation, Join section
Repository: flink
Updated Branches:
refs/heads/master 96b353d98 -> a9fc71d85
[FLINK-3912] [docs] Fix errors in Batch Scala API Documentation, Join section
This closes #1991
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a9fc71d8
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a9fc71d8
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/a9fc71d8
Branch: refs/heads/master
Commit: a9fc71d850528b472dee3541ae141e121bfc9b5f
Parents: 96b353d
Author: Ignacio N. Lucero Ascencio <ig...@gmail.com>
Authored: Fri May 13 23:41:25 2016 +0200
Committer: Fabian Hueske <fh...@apache.org>
Committed: Sat May 14 00:23:59 2016 +0200
----------------------------------------------------------------------
docs/apis/batch/dataset_transformations.md | 12 ++++++------
1 file changed, 6 insertions(+), 6 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/a9fc71d8/docs/apis/batch/dataset_transformations.md
----------------------------------------------------------------------
diff --git a/docs/apis/batch/dataset_transformations.md b/docs/apis/batch/dataset_transformations.md
index be9691c..2d72817 100644
--- a/docs/apis/batch/dataset_transformations.md
+++ b/docs/apis/batch/dataset_transformations.md
@@ -644,8 +644,8 @@ In contrast to a reduce function, a group-reduce function is not
implicitly combinable. In order to make a group-reduce function
combinable it must implement the `GroupCombineFunction` interface.
-**Important**: The generic input and output types of
-the `GroupCombineFunction` interface must be equal to the generic input type
+**Important**: The generic input and output types of
+the `GroupCombineFunction` interface must be equal to the generic input type
of the `GroupReduceFunction` as shown in the following example:
<div class="codetabs" markdown="1">
@@ -655,7 +655,7 @@ of the `GroupReduceFunction` as shown in the following example:
// Combinable GroupReduceFunction that computes a sum.
public class MyCombinableGroupReducer implements
GroupReduceFunction<Tuple2<String, Integer>, String>,
- GroupCombineFunction<Tuple2<String, Integer>, Tuple2<String, Integer>>
+ GroupCombineFunction<Tuple2<String, Integer>, Tuple2<String, Integer>>
{
@Override
public void reduce(Iterable<Tuple2<String, Integer>> in,
@@ -683,7 +683,7 @@ public class MyCombinableGroupReducer implements
sum += curr.f1;
}
// emit tuple with key and sum
- out.collect(new Tuple2<>(key, sum));
+ out.collect(new Tuple2<>(key, sum));
}
}
~~~
@@ -1379,8 +1379,8 @@ val ratings: DataSet[Ratings] = // [...]
val weights: DataSet[(String, Double)] = // [...]
val weightedRatings = ratings.join(weights).where("category").equalTo(0) {
- (rating, weight, out: Collector[(String, Double)] =>
- if (weight._2 > 0.1) out.collect(left.name, left.points * right._2)
+ (rating, weight, out: Collector[(String, Double)]) =>
+ if (weight._2 > 0.1) out.collect(rating.name, rating.points * weight._2)
}
~~~