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 2017/01/18 08:28:58 UTC

flink git commit: [hotfix] [docs] Several fixes on "Basic API Concepts".

Repository: flink
Updated Branches:
  refs/heads/master cb2820675 -> 6fb6967b9


[hotfix] [docs] Several fixes on "Basic API Concepts".

- Fix a wrong function name `groupBy()` to `keyBy()`.
- Add closing parentheses.
- Fix an invalid return type of sample code.
- Remove a duplicate "their".

This closes #3145.
This closes #3146.
This closes #3147.
This closes #3148.


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

Branch: refs/heads/master
Commit: 6fb6967b9f9a31f034bd09fcf76aaf147bc8e9a0
Parents: cb28206
Author: Keiji Yoshida <ke...@gmail.com>
Authored: Wed Jan 18 14:22:17 2017 +0900
Committer: Fabian Hueske <fh...@apache.org>
Committed: Wed Jan 18 09:25:02 2017 +0100

----------------------------------------------------------------------
 docs/dev/api_concepts.md | 12 ++++++------
 1 file changed, 6 insertions(+), 6 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/6fb6967b/docs/dev/api_concepts.md
----------------------------------------------------------------------
diff --git a/docs/dev/api_concepts.md b/docs/dev/api_concepts.md
index aa064d0..b3618aa 100644
--- a/docs/dev/api_concepts.md
+++ b/docs/dev/api_concepts.md
@@ -336,7 +336,7 @@ Field expressions make it very easy to select fields in (nested) composite types
 <div class="codetabs" markdown="1">
 <div data-lang="java" markdown="1">
 
-In the example below, we have a `WC` POJO with two fields "word" and "count". To group by the field `word`, we just pass its name to the `groupBy()` function.
+In the example below, we have a `WC` POJO with two fields "word" and "count". To group by the field `word`, we just pass its name to the `keyBy()` function.
 {% highlight java %}
 // some ordinary POJO (Plain old Java Object)
 public class WC {
@@ -392,7 +392,7 @@ These are valid field expressions for the example code above:
 </div>
 <div data-lang="scala" markdown="1">
 
-In the example below, we have a `WC` POJO with two fields "word" and "count". To group by the field `word`, we just pass its name to the `groupBy()` function.
+In the example below, we have a `WC` POJO with two fields "word" and "count". To group by the field `word`, we just pass its name to the `keyBy()` function.
 {% highlight java %}
 // some ordinary POJO (Plain old Java Object)
 class WC(var word: String, var count: Int) {
@@ -610,9 +610,9 @@ reduce, etc), four methods: `open`, `close`, `getRuntimeContext`, and
 `setRuntimeContext`. These are useful for parameterizing the function
 (see [Passing Parameters to Functions]({{ site.baseurl }}/dev/batch/index.html#passing-parameters-to-functions)),
 creating and finalizing local state, accessing broadcast variables (see
-[Broadcast Variables]({{ site.baseurl }}/dev/batch/index.html#broadcast-variables), and for accessing runtime
+[Broadcast Variables]({{ site.baseurl }}/dev/batch/index.html#broadcast-variables)), and for accessing runtime
 information such as accumulators and counters (see
-[Accumulators and Counters](#accumulators--counters), and information
+[Accumulators and Counters](#accumulators--counters)), and information
 on iterations (see [Iterations]({{ site.baseurl }}/dev/batch/iterations.html)).
 
 {% top %}
@@ -653,7 +653,7 @@ DataStream<Tuple2<String, Integer>> wordCounts = env.fromElements(
 
 wordCounts.map(new MapFunction<Tuple2<String, Integer>, Integer>() {
     @Override
-    public String map(Tuple2<String, Integer> value) throws Exception {
+    public Integer map(Tuple2<String, Integer> value) throws Exception {
         return value.f1;
     }
 });
@@ -753,7 +753,7 @@ Restrictions apply to classes containing fields that cannot be serialized, like
 resources. Classes that follow the Java Beans conventions work well in general.
 
 All classes that are not identified as POJO types (see POJO requirements above) are handled by Flink as general class types.
-Flink treats these data types as black boxes and is not able to access their their content (i.e., for efficient sorting). General types are de/serialized using the serialization framework [Kryo](https://github.com/EsotericSoftware/kryo).
+Flink treats these data types as black boxes and is not able to access their content (i.e., for efficient sorting). General types are de/serialized using the serialization framework [Kryo](https://github.com/EsotericSoftware/kryo).
 
 #### Values