flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From se...@apache.org
Subject flink git commit: [docs] fix readme typos; use the same scala style in the examples
Date Tue, 01 Mar 2016 10:49:44 GMT
Repository: flink
Updated Branches:
  refs/heads/release-1.0 30486905b -> 8e30f8665


[docs] fix readme typos; use the same scala style in the examples

This closes #1743


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

Branch: refs/heads/release-1.0
Commit: 8e30f86657e4432a226d28810bac54cdcc906c04
Parents: 3048690
Author: vasia <vasia@apache.org>
Authored: Mon Feb 29 22:49:35 2016 +0100
Committer: Stephan Ewen <sewen@apache.org>
Committed: Tue Mar 1 11:49:14 2016 +0100

----------------------------------------------------------------------
 README.md | 14 +++++++-------
 1 file changed, 7 insertions(+), 7 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/8e30f866/README.md
----------------------------------------------------------------------
diff --git a/README.md b/README.md
index 41ea37d..1597a58 100644
--- a/README.md
+++ b/README.md
@@ -19,17 +19,17 @@ Learn more about Flink at [http://flink.apache.org/](http://flink.apache.org/)
 
 * Fault-tolerance with *exactly-once* processing guarantees
 
-* Natural back-pressure in streaming programs.
+* Natural back-pressure in streaming programs
 
 * Libraries for Graph processing (batch), Machine Learning (batch), and Complex Event Processing
(streaming)
 
-* Built-in support for iterative programs (BSP) and in the DataSet (batch) API.
+* Built-in support for iterative programs (BSP) in the DataSet (batch) API
 
-* Custom memory management to for efficient and robust switching between in-memory and out-of-core
data processing algorithms.
+* Custom memory management for efficient and robust switching between in-memory and out-of-core
data processing algorithms
 
-* Compatibility layers for Apache Hadoop MapReduce and Apache Storm.
+* Compatibility layers for Apache Hadoop MapReduce and Apache Storm
 
-* Integration with YARN, HDFS, HBase, and other components of the Apache Hadoop ecosystem.
+* Integration with YARN, HDFS, HBase, and other components of the Apache Hadoop ecosystem
 
 
 ### Streaming Example
@@ -53,8 +53,8 @@ case class WordWithCount(word: String, count: Long)
 
 val text = env.readTextFile(path)
 
-val counts = text.flatMap { _.split("\\W+") }
-  .map { WordWithCount(_, 1) }
+val counts = text.flatMap { w => w.split("\\s") }
+  .map { w => WordWithCount(w, 1) }
   .groupBy("word")
   .sum("count")
 


Mime
View raw message