You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by al...@apache.org on 2014/09/24 11:09:12 UTC
svn commit: r1627262 - in /incubator/flink: index.html site/index.html
Author: aljoscha
Date: Wed Sep 24 09:09:12 2014
New Revision: 1627262
URL: http://svn.apache.org/r1627262
Log:
Fix missing parenthesis in Example on index.html
Modified:
incubator/flink/index.html
incubator/flink/site/index.html
Modified: incubator/flink/index.html
URL: http://svn.apache.org/viewvc/incubator/flink/index.html?rev=1627262&r1=1627261&r2=1627262&view=diff
==============================================================================
--- incubator/flink/index.html (original)
+++ incubator/flink/index.html Wed Sep 24 09:09:12 2014
@@ -88,7 +88,7 @@ DataSet<String> input = env.readTextFile
input.flatMap(new FlatMapFunction() {
public void flatMap(String value, Collector out) {
for (String s : value.split(" ")) {
- out.collect(new Tuple2<String, Long>(s, 1L);
+ out.collect(new Tuple2<String, Long>(s, 1L));
}
}
})
@@ -128,4 +128,4 @@ File System) can act as data sources.
</div>
</div>
</div>
-</div>
\ No newline at end of file
+</div>
Modified: incubator/flink/site/index.html
URL: http://svn.apache.org/viewvc/incubator/flink/site/index.html?rev=1627262&r1=1627261&r2=1627262&view=diff
==============================================================================
--- incubator/flink/site/index.html (original)
+++ incubator/flink/site/index.html Wed Sep 24 09:09:12 2014
@@ -202,7 +202,7 @@ complex tasks efficiently.</p>
<span class="n">input</span><span class="o">.</span><span class="na">flatMap</span><span class="o">(</span><span class="k">new</span> <span class="nf">FlatMapFunction</span><span class="o">()</span> <span class="o">{</span>
<span class="kd">public</span> <span class="kt">void</span> <span class="nf">flatMap</span><span class="o">(</span><span class="n">String</span> <span class="n">value</span><span class="o">,</span> <span class="n">Collector</span> <span class="n">out</span><span class="o">)</span> <span class="o">{</span>
<span class="k">for</span> <span class="o">(</span><span class="n">String</span> <span class="n">s</span> <span class="o">:</span> <span class="n">value</span><span class="o">.</span><span class="na">split</span><span class="o">(</span><span class="s">" "</span><span class="o">))</span> <span class="o">{</span>
- <span class="n">out</span><span class="o">.</span><span class="na">collect</span><span class="o">(</span><span class="k">new</span> <span class="n">Tuple2</span><span class="o"><</span><span class="n">String</span><span class="o">,</span> <span class="n">Long</span><span class="o">>(</span><span class="n">s</span><span class="o">,</span> <span class="mi">1L</span><span class="o">);</span>
+ <span class="n">out</span><span class="o">.</span><span class="na">collect</span><span class="o">(</span><span class="k">new</span> <span class="n">Tuple2</span><span class="o"><</span><span class="n">String</span><span class="o">,</span> <span class="n">Long</span><span class="o">>(</span><span class="n">s</span><span class="o">,</span> <span class="mi">1L</span><span class="o">));</span>
<span class="o">}</span>
<span class="o">}</span>
<span class="o">})</span>
@@ -244,6 +244,7 @@ File System) can act as data sources.</p
</div>
</div>
+
<div class="footer">
<hr class="divider">