Repository: flink Updated Branches: refs/heads/release-1.0 4ae55cfd7 -> 496dbc881
[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/496dbc88 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/496dbc88 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/496dbc88 Branch: refs/heads/release-1.0 Commit: 496dbc881b6cbec3851b523db9b5b35dbe0313c6 Parents: 4ae55cf Author: Ignacio N. Lucero Ascencio <[email protected]> Authored: Fri May 13 23:41:25 2016 +0200 Committer: Fabian Hueske <[email protected]> Committed: Sat May 14 00:25:50 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/496dbc88/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) } ~~~
