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/10/30 11:22:09 UTC
svn commit: r1635454 [1/2] - in /incubator/flink: _includes/ site/
site/blog/ site/blog/page2/ site/docs/0.7-incubating/ site/news/2012/08/21/
site/news/2012/10/15/ site/news/2012/11/12/ site/news/2012/11/21/
site/news/2013/03/27/ site/news/2013/10/21/...
Author: aljoscha
Date: Thu Oct 30 10:22:07 2014
New Revision: 1635454
URL: http://svn.apache.org/r1635454
Log:
Update website
Modified:
incubator/flink/_includes/navbar.html
incubator/flink/site/asf.html
incubator/flink/site/blog/index.html
incubator/flink/site/blog/page2/index.html
incubator/flink/site/coding_guidelines.html
incubator/flink/site/community.html
incubator/flink/site/docs/0.7-incubating/cli.html
incubator/flink/site/docs/0.7-incubating/cluster_execution.html
incubator/flink/site/docs/0.7-incubating/cluster_setup.html
incubator/flink/site/docs/0.7-incubating/example_connectors.html
incubator/flink/site/docs/0.7-incubating/faq.html
incubator/flink/site/docs/0.7-incubating/hadoop_compatibility.html
incubator/flink/site/docs/0.7-incubating/index.html
incubator/flink/site/docs/0.7-incubating/java_api_quickstart.html
incubator/flink/site/docs/0.7-incubating/local_execution.html
incubator/flink/site/docs/0.7-incubating/local_setup.html
incubator/flink/site/docs/0.7-incubating/programming_guide.html
incubator/flink/site/docs/0.7-incubating/scala_api_quickstart.html
incubator/flink/site/docs/0.7-incubating/setup_quickstart.html
incubator/flink/site/docs/0.7-incubating/spargel_guide.html
incubator/flink/site/docs/0.7-incubating/streaming_guide.html
incubator/flink/site/docs/0.7-incubating/yarn_setup.html
incubator/flink/site/downloads.html
incubator/flink/site/how-to-contribute.html
incubator/flink/site/index.html
incubator/flink/site/material.html
incubator/flink/site/news/2012/08/21/release02.html
incubator/flink/site/news/2012/10/15/icde2013.html
incubator/flink/site/news/2012/11/12/btw2013demo.html
incubator/flink/site/news/2012/11/21/previewICDE2013.html
incubator/flink/site/news/2013/03/27/www-demo-paper.html
incubator/flink/site/news/2013/10/21/cikm2013-paper.html
incubator/flink/site/news/2013/12/13/humboldt-innovation-award.html
incubator/flink/site/news/2014/01/10/stratosphere-hadoop-summit.html
incubator/flink/site/news/2014/01/12/0.4-migration-guide.html
incubator/flink/site/news/2014/01/13/stratosphere-release-0.4.html
incubator/flink/site/news/2014/01/26/optimizer_plan_visualization_tool.html
incubator/flink/site/news/2014/01/28/querying_mongodb.html
incubator/flink/site/news/2014/02/18/amazon-elastic-mapreduce-cloud-yarn.html
incubator/flink/site/news/2014/02/24/stratosphere-google-summer-of-code-2014.html
incubator/flink/site/news/2014/04/16/stratosphere-goes-apache-incubator.html
incubator/flink/site/news/2014/05/31/release-0.5.html
incubator/flink/site/news/2014/08/26/release-0.6.html
incubator/flink/site/news/2014/09/26/release-0.6.1.html
incubator/flink/site/news/2014/10/03/upcoming_events.html
incubator/flink/site/privacy-policy.html
incubator/flink/site/project.html
Modified: incubator/flink/_includes/navbar.html
URL: http://svn.apache.org/viewvc/incubator/flink/_includes/navbar.html?rev=1635454&r1=1635453&r2=1635454&view=diff
==============================================================================
--- incubator/flink/_includes/navbar.html (original)
+++ incubator/flink/_includes/navbar.html Thu Oct 30 10:22:07 2014
@@ -36,13 +36,13 @@
<a href="#" class="dropdown-toggle" data-toggle="dropdown">Documentation <b class="caret"></b></a>
<ul class="dropdown-menu">
<li role="presentation" class="dropdown-header">Current Stable:</li>
+ <li><a href="{{ site.baseurl }}/docs/0.7-incubating/">0.7.0-incubating</a></li>
+ <li><a href="{{ site.baseurl }}/docs/0.7-incubating/api/java">0.7.0-incubating Javadocs</a></li>
+ <li><a href="{{ site.baseurl }}/docs/0.7-incubating/api/scala/index.html#org.apache.flink.api.scala.package">0.7.0-incubating Scaladocs</a></li>
+ <li class="divider"></li>
+ <li role="presentation" class="dropdown-header">Previous:</li>
<li><a href="{{ site.baseurl }}/docs/0.6-incubating/">0.6-incubating</a></li>
<li><a href="{{ site.baseurl }}/docs/0.6-incubating/api/java">0.6-incubating Javadocs</a></li>
- <li class="divider"></li>
- <li role="presentation" class="dropdown-header">Beta Preview:</li>
- <li><a href="{{ site.baseurl }}/docs/0.7-incubating/">0.7-incubating</a></li>
- <li><a href="{{ site.baseurl }}/docs/0.7-incubating/api/java">0.7-incubating Javadocs</a></li>
- <li><a href="{{ site.baseurl }}/docs/0.7-incubating/api/scala/index.html#org.apache.flink.api.scala.package">0.7-incubating Scaladocs</a></li>
</ul>
</li>
Modified: incubator/flink/site/asf.html
URL: http://svn.apache.org/viewvc/incubator/flink/site/asf.html?rev=1635454&r1=1635453&r2=1635454&view=diff
==============================================================================
--- incubator/flink/site/asf.html (original)
+++ incubator/flink/site/asf.html Thu Oct 30 10:22:07 2014
@@ -55,13 +55,13 @@
<a href="#" class="dropdown-toggle" data-toggle="dropdown">Documentation <b class="caret"></b></a>
<ul class="dropdown-menu">
<li role="presentation" class="dropdown-header">Current Stable:</li>
+ <li><a href="/docs/0.7-incubating/">0.7.0-incubating</a></li>
+ <li><a href="/docs/0.7-incubating/api/java">0.7.0-incubating Javadocs</a></li>
+ <li><a href="/docs/0.7-incubating/api/scala/index.html#org.apache.flink.api.scala.package">0.7.0-incubating Scaladocs</a></li>
+ <li class="divider"></li>
+ <li role="presentation" class="dropdown-header">Previous:</li>
<li><a href="/docs/0.6-incubating/">0.6-incubating</a></li>
<li><a href="/docs/0.6-incubating/api/java">0.6-incubating Javadocs</a></li>
- <li class="divider"></li>
- <li role="presentation" class="dropdown-header">Beta Preview:</li>
- <li><a href="/docs/0.7-incubating/">0.7-incubating</a></li>
- <li><a href="/docs/0.7-incubating/api/java">0.7-incubating Javadocs</a></li>
- <li><a href="/docs/0.7-incubating/api/scala/index.html#org.apache.flink.api.scala.package">0.7-incubating Scaladocs</a></li>
</ul>
</li>
@@ -126,7 +126,7 @@
<div class="footer">
-<hr class="divider">
+<p><hr class="divider"></p>
<p><small>Apache Flink is an effort undergoing incubation at The Apache Software
Foundation (ASF), sponsored by the Apache Incubator PMC. Incubation is
Modified: incubator/flink/site/blog/index.html
URL: http://svn.apache.org/viewvc/incubator/flink/site/blog/index.html?rev=1635454&r1=1635453&r2=1635454&view=diff
==============================================================================
--- incubator/flink/site/blog/index.html (original)
+++ incubator/flink/site/blog/index.html Thu Oct 30 10:22:07 2014
@@ -55,13 +55,13 @@
<a href="#" class="dropdown-toggle" data-toggle="dropdown">Documentation <b class="caret"></b></a>
<ul class="dropdown-menu">
<li role="presentation" class="dropdown-header">Current Stable:</li>
+ <li><a href="/docs/0.7-incubating/">0.7.0-incubating</a></li>
+ <li><a href="/docs/0.7-incubating/api/java">0.7.0-incubating Javadocs</a></li>
+ <li><a href="/docs/0.7-incubating/api/scala/index.html#org.apache.flink.api.scala.package">0.7.0-incubating Scaladocs</a></li>
+ <li class="divider"></li>
+ <li role="presentation" class="dropdown-header">Previous:</li>
<li><a href="/docs/0.6-incubating/">0.6-incubating</a></li>
<li><a href="/docs/0.6-incubating/api/java">0.6-incubating Javadocs</a></li>
- <li class="divider"></li>
- <li role="presentation" class="dropdown-header">Beta Preview:</li>
- <li><a href="/docs/0.7-incubating/">0.7-incubating</a></li>
- <li><a href="/docs/0.7-incubating/api/java">0.7-incubating Javadocs</a></li>
- <li><a href="/docs/0.7-incubating/api/scala/index.html#org.apache.flink.api.scala.package">0.7-incubating Scaladocs</a></li>
</ul>
</li>
@@ -856,7 +856,7 @@ var disqus_shortname = 'stratosphere-eu'
<div class="footer">
-<hr class="divider">
+<p><hr class="divider"></p>
<p><small>Apache Flink is an effort undergoing incubation at The Apache Software
Foundation (ASF), sponsored by the Apache Incubator PMC. Incubation is
Modified: incubator/flink/site/blog/page2/index.html
URL: http://svn.apache.org/viewvc/incubator/flink/site/blog/page2/index.html?rev=1635454&r1=1635453&r2=1635454&view=diff
==============================================================================
--- incubator/flink/site/blog/page2/index.html (original)
+++ incubator/flink/site/blog/page2/index.html Thu Oct 30 10:22:07 2014
@@ -55,13 +55,13 @@
<a href="#" class="dropdown-toggle" data-toggle="dropdown">Documentation <b class="caret"></b></a>
<ul class="dropdown-menu">
<li role="presentation" class="dropdown-header">Current Stable:</li>
+ <li><a href="/docs/0.7-incubating/">0.7.0-incubating</a></li>
+ <li><a href="/docs/0.7-incubating/api/java">0.7.0-incubating Javadocs</a></li>
+ <li><a href="/docs/0.7-incubating/api/scala/index.html#org.apache.flink.api.scala.package">0.7.0-incubating Scaladocs</a></li>
+ <li class="divider"></li>
+ <li role="presentation" class="dropdown-header">Previous:</li>
<li><a href="/docs/0.6-incubating/">0.6-incubating</a></li>
<li><a href="/docs/0.6-incubating/api/java">0.6-incubating Javadocs</a></li>
- <li class="divider"></li>
- <li role="presentation" class="dropdown-header">Beta Preview:</li>
- <li><a href="/docs/0.7-incubating/">0.7-incubating</a></li>
- <li><a href="/docs/0.7-incubating/api/java">0.7-incubating Javadocs</a></li>
- <li><a href="/docs/0.7-incubating/api/scala/index.html#org.apache.flink.api.scala.package">0.7-incubating Scaladocs</a></li>
</ul>
</li>
@@ -396,7 +396,7 @@ var disqus_shortname = 'stratosphere-eu'
<div class="footer">
-<hr class="divider">
+<p><hr class="divider"></p>
<p><small>Apache Flink is an effort undergoing incubation at The Apache Software
Foundation (ASF), sponsored by the Apache Incubator PMC. Incubation is
Modified: incubator/flink/site/coding_guidelines.html
URL: http://svn.apache.org/viewvc/incubator/flink/site/coding_guidelines.html?rev=1635454&r1=1635453&r2=1635454&view=diff
==============================================================================
--- incubator/flink/site/coding_guidelines.html (original)
+++ incubator/flink/site/coding_guidelines.html Thu Oct 30 10:22:07 2014
@@ -55,13 +55,13 @@
<a href="#" class="dropdown-toggle" data-toggle="dropdown">Documentation <b class="caret"></b></a>
<ul class="dropdown-menu">
<li role="presentation" class="dropdown-header">Current Stable:</li>
+ <li><a href="/docs/0.7-incubating/">0.7.0-incubating</a></li>
+ <li><a href="/docs/0.7-incubating/api/java">0.7.0-incubating Javadocs</a></li>
+ <li><a href="/docs/0.7-incubating/api/scala/index.html#org.apache.flink.api.scala.package">0.7.0-incubating Scaladocs</a></li>
+ <li class="divider"></li>
+ <li role="presentation" class="dropdown-header">Previous:</li>
<li><a href="/docs/0.6-incubating/">0.6-incubating</a></li>
<li><a href="/docs/0.6-incubating/api/java">0.6-incubating Javadocs</a></li>
- <li class="divider"></li>
- <li role="presentation" class="dropdown-header">Beta Preview:</li>
- <li><a href="/docs/0.7-incubating/">0.7-incubating</a></li>
- <li><a href="/docs/0.7-incubating/api/java">0.7-incubating Javadocs</a></li>
- <li><a href="/docs/0.7-incubating/api/scala/index.html#org.apache.flink.api.scala.package">0.7-incubating Scaladocs</a></li>
</ul>
</li>
@@ -158,7 +158,7 @@
<div class="footer">
-<hr class="divider">
+<p><hr class="divider"></p>
<p><small>Apache Flink is an effort undergoing incubation at The Apache Software
Foundation (ASF), sponsored by the Apache Incubator PMC. Incubation is
Modified: incubator/flink/site/community.html
URL: http://svn.apache.org/viewvc/incubator/flink/site/community.html?rev=1635454&r1=1635453&r2=1635454&view=diff
==============================================================================
--- incubator/flink/site/community.html (original)
+++ incubator/flink/site/community.html Thu Oct 30 10:22:07 2014
@@ -55,13 +55,13 @@
<a href="#" class="dropdown-toggle" data-toggle="dropdown">Documentation <b class="caret"></b></a>
<ul class="dropdown-menu">
<li role="presentation" class="dropdown-header">Current Stable:</li>
+ <li><a href="/docs/0.7-incubating/">0.7.0-incubating</a></li>
+ <li><a href="/docs/0.7-incubating/api/java">0.7.0-incubating Javadocs</a></li>
+ <li><a href="/docs/0.7-incubating/api/scala/index.html#org.apache.flink.api.scala.package">0.7.0-incubating Scaladocs</a></li>
+ <li class="divider"></li>
+ <li role="presentation" class="dropdown-header">Previous:</li>
<li><a href="/docs/0.6-incubating/">0.6-incubating</a></li>
<li><a href="/docs/0.6-incubating/api/java">0.6-incubating Javadocs</a></li>
- <li class="divider"></li>
- <li role="presentation" class="dropdown-header">Beta Preview:</li>
- <li><a href="/docs/0.7-incubating/">0.7-incubating</a></li>
- <li><a href="/docs/0.7-incubating/api/java">0.7-incubating Javadocs</a></li>
- <li><a href="/docs/0.7-incubating/api/scala/index.html#org.apache.flink.api.scala.package">0.7-incubating Scaladocs</a></li>
</ul>
</li>
@@ -322,7 +322,7 @@
<div class="footer">
-<hr class="divider">
+<p><hr class="divider"></p>
<p><small>Apache Flink is an effort undergoing incubation at The Apache Software
Foundation (ASF), sponsored by the Apache Incubator PMC. Incubation is
Modified: incubator/flink/site/docs/0.7-incubating/cli.html
URL: http://svn.apache.org/viewvc/incubator/flink/site/docs/0.7-incubating/cli.html?rev=1635454&r1=1635453&r2=1635454&view=diff
==============================================================================
--- incubator/flink/site/docs/0.7-incubating/cli.html (original)
+++ incubator/flink/site/docs/0.7-incubating/cli.html Thu Oct 30 10:22:07 2014
@@ -144,20 +144,20 @@ local.sh</code> or <code><flink-home&
<li>
<p>Run example program with no arguments.</p>
- <div class="highlight"><pre><code>./bin/flink run ./examples/flink-java-examples-0.7.0-incubating-WordCount.jar
+ <div class="highlight"><pre><code>./bin/flink run ./examples/flink-java-examples-0.7-incubating-WordCount.jar
</code></pre></div>
</li>
<li>
<p>Run example program with arguments for input and result files</p>
- <div class="highlight"><pre><code>./bin/flink run ./examples/flink-java-examples-0.7.0-incubating-WordCount.jar \
+ <div class="highlight"><pre><code>./bin/flink run ./examples/flink-java-examples-0.7-incubating-WordCount.jar \
file:///home/user/hamlet.txt file:///home/user/wordcount_out
</code></pre></div>
</li>
<li>
<p>Run example program with parallelism 16 and arguments for input and result files</p>
- <div class="highlight"><pre><code>./bin/flink run -p 16 ./examples/flink-java-examples-0.7.0-incubating-WordCount.jar \
+ <div class="highlight"><pre><code>./bin/flink run -p 16 ./examples/flink-java-examples-0.7-incubating-WordCount.jar \
file:///home/user/hamlet.txt file:///home/user/wordcount_out
</code></pre></div>
</li>
@@ -165,21 +165,21 @@ local.sh</code> or <code><flink-home&
<p>Run example program on a specific JobManager:</p>
<div class="highlight"><pre><code>./bin/flink run -m myJMHost:6123 \
- ./examples/flink-java-examples-0.7.0-incubating-WordCount.jar \
+ ./examples/flink-java-examples-0.7-incubating-WordCount.jar \
-file:///home/user/hamlet.txt file:///home/user/wordcount_out
</code></pre></div>
</li>
<li>
<p>Display the expected arguments for the WordCount example program:</p>
- <div class="highlight"><pre><code>./bin/flink info -d ./examples/flink-java-examples-0.7.0-incubating-WordCount.jar
+ <div class="highlight"><pre><code>./bin/flink info -d ./examples/flink-java-examples-0.7-incubating-WordCount.jar
</code></pre></div>
</li>
<li>
<p>Display the optimized execution plan for the WordCount example program as JSON:</p>
<div class="highlight"><pre><code>./bin/flink info -e
- ./examples/flink-java-examples-0.7.0-incubating-WordCount.jar \
+ ./examples/flink-java-examples-0.7-incubating-WordCount.jar \
file:///home/user/hamlet.txt file:///home/user/wordcount_out
</code></pre></div>
</li>
Modified: incubator/flink/site/docs/0.7-incubating/cluster_execution.html
URL: http://svn.apache.org/viewvc/incubator/flink/site/docs/0.7-incubating/cluster_execution.html?rev=1635454&r1=1635453&r2=1635454&view=diff
==============================================================================
--- incubator/flink/site/docs/0.7-incubating/cluster_execution.html (original)
+++ incubator/flink/site/docs/0.7-incubating/cluster_execution.html Thu Oct 30 10:22:07 2014
@@ -152,7 +152,7 @@ execute the program.</p>
<div class="highlight"><pre><code class="language-xml"><span class="nt"><dependency></span>
<span class="nt"><groupId></span>org.apache.flink<span class="nt"></groupId></span>
<span class="nt"><artifactId></span>flink-clients<span class="nt"></artifactId></span>
- <span class="nt"><version></span>0.7.0-incubating<span class="nt"></version></span>
+ <span class="nt"><version></span>0.7-incubating<span class="nt"></version></span>
<span class="nt"></dependency></span></code></pre></div>
<h3 id="example">Example</h3>
@@ -194,7 +194,7 @@ Flink programs on a cluster directly. Th
<div class="highlight"><pre><code class="language-xml"><span class="nt"><dependency></span>
<span class="nt"><groupId></span>org.apache.flink<span class="nt"></groupId></span>
<span class="nt"><artifactId></span>flink-clients<span class="nt"></artifactId></span>
- <span class="nt"><version></span>0.7.0-incubating<span class="nt"></version></span>
+ <span class="nt"><version></span>0.7-incubating<span class="nt"></version></span>
<span class="nt"></dependency></span></code></pre></div>
<h3 id="example-1">Example</h3>
Modified: incubator/flink/site/docs/0.7-incubating/cluster_setup.html
URL: http://svn.apache.org/viewvc/incubator/flink/site/docs/0.7-incubating/cluster_setup.html?rev=1635454&r1=1635453&r2=1635454&view=diff
==============================================================================
--- incubator/flink/site/docs/0.7-incubating/cluster_setup.html (original)
+++ incubator/flink/site/docs/0.7-incubating/cluster_setup.html Thu Oct 30 10:22:07 2014
@@ -352,7 +352,7 @@ guide.</p>
<h2 id="flink-setup">Flink Setup</h2>
-<p>Go to the <a href="/downloads.html">downloads page</a> and get the ready to run
+<p>Go to the <a href="downloads/">downloads page</a> and get the ready to run
package. Make sure to pick the Flink package <strong>matching your Hadoop
version</strong>.</p>
Modified: incubator/flink/site/docs/0.7-incubating/example_connectors.html
URL: http://svn.apache.org/viewvc/incubator/flink/site/docs/0.7-incubating/example_connectors.html?rev=1635454&r1=1635453&r2=1635454&view=diff
==============================================================================
--- incubator/flink/site/docs/0.7-incubating/example_connectors.html (original)
+++ incubator/flink/site/docs/0.7-incubating/example_connectors.html Thu Oct 30 10:22:07 2014
@@ -142,7 +142,7 @@ mvn clean install</code></pre></div>
<li>
<p>Set the the version of Flink to <code>0.7-hadoop2-incubating</code> in the <code>pom.xml</code> file. The quickstart.sh script sets the version to the <code>hadoop1</code> version of Flink. Since the <code>microsoft-hadoop-azure</code> has been written for Hadoop 2.2 (mapreduce-API) version, we need to use the appropriate Flink version. </p>
- <p>Replace all occurences of <code><version>0.7.0-incubating</version></code> with <code><version>0.7-hadoop2-incubating</version></code>.</p>
+ <p>Replace all occurences of <code><version>0.7-incubating</version></code> with <code><version>0.7-hadoop2-incubating</version></code>.</p>
</li>
<li>
<p>Add the following dependencies (in the <code><dependencies></code> section) to your <code>pom.xml</code> file:</p>
Modified: incubator/flink/site/docs/0.7-incubating/faq.html
URL: http://svn.apache.org/viewvc/incubator/flink/site/docs/0.7-incubating/faq.html?rev=1635454&r1=1635453&r2=1635454&view=diff
==============================================================================
--- incubator/flink/site/docs/0.7-incubating/faq.html (original)
+++ incubator/flink/site/docs/0.7-incubating/faq.html Thu Oct 30 10:22:07 2014
@@ -227,13 +227,10 @@ of the fields used in your function is n
<p>In particular, if your function is an inner class, or anonymous inner class,
it contains a hidden reference to the enclosing class (usually called <code>this$0</code>, if you look
at the function in the debugger). If the enclosing class is not serializable, this is probably
-the source of the error. Solutions are to</p>
-
-<ul>
- <li>make the function a standalone class, or a static inner class (no more reference to the enclosing class)</li>
- <li>make the enclosing class serializable</li>
- <li>use a Java 8 lambda function.</li>
-</ul>
+the source of the error. Solutions are to
+- make the function a standalone class, or a static inner class (no more reference to the enclosing class)
+- make the enclosing class serializable
+- use a Java 8 lambda function.</p>
<h3 id="i-get-an-error-message-saying-that-not-enough-buffers-are-available-how-do-i-fix-this">I get an error message saying that not enough buffers are available. How do I fix this?</h3>
Modified: incubator/flink/site/docs/0.7-incubating/hadoop_compatibility.html
URL: http://svn.apache.org/viewvc/incubator/flink/site/docs/0.7-incubating/hadoop_compatibility.html?rev=1635454&r1=1635453&r2=1635454&view=diff
==============================================================================
--- incubator/flink/site/docs/0.7-incubating/hadoop_compatibility.html (original)
+++ incubator/flink/site/docs/0.7-incubating/hadoop_compatibility.html Thu Oct 30 10:22:07 2014
@@ -145,7 +145,7 @@
<div class="highlight"><pre><code class="language-xml"><span class="nt"><dependency></span>
<span class="nt"><groupId></span>org.apache.flink<span class="nt"></groupId></span>
<span class="nt"><artifactId></span>flink-hadoop-compatibility<span class="nt"></artifactId></span>
- <span class="nt"><version></span>0.7.0-incubating<span class="nt"></version></span>
+ <span class="nt"><version></span>0.7-incubating<span class="nt"></version></span>
<span class="nt"></dependency></span></code></pre></div>
<h3 id="using-hadoop-data-types">Using Hadoop Data Types</h3>
Modified: incubator/flink/site/docs/0.7-incubating/index.html
URL: http://svn.apache.org/viewvc/incubator/flink/site/docs/0.7-incubating/index.html?rev=1635454&r1=1635453&r2=1635454&view=diff
==============================================================================
--- incubator/flink/site/docs/0.7-incubating/index.html (original)
+++ incubator/flink/site/docs/0.7-incubating/index.html Thu Oct 30 10:22:07 2014
@@ -125,12 +125,12 @@ a thorough introduction of the Flink API
<h2 id="download">Download</h2>
<p>You can download Flink from the <a href="http://flink.incubator.apache.org/downloads.html">downloads</a> page
-of the <a href="http://flink.incubator.apache.org">project website</a>. This documentation if for version 0.7.0-incubating. Be careful
+of the <a href="http://flink.incubator.apache.org">project website</a>. This documentation if for version 0.7-incubating. Be careful
when picking a version, there are different versions depending on the Hadoop and/or
HDFS version that you want to use with Flink. Please refer to <a href="building.html">building</a> if you
want to build Flink yourself from the source.</p>
-<p>In Version 0.7.0-incubating the Scala API uses Scala 2.10. Please make
+<p>In Version 0.7-incubating the Scala API uses Scala 2.10. Please make
sure to use a compatible version.</p>
Modified: incubator/flink/site/docs/0.7-incubating/java_api_quickstart.html
URL: http://svn.apache.org/viewvc/incubator/flink/site/docs/0.7-incubating/java_api_quickstart.html?rev=1635454&r1=1635453&r2=1635454&view=diff
==============================================================================
--- incubator/flink/site/docs/0.7-incubating/java_api_quickstart.html (original)
+++ incubator/flink/site/docs/0.7-incubating/java_api_quickstart.html Thu Oct 30 10:22:07 2014
@@ -146,7 +146,7 @@
<div class="highlight"><pre><code class="language-bash" data-lang="bash"><span class="nv">$ </span>mvn archetype:generate <span class="se">\</span>
-DarchetypeGroupId<span class="o">=</span>org.apache.flink <span class="se">\</span>
-DarchetypeArtifactId<span class="o">=</span>flink-quickstart-java <span class="se">\</span>
- -DarchetypeVersion<span class="o">=</span>0.7.0-incubating</code></pre></div>
+ -DarchetypeVersion<span class="o">=</span>0.7-incubating</code></pre></div>
This allows you to <strong>name your newly created project</strong>. It will interactively ask you for the groupId, artifactId, and package name.
</div>
Modified: incubator/flink/site/docs/0.7-incubating/local_execution.html
URL: http://svn.apache.org/viewvc/incubator/flink/site/docs/0.7-incubating/local_execution.html?rev=1635454&r1=1635453&r2=1635454&view=diff
==============================================================================
--- incubator/flink/site/docs/0.7-incubating/local_execution.html (original)
+++ incubator/flink/site/docs/0.7-incubating/local_execution.html Thu Oct 30 10:22:07 2014
@@ -134,7 +134,7 @@
<div class="highlight"><pre><code class="language-xml"><span class="nt"><dependency></span>
<span class="nt"><groupId></span>org.apache.flink<span class="nt"></groupId></span>
<span class="nt"><artifactId></span>flink-clients<span class="nt"></artifactId></span>
- <span class="nt"><version></span>0.7.0-incubating<span class="nt"></version></span>
+ <span class="nt"><version></span>0.7-incubating<span class="nt"></version></span>
<span class="nt"></dependency></span></code></pre></div>
<h2 id="local-environment">Local Environment</h2>
Modified: incubator/flink/site/docs/0.7-incubating/local_setup.html
URL: http://svn.apache.org/viewvc/incubator/flink/site/docs/0.7-incubating/local_setup.html?rev=1635454&r1=1635453&r2=1635454&view=diff
==============================================================================
--- incubator/flink/site/docs/0.7-incubating/local_setup.html (original)
+++ incubator/flink/site/docs/0.7-incubating/local_setup.html Thu Oct 30 10:22:07 2014
@@ -130,7 +130,7 @@
<h2 id="download">Download</h2>
-<p>Go to the <a href="/downloads.html">downloads page</a> and get the ready to run package. If you want to interact with Hadoop (e.g. HDFS or HBase), make sure to pick the Flink package <strong>matching your Hadoop version</strong>. When in doubt or you plan to just work with the local file system pick the package for Hadoop 1.2.x.</p>
+<p>Go to the <a href="/downloads/">downloads page</a> and get the ready to run package. If you want to interact with Hadoop (e.g. HDFS or HBase), make sure to pick the Flink package <strong>matching your Hadoop version</strong>. When in doubt or you plan to just work with the local file system pick the package for Hadoop 1.2.x.</p>
<h2 id="requirements">Requirements</h2>
Modified: incubator/flink/site/docs/0.7-incubating/programming_guide.html
URL: http://svn.apache.org/viewvc/incubator/flink/site/docs/0.7-incubating/programming_guide.html?rev=1635454&r1=1635453&r2=1635454&view=diff
==============================================================================
--- incubator/flink/site/docs/0.7-incubating/programming_guide.html (original)
+++ incubator/flink/site/docs/0.7-incubating/programming_guide.html Thu Oct 30 10:22:07 2014
@@ -120,7 +120,12 @@
<li><a href="#program-skeleton">Program Skeleton</a></li>
<li><a href="#lazy-evaluation">Lazy Evaluation</a></li>
<li><a href="#transformations">Transformations</a></li>
- <li><a href="#specifying-keys">Specifying Keys</a></li>
+ <li><a href="#specifying-keys">Specifying Keys</a> <ul>
+ <li><a href="#define-keys-for-tuples">Define keys for Tuples</a></li>
+ <li><a href="#define-key-using-a-string-expression">Define key using a String Expression</a></li>
+ <li><a href="#define-key-using-a-key-selector-function">Define key using a Key Selector Function</a></li>
+ </ul>
+ </li>
<li><a href="#passing-functions-to-flink">Passing Functions to Flink</a></li>
<li><a href="#data-types">Data Types</a></li>
<li><a href="#data-sources">Data Sources</a></li>
@@ -243,7 +248,7 @@ manually create the project, you can use
<div class="highlight"><pre><code class="language-bash" data-lang="bash">mvn archetype:generate /
-DarchetypeGroupId<span class="o">=</span>org.apache.flink/
-DarchetypeArtifactId<span class="o">=</span>flink-quickstart-java /
- -DarchetypeVersion<span class="o">=</span>0.7.0-incubating</code></pre></div>
+ -DarchetypeVersion<span class="o">=</span>0.7-incubating</code></pre></div>
</div>
<div data-lang="scala">
@@ -251,7 +256,7 @@ manually create the project, you can use
<div class="highlight"><pre><code class="language-bash" data-lang="bash">mvn archetype:generate /
-DarchetypeGroupId<span class="o">=</span>org.apache.flink/
-DarchetypeArtifactId<span class="o">=</span>flink-quickstart-scala /
- -DarchetypeVersion<span class="o">=</span>0.7.0-incubating</code></pre></div>
+ -DarchetypeVersion<span class="o">=</span>0.7-incubating</code></pre></div>
</div>
</div>
@@ -265,12 +270,12 @@ manually create the project, you can use
<div class="highlight"><pre><code class="language-xml" data-lang="xml"><span class="nt"><dependency></span>
<span class="nt"><groupId></span>org.apache.flink<span class="nt"></groupId></span>
<span class="nt"><artifactId></span>flink-java<span class="nt"></artifactId></span>
- <span class="nt"><version></span>0.7.0-incubating<span class="nt"></version></span>
+ <span class="nt"><version></span>0.7-incubating<span class="nt"></version></span>
<span class="nt"></dependency></span>
<span class="nt"><dependency></span>
<span class="nt"><groupId></span>org.apache.flink<span class="nt"></groupId></span>
<span class="nt"><artifactId></span>flink-clients<span class="nt"></artifactId></span>
- <span class="nt"><version></span>0.7.0-incubating<span class="nt"></version></span>
+ <span class="nt"><version></span>0.7-incubating<span class="nt"></version></span>
<span class="nt"></dependency></span></code></pre></div>
</div>
@@ -279,12 +284,12 @@ manually create the project, you can use
<div class="highlight"><pre><code class="language-xml" data-lang="xml"><span class="nt"><dependency></span>
<span class="nt"><groupId></span>org.apache.flink<span class="nt"></groupId></span>
<span class="nt"><artifactId></span>flink-scala<span class="nt"></artifactId></span>
- <span class="nt"><version></span>0.7.0-incubating<span class="nt"></version></span>
+ <span class="nt"><version></span>0.7-incubating<span class="nt"></version></span>
<span class="nt"></dependency></span>
<span class="nt"><dependency></span>
<span class="nt"><groupId></span>org.apache.flink<span class="nt"></groupId></span>
<span class="nt"><artifactId></span>flink-clients<span class="nt"></artifactId></span>
- <span class="nt"><version></span>0.7.0-incubating<span class="nt"></version></span>
+ <span class="nt"><version></span>0.7-incubating<span class="nt"></version></span>
<span class="nt"></dependency></span></code></pre></div>
</div>
@@ -811,7 +816,7 @@ examples.</p>
<td><strong>MapPartition</strong></td>
<td>
<p>Transforms a parallel partition in a single function call. The function get the partition
- as an `Iterator` and can produce an arbitrary number of result values. The number of
+ as a `TraversableOnce` and can produce an arbitrary number of result values. The number of
elements in each partition depends on the degree-of-parallelism and previous operations.</p>
<div class="highlight"><pre><code class="language-scala" data-lang="scala"><span class="n">data</span><span class="o">.</span><span class="n">mapPartition</span> <span class="o">{</span> <span class="n">in</span> <span class="k">=></span> <span class="n">in</span> <span class="n">map</span> <span class="o">{</span> <span class="o">(</span><span class="k">_</span><span class="o">,</span> <span class="mi">1</span><span class="o">)</span> <span class="o">}</span> <span class="o">}</span></code></pre></div>
@@ -980,7 +985,7 @@ you do not need to physically pack the d
values. Keys are âvirtualâ: they are defined as functions over the
actual data to guide the grouping operator.</p>
- <h3 class="no_toc" id="define-keys-for-tuples">Define keys for Tuples</h3>
+ <h3 id="define-keys-for-tuples">Define keys for Tuples</h3>
<p>The simplest case is grouping a data set of Tuples on one or more
fields of the Tuple:</p>
@@ -1009,8 +1014,7 @@ with the same value for both fields.</p>
<p>Specifying <code>groupBy(0)</code> will cause the system to use the full <code>Tuple2</code> as a key (with the Integer and Float being the key). If you want to ânavigateâ into the nested <code>Tuple2</code>, you have to use a string-based expression, as explained below. For this particular example, you would have to specfiy <code>f0.f0</code>.</p>
- <h3 class="no_toc" id="define-key-using-a-string-expression">Define key using a String Expression</h3>
-
+ <h3 id="define-key-using-a-string-expression">Define key using a String Expression</h3>
<p>Starting from release 0.7-incubating, you can use String-based key expressions to select keys.</p>
<p>The String expressions allow to specify the name of the field in a class you want to group by.</p>
@@ -1073,7 +1077,7 @@ with the same value for both fields.</p>
<p>Please note that you can only use types inside POJOs that Flink is able to serialize. Currently, we are using <a href="http://avro.apache.org">Avro</a> to serialize arbitrary objects (such as <code>Date</code>).</p>
- <h3 class="no_toc" id="define-key-using-a-key-selector-function">Define key using a Key Selector Function</h3>
+ <h3 id="define-key-using-a-key-selector-function">Define key using a Key Selector Function</h3>
<p>An additional way to define keys are âkey selectorâ functions, which
takes as argument one dataset element and returns a key of an
@@ -1134,127 +1138,59 @@ you do not need to physically pack the d
values. Keys are âvirtualâ: they are defined as functions over the
actual data to guide the grouping operator.</p>
- <h3 class="no_toc" id="define-keys-for-tuples-1">Define keys for Tuples</h3>
+ <p>The simplest case is grouping a data set of Case Classes on one or more
+of itâs fields:</p>
- <p>The simplest case is grouping a data set of Tuples on one or more
-fields of the Tuple:</p>
-
- <div class="highlight"><pre><code class="language-scala" data-lang="scala"><span class="k">val</span> <span class="n">input</span><span class="k">:</span> <span class="kt">DataSet</span><span class="o">[(</span><span class="kt">Int</span>, <span class="kt">String</span>, <span class="kt">Long</span><span class="o">)]</span> <span class="k">=</span> <span class="c1">// [...]</span>
+ <div class="highlight"><pre><code class="language-scala" data-lang="scala"><span class="k">case</span> <span class="k">class</span> <span class="nc">WordCount</span><span class="o">(</span><span class="n">docId</span><span class="k">:</span> <span class="kt">Int</span><span class="o">,</span> <span class="n">word</span><span class="k">:</span> <span class="kt">String</span><span class="o">,</span> <span class="n">count</span><span class="k">:</span> <span class="kt">Int</span><span class="o">)</span>
+<span class="k">val</span> <span class="n">input</span><span class="k">:</span> <span class="kt">DataSet</span><span class="o">[</span><span class="kt">WordCount</span><span class="o">]</span> <span class="k">=</span> <span class="c1">// [...]</span>
<span class="k">val</span> <span class="n">grouped</span> <span class="k">=</span> <span class="n">input</span>
- <span class="o">.</span><span class="n">groupBy</span><span class="o">(</span><span class="mi">0</span><span class="o">)</span>
+ <span class="o">.</span><span class="n">groupBy</span><span class="o">(</span><span class="s">"word"</span><span class="o">)</span>
<span class="o">.</span><span class="n">reduceGroup</span><span class="o">(</span><span class="cm">/*do something*/</span><span class="o">)</span></code></pre></div>
- <p>The data set is grouped on the first field of the tuples (the one of
-Integer type). The group-reduce function will thus receive groups of tuples with
-the same value in the first field.</p>
+ <p>The data set is grouped on the second field of the Case Class (the one of
+String type). The group reduce function will thus receive groups of elements with
+the same value in the second field.</p>
- <div class="highlight"><pre><code class="language-scala" data-lang="scala"><span class="k">val</span> <span class="n">input</span><span class="k">:</span> <span class="kt">DataSet</span><span class="o">[(</span><span class="kt">Int</span>, <span class="kt">String</span>, <span class="kt">Long</span><span class="o">)]</span> <span class="k">=</span> <span class="c1">// [...]</span>
+ <div class="highlight"><pre><code class="language-scala" data-lang="scala"><span class="k">val</span> <span class="n">input</span><span class="k">:</span> <span class="kt">DataSet</span><span class="o">[</span><span class="kt">WordCount</span><span class="o">]</span> <span class="k">=</span> <span class="c1">// [...]</span>
<span class="k">val</span> <span class="n">grouped</span> <span class="k">=</span> <span class="n">input</span>
- <span class="o">.</span><span class="n">groupBy</span><span class="o">(</span><span class="mi">0</span><span class="o">,</span><span class="mi">1</span><span class="o">)</span>
- <span class="o">.</span><span class="n">reduce</span><span class="o">(</span><span class="cm">/*do something*/</span><span class="o">)</span></code></pre></div>
-
- <p>The data set is grouped on the composite key consisting of the first and the
-second fields, therefore the group-reduce function will receive groups
-with the same value for both fields.</p>
-
- <p>A note on nested Tuples: If you have a DataSet with a nested tuple, such as:</p>
-
- <div class="highlight"><pre><code class="language-scala" data-lang="scala"><span class="k">val</span> <span class="n">ds</span><span class="k">:</span> <span class="kt">DataSet</span><span class="o">[((</span><span class="kt">Int</span>, <span class="kt">Float</span><span class="o">)</span>, <span class="kt">String</span>, <span class="kt">Long</span><span class="o">)]</span></code></pre></div>
-
- <p>Specifying <code>groupBy(0)</code> will cause the system to use the full <code>Tuple2</code> as a key (with the Int and
-Float being the key). If you want to ânavigateâ into the nested <code>Tuple2</code>, you have to use a
-string-based expression, as explained below. For this particular example, you would have to specfiy
-<code>"_1._1"</code>.</p>
-
- <h3 class="no_toc" id="define-key-using-a-string-expression-1">Define key using a String Expression</h3>
-
- <p>Starting from release 0.7-incubating, you can use String-based key expressions to select keys.</p>
-
- <p>The String expressions allow to specify the name of the field in a class you want to group by.</p>
-
- <p>In the example below, we have a <code>WC</code> POJO with two fields âwordâ and âcountâ. To group by the field
-âwordâ, we just pass this name to the <code>groupBy()</code> function.</p>
-
- <div class="highlight"><pre><code class="language-java" data-lang="java"><span class="c1">// some ordinary POJO (Plain old Java Object)</span>
-<span class="kd">class</span> <span class="nf">WC</span><span class="o">(</span><span class="n">var</span> <span class="nl">word:</span> <span class="n">String</span><span class="o">,</span> <span class="n">var</span> <span class="nl">count:</span> <span class="n">Int</span><span class="o">)</span> <span class="o">{</span>
- <span class="n">def</span> <span class="nf">this</span><span class="o">()</span> <span class="o">{</span> <span class="k">this</span><span class="o">(</span><span class="s">""</span><span class="o">,</span> <span class="mi">0L</span><span class="o">)</span> <span class="o">}</span>
-<span class="o">}</span>
-<span class="n">val</span> <span class="nl">words:</span> <span class="n">DataSet</span><span class="o">[</span><span class="n">WC</span><span class="o">]</span> <span class="o">=</span> <span class="c1">// [...]</span>
-<span class="n">val</span> <span class="n">wordCounts</span> <span class="o">=</span> <span class="n">words</span><span class="o">.</span><span class="na">groupBy</span><span class="o">(</span><span class="s">"word"</span><span class="o">).</span><span class="na">reduce</span><span class="o">(</span><span class="cm">/*do something*/</span><span class="o">)</span>
-
-<span class="c1">// or, as a case class, which is less typing</span>
-<span class="k">case</span> <span class="kd">class</span> <span class="nf">WC</span><span class="o">(</span><span class="nl">word:</span> <span class="n">String</span><span class="o">,</span> <span class="nl">count:</span> <span class="n">Int</span><span class="o">)</span>
-<span class="n">val</span> <span class="nl">words:</span> <span class="n">DataSet</span><span class="o">[</span><span class="n">WC</span><span class="o">]</span> <span class="o">=</span> <span class="c1">// [...]</span>
-<span class="n">val</span> <span class="n">wordCounts</span> <span class="o">=</span> <span class="n">words</span><span class="o">.</span><span class="na">groupBy</span><span class="o">(</span><span class="s">"word"</span><span class="o">).</span><span class="na">reduce</span><span class="o">(</span><span class="cm">/*do something*/</span><span class="o">)</span></code></pre></div>
-
- <p><strong>Conditions</strong> for a class to enable using field selection expressions:</p>
-
- <ul>
- <li>The class must be public</li>
- <li>It must have a public constructor without arguments or be a case class.</li>
- <li>All fields either have to be public or there must be getters and setters for all non-public
- fields. If the field name is <code>foo</code> the getter and setters must be called <code>foo</code> and <code>foo_=</code>. This
- is what normally gets generated when you hava a <code>var foo</code> in your class. This also automatically
- applies to case classes since the getters and setters are automatically generated.</li>
- </ul>
+ <span class="o">.</span><span class="n">groupBy</span><span class="o">(</span><span class="s">"docId"</span><span class="o">,</span> <span class="s">"word"</span><span class="o">)</span>
+ <span class="o">.</span><span class="n">reduceGroup</span><span class="o">(</span><span class="cm">/*do something*/</span><span class="o">);</span></code></pre></div>
- <p><strong>Valid Expressions</strong>:</p>
+ <p>Here the DataSet is grouped on the composite key consisting of the first and the
+second fields, therefore the group reduce function will receive groups
+with the same value in both fields.</p>
- <ul>
- <li>You can select POJO fields by their field name</li>
- <li>You can select Tuple fields by their field name as well. For example <code>_1</code> or <code>_6</code>.</li>
- <li>You can select nested fields in POJOs and Tuples. Expressions like <code>user.zip</code> or <code>user.groupId</code>
-are valid. Flink also supports POJOs inside Tuples: <code>_2.user.zip</code>.</li>
- <li>You can select all fields at each level. To select all fields, specify <code>*</code>. This also works for
-the nested case: <code>user.*</code>.</li>
- </ul>
+ <p>As a special case, fields of Tuple DataSets can also be specified by (zero-based) index:</p>
- <p><strong>Example for nested POJO</strong></p>
+ <div class="highlight"><pre><code class="language-scala" data-lang="scala"><span class="k">val</span> <span class="n">input</span><span class="k">:</span> <span class="kt">DataSet</span><span class="o">[(</span><span class="kt">Int</span>, <span class="kt">String</span>, <span class="kt">Int</span><span class="o">)]</span> <span class="k">=</span> <span class="c1">// [...]</span>
+<span class="k">val</span> <span class="n">grouped</span> <span class="k">=</span> <span class="n">input</span>
+ <span class="o">.</span><span class="n">groupBy</span><span class="o">(</span><span class="mi">0</span><span class="o">,</span> <span class="mi">1</span><span class="o">)</span>
+ <span class="o">.</span><span class="n">reduceGroup</span><span class="o">(</span><span class="cm">/*do something*/</span><span class="o">);</span></code></pre></div>
- <div class="highlight"><pre><code class="language-scala" data-lang="scala"><span class="k">class</span> <span class="nc">WC</span><span class="o">(</span><span class="k">var</span> <span class="n">complex</span><span class="k">:</span> <span class="kt">ComplexNestedClass</span><span class="o">,</span> <span class="k">var</span> <span class="n">count</span><span class="k">:</span> <span class="kt">Int</span><span class="o">)</span> <span class="o">{</span>
- <span class="k">def</span> <span class="k">this</span><span class="o">()</span> <span class="o">{</span> <span class="k">this</span><span class="o">(</span><span class="kc">null</span><span class="o">,</span> <span class="mi">0</span><span class="o">)</span> <span class="o">}</span>
+ <p>For DataSets that donât contain Case Classes or Tuples, key definition is done via a âkey selectorâ
+function, which takes as argument one dataset element and must return a key of an
+arbitrary data type. For example:</p>
+
+ <div class="highlight"><pre><code class="language-scala" data-lang="scala"><span class="c1">// some ordinary object</span>
+<span class="k">class</span> <span class="nc">WC</span> <span class="o">{</span>
+ <span class="k">val</span> <span class="n">word</span><span class="k">:</span> <span class="kt">String</span>
+ <span class="k">val</span> <span class="n">count</span><span class="k">:</span> <span class="kt">Int</span>
<span class="o">}</span>
-<span class="k">class</span> <span class="nc">ComplexNestedClass</span><span class="o">(</span>
- <span class="k">var</span> <span class="n">someNumber</span><span class="k">:</span> <span class="kt">Int</span><span class="o">,</span>
- <span class="n">someFloat</span><span class="k">:</span> <span class="kt">Float</span><span class="o">,</span>
- <span class="n">word</span><span class="k">:</span> <span class="o">(</span><span class="kt">Long</span><span class="o">,</span> <span class="kt">Long</span><span class="o">,</span> <span class="nc">String</span><span class="o">),</span>
- <span class="n">hadoopCitizen</span><span class="k">:</span> <span class="kt">IntWritable</span><span class="o">)</span> <span class="o">{</span>
- <span class="k">def</span> <span class="k">this</span><span class="o">()</span> <span class="o">{</span> <span class="k">this</span><span class="o">(</span><span class="mi">0</span><span class="o">,</span> <span class="mi">0</span><span class="o">,</span> <span class="o">(</span><span class="mi">0</span><span class="o">,</span> <span class="mi">0</span><span class="o">,</span> <span class="s">""</span><span class="o">),</span> <span class="k">new</span> <span class="nc">IntWritable</span><span class="o">(</span><span class="mi">0</span><span class="o">))</span> <span class="o">}</span>
-<span class="o">}</span></code></pre></div>
-
- <p>These are valid expressions for the example POJO above:</p>
-
- <ul>
- <li><code>count</code>: The count field in the <code>WC</code> class.</li>
- <li><code>complex.*</code>: Selects all fields in the <code>ComplexNestedClass</code>.</li>
- <li><code>complex.word._3</code>: Selects the last field in the Tuple3.</li>
- <li><code>complex.hadoopCitizen</code>: Selects a Hadoop-<code>Writable</code> type as a key.</li>
- </ul>
-
- <p>Please note that you can only use types inside POJOs that Flink is able to serialize. Currently,
-we are using <a href="http://avro.apache.org">Avro</a> to serialize arbitrary objects (such as <code>Date</code>).</p>
-
- <h3 class="no_toc" id="define-key-using-a-key-selector-function-1">Define key using a Key Selector Function</h3>
-
- <p>An additional way to define keys are âkey selectorâ functions, which
-takes as argument one dataset element and returns a key of an
-arbitrary data type by performing an arbitrary computation on this
-element. For example:</p>
-
- <div class="highlight"><pre><code class="language-scala" data-lang="scala"><span class="c1">// some ordinary case class</span>
-<span class="k">case</span> <span class="k">class</span> <span class="nc">WC</span><span class="o">(</span><span class="n">word</span><span class="k">:</span> <span class="kt">String</span><span class="o">,</span> <span class="n">count</span><span class="k">:</span> <span class="kt">Int</span><span class="o">)</span>
<span class="k">val</span> <span class="n">words</span><span class="k">:</span> <span class="kt">DataSet</span><span class="o">[</span><span class="kt">WC</span><span class="o">]</span> <span class="k">=</span> <span class="c1">// [...]</span>
-<span class="k">val</span> <span class="n">wordCounts</span> <span class="k">=</span> <span class="n">words</span>
- <span class="o">.</span><span class="n">groupBy</span><span class="o">(</span> <span class="k">_</span><span class="o">.</span><span class="n">word</span> <span class="o">).</span><span class="n">reduce</span><span class="o">(</span><span class="cm">/*do something*/</span><span class="o">)</span></code></pre></div>
+<span class="k">val</span> <span class="n">counts</span><span class="k">:</span> <span class="kt">DataSet</span><span class="o">[</span><span class="kt">WC</span><span class="o">]</span> <span class="k">=</span> <span class="n">words</span> <span class="n">groupBy</span> <span class="o">{</span> <span class="k">_</span><span class="o">.</span><span class="n">word</span> <span class="o">}</span> <span class="n">reduce</span> <span class="o">{</span> <span class="cm">/*do something*/</span><span class="o">}</span></code></pre></div>
<p>Remember that keys are not only used for grouping, but also joining and matching data sets:</p>
- <div class="highlight"><pre><code class="language-scala" data-lang="scala"><span class="c1">// some case class</span>
+ <div class="highlight"><pre><code class="language-scala" data-lang="scala"><span class="c1">// some object</span>
<span class="k">case</span> <span class="k">class</span> <span class="nc">Rating</span><span class="o">(</span><span class="n">name</span><span class="k">:</span> <span class="kt">String</span><span class="o">,</span> <span class="n">category</span><span class="k">:</span> <span class="kt">String</span><span class="o">,</span> <span class="n">points</span><span class="k">:</span> <span class="kt">Int</span><span class="o">)</span>
-
<span class="k">val</span> <span class="n">ratings</span><span class="k">:</span> <span class="kt">DataSet</span><span class="o">[</span><span class="kt">Rating</span><span class="o">]</span> <span class="k">=</span> <span class="c1">// [...]</span>
<span class="k">val</span> <span class="n">weights</span><span class="k">:</span> <span class="kt">DataSet</span><span class="o">[(</span><span class="kt">String</span>, <span class="kt">Double</span><span class="o">)]</span> <span class="k">=</span> <span class="c1">// [...]</span>
-<span class="k">val</span> <span class="n">weightedRatings</span> <span class="k">=</span> <span class="n">ratings</span><span class="o">.</span><span class="n">join</span><span class="o">(</span><span class="n">weights</span><span class="o">).</span><span class="n">where</span><span class="o">(</span><span class="s">"category"</span><span class="o">).</span><span class="n">equalTo</span><span class="o">(</span><span class="s">"_1"</span><span class="o">)</span></code></pre></div>
+
+<span class="c1">// Tuples are also Case Classes in Scala, so we could use this:</span>
+<span class="k">val</span> <span class="n">weightedRatings</span> <span class="k">=</span> <span class="n">ratings</span><span class="o">.</span><span class="n">join</span><span class="o">(</span><span class="n">weights</span><span class="o">).</span><span class="n">where</span><span class="o">(</span><span class="s">"category"</span><span class="o">).</span><span class="n">equalTo</span><span class="o">(</span><span class="s">"_1"</span><span class="o">)</span>
+
+<span class="c1">// Or This:</span>
+<span class="k">val</span> <span class="n">weightedRatings2</span> <span class="k">=</span> <span class="n">ratings</span><span class="o">.</span><span class="n">join</span><span class="o">(</span><span class="n">weights</span><span class="o">).</span><span class="n">where</span><span class="o">(</span><span class="s">"category"</span><span class="o">).</span><span class="n">equalTo</span><span class="o">(</span><span class="mi">0</span><span class="o">)</span></code></pre></div>
</div>
</div>
Modified: incubator/flink/site/docs/0.7-incubating/scala_api_quickstart.html
URL: http://svn.apache.org/viewvc/incubator/flink/site/docs/0.7-incubating/scala_api_quickstart.html?rev=1635454&r1=1635453&r2=1635454&view=diff
==============================================================================
--- incubator/flink/site/docs/0.7-incubating/scala_api_quickstart.html (original)
+++ incubator/flink/site/docs/0.7-incubating/scala_api_quickstart.html Thu Oct 30 10:22:07 2014
@@ -146,7 +146,7 @@
<div class="highlight"><pre><code class="language-bash" data-lang="bash"><span class="nv">$ </span>mvn archetype:generate <span class="se">\</span>
-DarchetypeGroupId<span class="o">=</span>org.apache.flink <span class="se">\</span>
-DarchetypeArtifactId<span class="o">=</span>flink-quickstart-scala <span class="se">\</span>
- -DarchetypeVersion<span class="o">=</span>0.7.0-incubating</code></pre></div>
+ -DarchetypeVersion<span class="o">=</span>0.7-incubating</code></pre></div>
This allows you to <strong>name your newly created project</strong>. It will interactively ask you for the groupId, artifactId, and package name.
</div>
Modified: incubator/flink/site/docs/0.7-incubating/setup_quickstart.html
URL: http://svn.apache.org/viewvc/incubator/flink/site/docs/0.7-incubating/setup_quickstart.html?rev=1635454&r1=1635453&r2=1635454&view=diff
==============================================================================
--- incubator/flink/site/docs/0.7-incubating/setup_quickstart.html (original)
+++ incubator/flink/site/docs/0.7-incubating/setup_quickstart.html Thu Oct 30 10:22:07 2014
@@ -137,10 +137,10 @@
<p>
<div class="tab-content text-center">
<div class="tab-pane active" id="bin-hadoop1">
- <a class="btn btn-info btn-lg" onclick="_gaq.push(['_trackEvent','Action','download-quickstart-setup-1',this.href]);" href="http://www.apache.org/dyn/closer.cgi/incubator/flink/flink-0.7.0-incubating/flink-0.7.0-incubating-bin-hadoop1.tgz"><i class="icon-download"> </i> Download Flink for Hadoop 1.2</a>
+ <a class="btn btn-info btn-lg" onclick="_gaq.push(['_trackEvent','Action','download-quickstart-setup-1',this.href]);" href="http://www.apache.org/dyn/closer.cgi/incubator/flink/flink-0.7-incubating-bin-hadoop1.tgz"><i class="icon-download"> </i> Download Flink for Hadoop 1.2</a>
</div>
<div class="tab-pane" id="bin-hadoop2">
- <a class="btn btn-info btn-lg" onclick="_gaq.push(['_trackEvent','Action','download-quickstart-setup-2',this.href]);" href="http://www.apache.org/dyn/closer.cgi/incubator/flink/flink-0.7.0-incubating/flink-0.7.0-incubating-bin-hadoop2.tgz"><i class="icon-download"> </i> Download Flink for Hadoop 2</a>
+ <a class="btn btn-info btn-lg" onclick="_gaq.push(['_trackEvent','Action','download-quickstart-setup-2',this.href]);" href="http://www.apache.org/dyn/closer.cgi/incubator/flink/flink-0.7-incubating-bin-hadoop2.tgz"><i class="icon-download"> </i> Download Flink for Hadoop 2</a>
</div>
</div>
</p>
@@ -177,7 +177,7 @@ sure everything is up and running.</p>
<p><strong>Start the example program</strong>:</p>
<div class="highlight"><pre><code class="language-bash"><span class="nv">$ </span>bin/flink run <span class="se">\</span>
- --jarfile ./examples/flink-java-examples-0.7.0-incubating-WordCount.jar <span class="se">\</span>
+ --jarfile ./examples/flink-java-examples-0.7-incubating-WordCount.jar <span class="se">\</span>
--arguments file://<span class="sb">`</span><span class="nb">pwd</span><span class="sb">`</span>/hamlet.txt file://<span class="sb">`</span><span class="nb">pwd</span><span class="sb">`</span>/wordcount-result.txt</code></pre></div>
</li>
@@ -232,7 +232,7 @@ configuration files, which need to be ac
<p>You can easily deploy Flink on your existing <strong>YARN cluster</strong>. </p>
<ol>
- <li>Download the <strong>Flink YARN package</strong> with the YARN client: <a href="http://www.apache.org/dyn/closer.cgi/incubator/flink/flink-0.7.0-incubating/flink-0.7.0-incubating-bin-hadoop2-yarn.tgz">Flink for YARN</a></li>
+ <li>Download the <strong>Flink YARN package</strong> with the YARN client: <a href="http://www.apache.org/dyn/closer.cgi/incubator/flink/flink-0.7-incubating-bin-hadoop2-yarn.tgz">Flink for YARN</a></li>
<li>Make sure your <strong>HADOOP_HOME</strong> (or <em>YARN_CONF_DIR</em> or <em>HADOOP_CONF_DIR</em>) <strong>environment variable</strong> is set to read your YARN and HDFS configuration.</li>
<li>Run the <strong>YARN client</strong> with: <code>./bin/yarn-session.sh</code>. You can run the client with options <code>-n 10 -tm 8192</code> to allocate 10 TaskManagers with 8GB of memory each.</li>
</ol>
Modified: incubator/flink/site/docs/0.7-incubating/spargel_guide.html
URL: http://svn.apache.org/viewvc/incubator/flink/site/docs/0.7-incubating/spargel_guide.html?rev=1635454&r1=1635453&r2=1635454&view=diff
==============================================================================
--- incubator/flink/site/docs/0.7-incubating/spargel_guide.html (original)
+++ incubator/flink/site/docs/0.7-incubating/spargel_guide.html Thu Oct 30 10:22:07 2014
@@ -138,7 +138,7 @@
<div class="highlight"><pre><code class="language-xml"><span class="nt"><dependency></span>
<span class="nt"><groupId></span>org.apache.flink<span class="nt"></groupId></span>
<span class="nt"><artifactId></span>flink-spargel<span class="nt"></artifactId></span>
- <span class="nt"><version></span>0.7.0-incubating<span class="nt"></version></span>
+ <span class="nt"><version></span>0.7-incubating<span class="nt"></version></span>
<span class="nt"></dependency></span></code></pre></div>
<p>Extend <strong>VertexUpdateFunction<</strong><em>VertexKeyType</em>, <em>VertexValueType</em>, <em>MessageType</em><strong>></strong> to implement your <em>custom vertex update logic</em>.</p>
Modified: incubator/flink/site/docs/0.7-incubating/streaming_guide.html
URL: http://svn.apache.org/viewvc/incubator/flink/site/docs/0.7-incubating/streaming_guide.html?rev=1635454&r1=1635453&r2=1635454&view=diff
==============================================================================
--- incubator/flink/site/docs/0.7-incubating/streaming_guide.html (original)
+++ incubator/flink/site/docs/0.7-incubating/streaming_guide.html Thu Oct 30 10:22:07 2014
@@ -167,7 +167,7 @@
<div class="highlight"><pre><code class="language-xml"><span class="nt"><dependency></span>
<span class="nt"><groupId></span>org.apache.flink<span class="nt"></groupId></span>
<span class="nt"><artifactId></span>flink-streaming-core<span class="nt"></artifactId></span>
- <span class="nt"><version></span>0.7.0-incubating<span class="nt"></version></span>
+ <span class="nt"><version></span>0.7-incubating<span class="nt"></version></span>
<span class="nt"></dependency></span></code></pre></div>
<p>Create a data stream flow with our Java API as described below. In order to create your own Flink Streaming program, we encourage you to start with the <a href="#program-skeleton">skeleton</a> and gradually add your own <a href="#operations">operations</a>. The remaining sections act as references for additional operations and advanced features.</p>
Modified: incubator/flink/site/docs/0.7-incubating/yarn_setup.html
URL: http://svn.apache.org/viewvc/incubator/flink/site/docs/0.7-incubating/yarn_setup.html?rev=1635454&r1=1635453&r2=1635454&view=diff
==============================================================================
--- incubator/flink/site/docs/0.7-incubating/yarn_setup.html (original)
+++ incubator/flink/site/docs/0.7-incubating/yarn_setup.html Thu Oct 30 10:22:07 2014
@@ -133,9 +133,9 @@
<p>Start YARN session with 4 Task Managers (each with 4 GB of Heapspace):</p>
-<div class="highlight"><pre><code class="language-bash">wget http://artfiles.org/apache.org/incubator/flink/flink-0.7.0-incubating/flink-0.7.0-incubating-bin-hadoop2-yarn.tgz
-tar xvzf flink-0.7.0-incubating-bin-hadoop2-yarn.tgz
-<span class="nb">cd </span>flink-yarn-0.7.0-incubating/
+<div class="highlight"><pre><code class="language-bash">wget http://www.apache.org/dyn/closer.cgi/incubator/flink/flink-0.7-incubating-bin-hadoop2-yarn.tgz
+tar xvzf flink-0.7-incubating-bin-hadoop2-yarn.tgz
+<span class="nb">cd </span>flink-yarn-0.7-incubating/
./bin/yarn-session.sh -n <span class="m">4</span> -jm <span class="m">1024</span> -tm 4096</code></pre></div>
<p>Specify the <code>-s</code> flag for the number of processing slots per Task Manager. We recommend to set the number of slots to the number of processors per machine.</p>
@@ -151,7 +151,7 @@ tar xvzf flink-0.7.0-incubating-bin-hado
<li>HDFS (Hadoop Distributed File System)</li>
</ul>
-<p>If you have troubles using the Flink YARN client, have a look in the <a href="faq.html">FAQ section</a>.</p>
+<p>If you have troubles using the Flink YARN client, have a look in the <a href="/docs/0.5/general/faq.html">FAQ section</a>.</p>
<h3 id="start-flink-session">Start Flink Session</h3>
@@ -161,14 +161,14 @@ tar xvzf flink-0.7.0-incubating-bin-hado
<h4 id="download-flink-for-yarn">Download Flink for YARN</h4>
-<p>Download the YARN tgz package on the <a href="/downloads.html">download page</a>. It contains the required files.</p>
+<p>Download the YARN tgz package on the <a href="/downloads/">download page</a>. It contains the required files.</p>
-<p>Extract the package using:</p>
+<p>If you want to build the YARN .tgz file from sources, follow the <a href="building.html">build instructions</a>. Make sure to use the <code>-Dhadoop.profile=2</code> profile. You can find the file in <code>flink-dist/target/flink-dist--yarn.tar.gz</code> (<em>Note: The version might be different for you</em> ).</p>
-<div class="highlight"><pre><code class="language-bash">tar xvzf flink-0.7.0-incubating-bin-hadoop2-yarn.tgz
-<span class="nb">cd </span>flink-yarn-0.7.0-incubating/</code></pre></div>
+<p>Extract the package using:</p>
-<p>If you want to build the YARN .tgz file from sources, follow the <a href="building.html">build instructions</a>. Make sure to use the <code>-Dhadoop.profile=2</code> profile. You can find the result of the build in <code>flink-dist/target/flink-0.7.0-incubating-bin/flink-yarn-0.7.0-incubating/</code> (<em>Note: The version might be different for you</em> ).</p>
+<div class="highlight"><pre><code class="language-bash">tar xvzf flink-dist-0.7-incubating-yarn.tar.gz
+<span class="nb">cd </span>flink-yarn-0.7-incubating/</code></pre></div>
<h4 id="start-a-session">Start a Session</h4>
@@ -250,7 +250,7 @@ Action <span class="s2">"run"<
<div class="highlight"><pre><code class="language-bash">wget -O apache-license-v2.txt http://www.apache.org/licenses/LICENSE-2.0.txt
-./bin/flink run -j ./examples/flink-java-examples-0.7.0-incubating-WordCount.jar <span class="se">\</span>
+./bin/flink run -j ./examples/flink-java-examples-0.7-incubating-WordCount.jar <span class="se">\</span>
-a <span class="m">1</span> file://<span class="sb">`</span><span class="nb">pwd</span><span class="sb">`</span>/apache-license-v2.txt file://<span class="sb">`</span><span class="nb">pwd</span><span class="sb">`</span>/wordcount-result.txt</code></pre></div>
<p>If there is the following error, make sure that all TaskManagers started:</p>
@@ -311,7 +311,6 @@ Once that is enabled, users can use the
<p>After that, the AM starts allocating the containers for Flinkâs TaskManagers, which will download the jar file and the modified configuration from the HDFS. Once these steps are completed, Flink is set up and ready to accept Jobs.</p>
-
<div style="padding-top:30px" id="disqus_thread"></div>
<script type="text/javascript">
Modified: incubator/flink/site/downloads.html
URL: http://svn.apache.org/viewvc/incubator/flink/site/downloads.html?rev=1635454&r1=1635453&r2=1635454&view=diff
==============================================================================
--- incubator/flink/site/downloads.html (original)
+++ incubator/flink/site/downloads.html Thu Oct 30 10:22:07 2014
@@ -55,13 +55,13 @@
<a href="#" class="dropdown-toggle" data-toggle="dropdown">Documentation <b class="caret"></b></a>
<ul class="dropdown-menu">
<li role="presentation" class="dropdown-header">Current Stable:</li>
+ <li><a href="/docs/0.7-incubating/">0.7.0-incubating</a></li>
+ <li><a href="/docs/0.7-incubating/api/java">0.7.0-incubating Javadocs</a></li>
+ <li><a href="/docs/0.7-incubating/api/scala/index.html#org.apache.flink.api.scala.package">0.7.0-incubating Scaladocs</a></li>
+ <li class="divider"></li>
+ <li role="presentation" class="dropdown-header">Previous:</li>
<li><a href="/docs/0.6-incubating/">0.6-incubating</a></li>
<li><a href="/docs/0.6-incubating/api/java">0.6-incubating Javadocs</a></li>
- <li class="divider"></li>
- <li role="presentation" class="dropdown-header">Beta Preview:</li>
- <li><a href="/docs/0.7-incubating/">0.7-incubating</a></li>
- <li><a href="/docs/0.7-incubating/api/java">0.7-incubating Javadocs</a></li>
- <li><a href="/docs/0.7-incubating/api/scala/index.html#org.apache.flink.api.scala.package">0.7-incubating Scaladocs</a></li>
</ul>
</li>
@@ -112,16 +112,16 @@
<h1>Downloads</h1>
-<script type="text/javascript">
+<p><script type="text/javascript">
$( document ).ready(function() {
// Handler for .ready() called.
- $('.ga-track').on('click', function() {
+ $('.ga-track').on('click', function() {
// we just use the element id for tracking with google analytics
- ga('send', 'event', 'button', 'click', $(this).attr('id'));
- });
+ ga('send', 'event', 'button', 'click', $(this).attr('id'));
+ });</p>
-});
-</script>
+<p>});
+</script></p>
<p class="lead">Pick the <strong>Apache Flink</strong> package matching your Hadoop version.</p>
@@ -221,7 +221,7 @@ mvn clean package -DskipTests
<div class="footer">
-<hr class="divider">
+<p><hr class="divider"></p>
<p><small>Apache Flink is an effort undergoing incubation at The Apache Software
Foundation (ASF), sponsored by the Apache Incubator PMC. Incubation is
Modified: incubator/flink/site/how-to-contribute.html
URL: http://svn.apache.org/viewvc/incubator/flink/site/how-to-contribute.html?rev=1635454&r1=1635453&r2=1635454&view=diff
==============================================================================
--- incubator/flink/site/how-to-contribute.html (original)
+++ incubator/flink/site/how-to-contribute.html Thu Oct 30 10:22:07 2014
@@ -55,13 +55,13 @@
<a href="#" class="dropdown-toggle" data-toggle="dropdown">Documentation <b class="caret"></b></a>
<ul class="dropdown-menu">
<li role="presentation" class="dropdown-header">Current Stable:</li>
+ <li><a href="/docs/0.7-incubating/">0.7.0-incubating</a></li>
+ <li><a href="/docs/0.7-incubating/api/java">0.7.0-incubating Javadocs</a></li>
+ <li><a href="/docs/0.7-incubating/api/scala/index.html#org.apache.flink.api.scala.package">0.7.0-incubating Scaladocs</a></li>
+ <li class="divider"></li>
+ <li role="presentation" class="dropdown-header">Previous:</li>
<li><a href="/docs/0.6-incubating/">0.6-incubating</a></li>
<li><a href="/docs/0.6-incubating/api/java">0.6-incubating Javadocs</a></li>
- <li class="divider"></li>
- <li role="presentation" class="dropdown-header">Beta Preview:</li>
- <li><a href="/docs/0.7-incubating/">0.7-incubating</a></li>
- <li><a href="/docs/0.7-incubating/api/java">0.7-incubating Javadocs</a></li>
- <li><a href="/docs/0.7-incubating/api/scala/index.html#org.apache.flink.api.scala.package">0.7-incubating Scaladocs</a></li>
</ul>
</li>
@@ -283,7 +283,7 @@ To merge pull requests from our GitHub m
<div class="footer">
-<hr class="divider">
+<p><hr class="divider"></p>
<p><small>Apache Flink is an effort undergoing incubation at The Apache Software
Foundation (ASF), sponsored by the Apache Incubator PMC. Incubation is
Modified: incubator/flink/site/index.html
URL: http://svn.apache.org/viewvc/incubator/flink/site/index.html?rev=1635454&r1=1635453&r2=1635454&view=diff
==============================================================================
--- incubator/flink/site/index.html (original)
+++ incubator/flink/site/index.html Thu Oct 30 10:22:07 2014
@@ -55,13 +55,13 @@
<a href="#" class="dropdown-toggle" data-toggle="dropdown">Documentation <b class="caret"></b></a>
<ul class="dropdown-menu">
<li role="presentation" class="dropdown-header">Current Stable:</li>
+ <li><a href="/docs/0.7-incubating/">0.7.0-incubating</a></li>
+ <li><a href="/docs/0.7-incubating/api/java">0.7.0-incubating Javadocs</a></li>
+ <li><a href="/docs/0.7-incubating/api/scala/index.html#org.apache.flink.api.scala.package">0.7.0-incubating Scaladocs</a></li>
+ <li class="divider"></li>
+ <li role="presentation" class="dropdown-header">Previous:</li>
<li><a href="/docs/0.6-incubating/">0.6-incubating</a></li>
<li><a href="/docs/0.6-incubating/api/java">0.6-incubating Javadocs</a></li>
- <li class="divider"></li>
- <li role="presentation" class="dropdown-header">Beta Preview:</li>
- <li><a href="/docs/0.7-incubating/">0.7-incubating</a></li>
- <li><a href="/docs/0.7-incubating/api/java">0.7-incubating Javadocs</a></li>
- <li><a href="/docs/0.7-incubating/api/scala/index.html#org.apache.flink.api.scala.package">0.7-incubating Scaladocs</a></li>
</ul>
</li>
@@ -250,7 +250,7 @@ File System) can act as data sources.</p
<div class="footer">
-<hr class="divider">
+<p><hr class="divider"></p>
<p><small>Apache Flink is an effort undergoing incubation at The Apache Software
Foundation (ASF), sponsored by the Apache Incubator PMC. Incubation is
Modified: incubator/flink/site/material.html
URL: http://svn.apache.org/viewvc/incubator/flink/site/material.html?rev=1635454&r1=1635453&r2=1635454&view=diff
==============================================================================
--- incubator/flink/site/material.html (original)
+++ incubator/flink/site/material.html Thu Oct 30 10:22:07 2014
@@ -55,13 +55,13 @@
<a href="#" class="dropdown-toggle" data-toggle="dropdown">Documentation <b class="caret"></b></a>
<ul class="dropdown-menu">
<li role="presentation" class="dropdown-header">Current Stable:</li>
+ <li><a href="/docs/0.7-incubating/">0.7.0-incubating</a></li>
+ <li><a href="/docs/0.7-incubating/api/java">0.7.0-incubating Javadocs</a></li>
+ <li><a href="/docs/0.7-incubating/api/scala/index.html#org.apache.flink.api.scala.package">0.7.0-incubating Scaladocs</a></li>
+ <li class="divider"></li>
+ <li role="presentation" class="dropdown-header">Previous:</li>
<li><a href="/docs/0.6-incubating/">0.6-incubating</a></li>
<li><a href="/docs/0.6-incubating/api/java">0.6-incubating Javadocs</a></li>
- <li class="divider"></li>
- <li role="presentation" class="dropdown-header">Beta Preview:</li>
- <li><a href="/docs/0.7-incubating/">0.7-incubating</a></li>
- <li><a href="/docs/0.7-incubating/api/java">0.7-incubating Javadocs</a></li>
- <li><a href="/docs/0.7-incubating/api/scala/index.html#org.apache.flink.api.scala.package">0.7-incubating Scaladocs</a></li>
</ul>
</li>
@@ -232,7 +232,7 @@ Big Data Beers Berlin Meetup, November 2
<div class="footer">
-<hr class="divider">
+<p><hr class="divider"></p>
<p><small>Apache Flink is an effort undergoing incubation at The Apache Software
Foundation (ASF), sponsored by the Apache Incubator PMC. Incubation is
Modified: incubator/flink/site/news/2012/08/21/release02.html
URL: http://svn.apache.org/viewvc/incubator/flink/site/news/2012/08/21/release02.html?rev=1635454&r1=1635453&r2=1635454&view=diff
==============================================================================
--- incubator/flink/site/news/2012/08/21/release02.html (original)
+++ incubator/flink/site/news/2012/08/21/release02.html Thu Oct 30 10:22:07 2014
@@ -55,13 +55,13 @@
<a href="#" class="dropdown-toggle" data-toggle="dropdown">Documentation <b class="caret"></b></a>
<ul class="dropdown-menu">
<li role="presentation" class="dropdown-header">Current Stable:</li>
+ <li><a href="/docs/0.7-incubating/">0.7.0-incubating</a></li>
+ <li><a href="/docs/0.7-incubating/api/java">0.7.0-incubating Javadocs</a></li>
+ <li><a href="/docs/0.7-incubating/api/scala/index.html#org.apache.flink.api.scala.package">0.7.0-incubating Scaladocs</a></li>
+ <li class="divider"></li>
+ <li role="presentation" class="dropdown-header">Previous:</li>
<li><a href="/docs/0.6-incubating/">0.6-incubating</a></li>
<li><a href="/docs/0.6-incubating/api/java">0.6-incubating Javadocs</a></li>
- <li class="divider"></li>
- <li role="presentation" class="dropdown-header">Beta Preview:</li>
- <li><a href="/docs/0.7-incubating/">0.7-incubating</a></li>
- <li><a href="/docs/0.7-incubating/api/java">0.7-incubating Javadocs</a></li>
- <li><a href="/docs/0.7-incubating/api/scala/index.html#org.apache.flink.api.scala.package">0.7-incubating Scaladocs</a></li>
</ul>
</li>
@@ -164,7 +164,7 @@
<div class="footer">
-<hr class="divider">
+<p><hr class="divider"></p>
<p><small>Apache Flink is an effort undergoing incubation at The Apache Software
Foundation (ASF), sponsored by the Apache Incubator PMC. Incubation is
Modified: incubator/flink/site/news/2012/10/15/icde2013.html
URL: http://svn.apache.org/viewvc/incubator/flink/site/news/2012/10/15/icde2013.html?rev=1635454&r1=1635453&r2=1635454&view=diff
==============================================================================
--- incubator/flink/site/news/2012/10/15/icde2013.html (original)
+++ incubator/flink/site/news/2012/10/15/icde2013.html Thu Oct 30 10:22:07 2014
@@ -55,13 +55,13 @@
<a href="#" class="dropdown-toggle" data-toggle="dropdown">Documentation <b class="caret"></b></a>
<ul class="dropdown-menu">
<li role="presentation" class="dropdown-header">Current Stable:</li>
+ <li><a href="/docs/0.7-incubating/">0.7.0-incubating</a></li>
+ <li><a href="/docs/0.7-incubating/api/java">0.7.0-incubating Javadocs</a></li>
+ <li><a href="/docs/0.7-incubating/api/scala/index.html#org.apache.flink.api.scala.package">0.7.0-incubating Scaladocs</a></li>
+ <li class="divider"></li>
+ <li role="presentation" class="dropdown-header">Previous:</li>
<li><a href="/docs/0.6-incubating/">0.6-incubating</a></li>
<li><a href="/docs/0.6-incubating/api/java">0.6-incubating Javadocs</a></li>
- <li class="divider"></li>
- <li role="presentation" class="dropdown-header">Beta Preview:</li>
- <li><a href="/docs/0.7-incubating/">0.7-incubating</a></li>
- <li><a href="/docs/0.7-incubating/api/java">0.7-incubating Javadocs</a></li>
- <li><a href="/docs/0.7-incubating/api/scala/index.html#org.apache.flink.api.scala.package">0.7-incubating Scaladocs</a></li>
</ul>
</li>
@@ -165,7 +165,7 @@ We demonstrate our optimizer and a job s
<div class="footer">
-<hr class="divider">
+<p><hr class="divider"></p>
<p><small>Apache Flink is an effort undergoing incubation at The Apache Software
Foundation (ASF), sponsored by the Apache Incubator PMC. Incubation is
Modified: incubator/flink/site/news/2012/11/12/btw2013demo.html
URL: http://svn.apache.org/viewvc/incubator/flink/site/news/2012/11/12/btw2013demo.html?rev=1635454&r1=1635453&r2=1635454&view=diff
==============================================================================
--- incubator/flink/site/news/2012/11/12/btw2013demo.html (original)
+++ incubator/flink/site/news/2012/11/12/btw2013demo.html Thu Oct 30 10:22:07 2014
@@ -55,13 +55,13 @@
<a href="#" class="dropdown-toggle" data-toggle="dropdown">Documentation <b class="caret"></b></a>
<ul class="dropdown-menu">
<li role="presentation" class="dropdown-header">Current Stable:</li>
+ <li><a href="/docs/0.7-incubating/">0.7.0-incubating</a></li>
+ <li><a href="/docs/0.7-incubating/api/java">0.7.0-incubating Javadocs</a></li>
+ <li><a href="/docs/0.7-incubating/api/scala/index.html#org.apache.flink.api.scala.package">0.7.0-incubating Scaladocs</a></li>
+ <li class="divider"></li>
+ <li role="presentation" class="dropdown-header">Previous:</li>
<li><a href="/docs/0.6-incubating/">0.6-incubating</a></li>
<li><a href="/docs/0.6-incubating/api/java">0.6-incubating Javadocs</a></li>
- <li class="divider"></li>
- <li role="presentation" class="dropdown-header">Beta Preview:</li>
- <li><a href="/docs/0.7-incubating/">0.7-incubating</a></li>
- <li><a href="/docs/0.7-incubating/api/java">0.7-incubating Javadocs</a></li>
- <li><a href="/docs/0.7-incubating/api/scala/index.html#org.apache.flink.api.scala.package">0.7-incubating Scaladocs</a></li>
</ul>
</li>
@@ -163,7 +163,7 @@ Analyzing big data sets as they occur in
<div class="footer">
-<hr class="divider">
+<p><hr class="divider"></p>
<p><small>Apache Flink is an effort undergoing incubation at The Apache Software
Foundation (ASF), sponsored by the Apache Incubator PMC. Incubation is
Modified: incubator/flink/site/news/2012/11/21/previewICDE2013.html
URL: http://svn.apache.org/viewvc/incubator/flink/site/news/2012/11/21/previewICDE2013.html?rev=1635454&r1=1635453&r2=1635454&view=diff
==============================================================================
--- incubator/flink/site/news/2012/11/21/previewICDE2013.html (original)
+++ incubator/flink/site/news/2012/11/21/previewICDE2013.html Thu Oct 30 10:22:07 2014
@@ -55,13 +55,13 @@
<a href="#" class="dropdown-toggle" data-toggle="dropdown">Documentation <b class="caret"></b></a>
<ul class="dropdown-menu">
<li role="presentation" class="dropdown-header">Current Stable:</li>
+ <li><a href="/docs/0.7-incubating/">0.7.0-incubating</a></li>
+ <li><a href="/docs/0.7-incubating/api/java">0.7.0-incubating Javadocs</a></li>
+ <li><a href="/docs/0.7-incubating/api/scala/index.html#org.apache.flink.api.scala.package">0.7.0-incubating Scaladocs</a></li>
+ <li class="divider"></li>
+ <li role="presentation" class="dropdown-header">Previous:</li>
<li><a href="/docs/0.6-incubating/">0.6-incubating</a></li>
<li><a href="/docs/0.6-incubating/api/java">0.6-incubating Javadocs</a></li>
- <li class="divider"></li>
- <li role="presentation" class="dropdown-header">Beta Preview:</li>
- <li><a href="/docs/0.7-incubating/">0.7-incubating</a></li>
- <li><a href="/docs/0.7-incubating/api/java">0.7-incubating Javadocs</a></li>
- <li><a href="/docs/0.7-incubating/api/scala/index.html#org.apache.flink.api.scala.package">0.7-incubating Scaladocs</a></li>
</ul>
</li>
@@ -158,7 +158,7 @@ The demo shows how static code analysis
<div class="footer">
-<hr class="divider">
+<p><hr class="divider"></p>
<p><small>Apache Flink is an effort undergoing incubation at The Apache Software
Foundation (ASF), sponsored by the Apache Incubator PMC. Incubation is
Modified: incubator/flink/site/news/2013/03/27/www-demo-paper.html
URL: http://svn.apache.org/viewvc/incubator/flink/site/news/2013/03/27/www-demo-paper.html?rev=1635454&r1=1635453&r2=1635454&view=diff
==============================================================================
--- incubator/flink/site/news/2013/03/27/www-demo-paper.html (original)
+++ incubator/flink/site/news/2013/03/27/www-demo-paper.html Thu Oct 30 10:22:07 2014
@@ -55,13 +55,13 @@
<a href="#" class="dropdown-toggle" data-toggle="dropdown">Documentation <b class="caret"></b></a>
<ul class="dropdown-menu">
<li role="presentation" class="dropdown-header">Current Stable:</li>
+ <li><a href="/docs/0.7-incubating/">0.7.0-incubating</a></li>
+ <li><a href="/docs/0.7-incubating/api/java">0.7.0-incubating Javadocs</a></li>
+ <li><a href="/docs/0.7-incubating/api/scala/index.html#org.apache.flink.api.scala.package">0.7.0-incubating Scaladocs</a></li>
+ <li class="divider"></li>
+ <li role="presentation" class="dropdown-header">Previous:</li>
<li><a href="/docs/0.6-incubating/">0.6-incubating</a></li>
<li><a href="/docs/0.6-incubating/api/java">0.6-incubating Javadocs</a></li>
- <li class="divider"></li>
- <li role="presentation" class="dropdown-header">Beta Preview:</li>
- <li><a href="/docs/0.7-incubating/">0.7-incubating</a></li>
- <li><a href="/docs/0.7-incubating/api/java">0.7-incubating Javadocs</a></li>
- <li><a href="/docs/0.7-incubating/api/scala/index.html#org.apache.flink.api.scala.package">0.7-incubating Scaladocs</a></li>
</ul>
</li>
@@ -162,7 +162,7 @@ The importance of social-media platforms
<div class="footer">
-<hr class="divider">
+<p><hr class="divider"></p>
<p><small>Apache Flink is an effort undergoing incubation at The Apache Software
Foundation (ASF), sponsored by the Apache Incubator PMC. Incubation is
Modified: incubator/flink/site/news/2013/10/21/cikm2013-paper.html
URL: http://svn.apache.org/viewvc/incubator/flink/site/news/2013/10/21/cikm2013-paper.html?rev=1635454&r1=1635453&r2=1635454&view=diff
==============================================================================
--- incubator/flink/site/news/2013/10/21/cikm2013-paper.html (original)
+++ incubator/flink/site/news/2013/10/21/cikm2013-paper.html Thu Oct 30 10:22:07 2014
@@ -55,13 +55,13 @@
<a href="#" class="dropdown-toggle" data-toggle="dropdown">Documentation <b class="caret"></b></a>
<ul class="dropdown-menu">
<li role="presentation" class="dropdown-header">Current Stable:</li>
+ <li><a href="/docs/0.7-incubating/">0.7.0-incubating</a></li>
+ <li><a href="/docs/0.7-incubating/api/java">0.7.0-incubating Javadocs</a></li>
+ <li><a href="/docs/0.7-incubating/api/scala/index.html#org.apache.flink.api.scala.package">0.7.0-incubating Scaladocs</a></li>
+ <li class="divider"></li>
+ <li role="presentation" class="dropdown-header">Previous:</li>
<li><a href="/docs/0.6-incubating/">0.6-incubating</a></li>
<li><a href="/docs/0.6-incubating/api/java">0.6-incubating Javadocs</a></li>
- <li class="divider"></li>
- <li role="presentation" class="dropdown-header">Beta Preview:</li>
- <li><a href="/docs/0.7-incubating/">0.7-incubating</a></li>
- <li><a href="/docs/0.7-incubating/api/java">0.7-incubating Javadocs</a></li>
- <li><a href="/docs/0.7-incubating/api/scala/index.html#org.apache.flink.api.scala.package">0.7-incubating Scaladocs</a></li>
</ul>
</li>
@@ -195,7 +195,7 @@ in the majority of cases.</p>
<div class="footer">
-<hr class="divider">
+<p><hr class="divider"></p>
<p><small>Apache Flink is an effort undergoing incubation at The Apache Software
Foundation (ASF), sponsored by the Apache Incubator PMC. Incubation is