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/11/04 13:21:34 UTC
svn commit: r1636557 [2/2] - in /incubator/flink: ./ site/ site/blog/
site/blog/page2/ site/docs/0.6-incubating/ 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/ sit...
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=1636557&r1=1636556&r2=1636557&view=diff
==============================================================================
--- incubator/flink/site/docs/0.7-incubating/programming_guide.html (original)
+++ incubator/flink/site/docs/0.7-incubating/programming_guide.html Tue Nov 4 12:21:32 2014
@@ -120,12 +120,7 @@
<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> <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="#specifying-keys">Specifying Keys</a></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>
@@ -248,7 +243,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-incubating</code></pre></div>
+ -DarchetypeVersion<span class="o">=</span>0.7.0-incubating</code></pre></div>
</div>
<div data-lang="scala">
@@ -256,7 +251,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-incubating</code></pre></div>
+ -DarchetypeVersion<span class="o">=</span>0.7.0-incubating</code></pre></div>
</div>
</div>
@@ -270,12 +265,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-incubating<span class="nt"></version></span>
+ <span class="nt"><version></span>0.7.0-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-incubating<span class="nt"></version></span>
+ <span class="nt"><version></span>0.7.0-incubating<span class="nt"></version></span>
<span class="nt"></dependency></span></code></pre></div>
</div>
@@ -284,12 +279,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-incubating<span class="nt"></version></span>
+ <span class="nt"><version></span>0.7.0-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-incubating<span class="nt"></version></span>
+ <span class="nt"><version></span>0.7.0-incubating<span class="nt"></version></span>
<span class="nt"></dependency></span></code></pre></div>
</div>
@@ -816,7 +811,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 a `TraversableOnce` and can produce an arbitrary number of result values. The number of
+ as an `Iterator` 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>
@@ -985,7 +980,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 id="define-keys-for-tuples">Define keys for Tuples</h3>
+ <h3 class="no_toc" 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>
@@ -1014,7 +1009,8 @@ 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 id="define-key-using-a-string-expression">Define key using a String Expression</h3>
+ <h3 class="no_toc" 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>
@@ -1077,7 +1073,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 id="define-key-using-a-key-selector-function">Define key using a Key Selector Function</h3>
+ <h3 class="no_toc" 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
@@ -1138,59 +1134,127 @@ 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>
- <p>The simplest case is grouping a data set of Case Classes on one or more
-of itâs fields:</p>
+ <h3 class="no_toc" id="define-keys-for-tuples-1">Define keys for Tuples</h3>
- <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>
+ <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>
<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="s">"word"</span><span class="o">)</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">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 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>
+ <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>
- <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>
+ <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>
<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="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>
+ <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>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>
+ <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>As a special case, fields of Tuple DataSets can also be specified by (zero-based) index:</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">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">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>
- <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>
+ <p><strong>Valid Expressions</strong>:</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><strong>Example for nested POJO</strong></p>
+
+ <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>
<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">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>
+<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>
<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 object</span>
+ <div class="highlight"><pre><code class="language-scala" data-lang="scala"><span class="c1">// some case class</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="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>
+<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>
</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=1636557&r1=1636556&r2=1636557&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 Tue Nov 4 12:21:32 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-incubating</code></pre></div>
+ -DarchetypeVersion<span class="o">=</span>0.7.0-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=1636557&r1=1636556&r2=1636557&view=diff
==============================================================================
--- incubator/flink/site/docs/0.7-incubating/setup_quickstart.html (original)
+++ incubator/flink/site/docs/0.7-incubating/setup_quickstart.html Tue Nov 4 12:21:32 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-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.0-incubating/flink-0.7.0-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-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.0-incubating/flink-0.7.0-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-incubating-WordCount.jar <span class="se">\</span>
+ --jarfile ./examples/flink-java-examples-0.7.0-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-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.0-incubating/flink-0.7.0-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=1636557&r1=1636556&r2=1636557&view=diff
==============================================================================
--- incubator/flink/site/docs/0.7-incubating/spargel_guide.html (original)
+++ incubator/flink/site/docs/0.7-incubating/spargel_guide.html Tue Nov 4 12:21:32 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-incubating<span class="nt"></version></span>
+ <span class="nt"><version></span>0.7.0-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=1636557&r1=1636556&r2=1636557&view=diff
==============================================================================
--- incubator/flink/site/docs/0.7-incubating/streaming_guide.html (original)
+++ incubator/flink/site/docs/0.7-incubating/streaming_guide.html Tue Nov 4 12:21:32 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-incubating<span class="nt"></version></span>
+ <span class="nt"><version></span>0.7.0-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=1636557&r1=1636556&r2=1636557&view=diff
==============================================================================
--- incubator/flink/site/docs/0.7-incubating/yarn_setup.html (original)
+++ incubator/flink/site/docs/0.7-incubating/yarn_setup.html Tue Nov 4 12:21:32 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://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/
+<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/
./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-incubating-bin-hadoop
<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="/docs/0.5/general/faq.html">FAQ section</a>.</p>
+<p>If you have troubles using the Flink YARN client, have a look in the <a href="faq.html">FAQ section</a>.</p>
<h3 id="start-flink-session">Start Flink Session</h3>
@@ -161,14 +161,14 @@ tar xvzf flink-0.7-incubating-bin-hadoop
<h4 id="download-flink-for-yarn">Download Flink for YARN</h4>
-<p>Download the YARN tgz package on the <a href="/downloads/">download page</a>. It contains the required files.</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>
+<p>Download the YARN tgz package on the <a href="/downloads.html">download page</a>. It contains the required files.</p>
<p>Extract the package using:</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>
+<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>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>
<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-incubating-WordCount.jar <span class="se">\</span>
+./bin/flink run -j ./examples/flink-java-examples-0.7.0-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,6 +311,7 @@ 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=1636557&r1=1636556&r2=1636557&view=diff
==============================================================================
--- incubator/flink/site/downloads.html (original)
+++ incubator/flink/site/downloads.html Tue Nov 4 12:21:32 2014
@@ -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=1636557&r1=1636556&r2=1636557&view=diff
==============================================================================
--- incubator/flink/site/how-to-contribute.html (original)
+++ incubator/flink/site/how-to-contribute.html Tue Nov 4 12:21:32 2014
@@ -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=1636557&r1=1636556&r2=1636557&view=diff
==============================================================================
--- incubator/flink/site/index.html (original)
+++ incubator/flink/site/index.html Tue Nov 4 12:21:32 2014
@@ -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=1636557&r1=1636556&r2=1636557&view=diff
==============================================================================
--- incubator/flink/site/material.html (original)
+++ incubator/flink/site/material.html Tue Nov 4 12:21:32 2014
@@ -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=1636557&r1=1636556&r2=1636557&view=diff
==============================================================================
--- incubator/flink/site/news/2012/08/21/release02.html (original)
+++ incubator/flink/site/news/2012/08/21/release02.html Tue Nov 4 12:21:32 2014
@@ -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=1636557&r1=1636556&r2=1636557&view=diff
==============================================================================
--- incubator/flink/site/news/2012/10/15/icde2013.html (original)
+++ incubator/flink/site/news/2012/10/15/icde2013.html Tue Nov 4 12:21:32 2014
@@ -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=1636557&r1=1636556&r2=1636557&view=diff
==============================================================================
--- incubator/flink/site/news/2012/11/12/btw2013demo.html (original)
+++ incubator/flink/site/news/2012/11/12/btw2013demo.html Tue Nov 4 12:21:32 2014
@@ -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=1636557&r1=1636556&r2=1636557&view=diff
==============================================================================
--- incubator/flink/site/news/2012/11/21/previewICDE2013.html (original)
+++ incubator/flink/site/news/2012/11/21/previewICDE2013.html Tue Nov 4 12:21:32 2014
@@ -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=1636557&r1=1636556&r2=1636557&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 Tue Nov 4 12:21:32 2014
@@ -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=1636557&r1=1636556&r2=1636557&view=diff
==============================================================================
--- incubator/flink/site/news/2013/10/21/cikm2013-paper.html (original)
+++ incubator/flink/site/news/2013/10/21/cikm2013-paper.html Tue Nov 4 12:21:32 2014
@@ -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
Modified: incubator/flink/site/news/2013/12/13/humboldt-innovation-award.html
URL: http://svn.apache.org/viewvc/incubator/flink/site/news/2013/12/13/humboldt-innovation-award.html?rev=1636557&r1=1636556&r2=1636557&view=diff
==============================================================================
--- incubator/flink/site/news/2013/12/13/humboldt-innovation-award.html (original)
+++ incubator/flink/site/news/2013/12/13/humboldt-innovation-award.html Tue Nov 4 12:21:32 2014
@@ -167,7 +167,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/2014/01/10/stratosphere-hadoop-summit.html
URL: http://svn.apache.org/viewvc/incubator/flink/site/news/2014/01/10/stratosphere-hadoop-summit.html?rev=1636557&r1=1636556&r2=1636557&view=diff
==============================================================================
--- incubator/flink/site/news/2014/01/10/stratosphere-hadoop-summit.html (original)
+++ incubator/flink/site/news/2014/01/10/stratosphere-hadoop-summit.html Tue Nov 4 12:21:32 2014
@@ -156,7 +156,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/2014/01/12/0.4-migration-guide.html
URL: http://svn.apache.org/viewvc/incubator/flink/site/news/2014/01/12/0.4-migration-guide.html?rev=1636557&r1=1636556&r2=1636557&view=diff
==============================================================================
--- incubator/flink/site/news/2014/01/12/0.4-migration-guide.html (original)
+++ incubator/flink/site/news/2014/01/12/0.4-migration-guide.html Tue Nov 4 12:21:32 2014
@@ -233,7 +233,7 @@ For a complete overview of the renamings
<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/2014/01/13/stratosphere-release-0.4.html
URL: http://svn.apache.org/viewvc/incubator/flink/site/news/2014/01/13/stratosphere-release-0.4.html?rev=1636557&r1=1636556&r2=1636557&view=diff
==============================================================================
--- incubator/flink/site/news/2014/01/13/stratosphere-release-0.4.html (original)
+++ incubator/flink/site/news/2014/01/13/stratosphere-release-0.4.html Tue Nov 4 12:21:32 2014
@@ -236,7 +236,7 @@ Follow <a href="/docs/0.4/setup/yarn.htm
<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/2014/01/26/optimizer_plan_visualization_tool.html
URL: http://svn.apache.org/viewvc/incubator/flink/site/news/2014/01/26/optimizer_plan_visualization_tool.html?rev=1636557&r1=1636556&r2=1636557&view=diff
==============================================================================
--- incubator/flink/site/news/2014/01/26/optimizer_plan_visualization_tool.html (original)
+++ incubator/flink/site/news/2014/01/26/optimizer_plan_visualization_tool.html Tue Nov 4 12:21:32 2014
@@ -171,7 +171,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/2014/01/28/querying_mongodb.html
URL: http://svn.apache.org/viewvc/incubator/flink/site/news/2014/01/28/querying_mongodb.html?rev=1636557&r1=1636556&r2=1636557&view=diff
==============================================================================
--- incubator/flink/site/news/2014/01/28/querying_mongodb.html (original)
+++ incubator/flink/site/news/2014/01/28/querying_mongodb.html Tue Nov 4 12:21:32 2014
@@ -239,7 +239,7 @@ You can now press the "Run" bu
<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/2014/02/18/amazon-elastic-mapreduce-cloud-yarn.html
URL: http://svn.apache.org/viewvc/incubator/flink/site/news/2014/02/18/amazon-elastic-mapreduce-cloud-yarn.html?rev=1636557&r1=1636556&r2=1636557&view=diff
==============================================================================
--- incubator/flink/site/news/2014/02/18/amazon-elastic-mapreduce-cloud-yarn.html (original)
+++ incubator/flink/site/news/2014/02/18/amazon-elastic-mapreduce-cloud-yarn.html Tue Nov 4 12:21:32 2014
@@ -346,7 +346,7 @@ Inspect the result in HDFS using:</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/news/2014/02/24/stratosphere-google-summer-of-code-2014.html
URL: http://svn.apache.org/viewvc/incubator/flink/site/news/2014/02/24/stratosphere-google-summer-of-code-2014.html?rev=1636557&r1=1636556&r2=1636557&view=diff
==============================================================================
--- incubator/flink/site/news/2014/02/24/stratosphere-google-summer-of-code-2014.html (original)
+++ incubator/flink/site/news/2014/02/24/stratosphere-google-summer-of-code-2014.html Tue Nov 4 12:21:32 2014
@@ -163,7 +163,7 @@ Applying students can use our wiki (crea
<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/2014/04/16/stratosphere-goes-apache-incubator.html
URL: http://svn.apache.org/viewvc/incubator/flink/site/news/2014/04/16/stratosphere-goes-apache-incubator.html?rev=1636557&r1=1636556&r2=1636557&view=diff
==============================================================================
--- incubator/flink/site/news/2014/04/16/stratosphere-goes-apache-incubator.html (original)
+++ incubator/flink/site/news/2014/04/16/stratosphere-goes-apache-incubator.html Tue Nov 4 12:21:32 2014
@@ -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/news/2014/05/31/release-0.5.html
URL: http://svn.apache.org/viewvc/incubator/flink/site/news/2014/05/31/release-0.5.html?rev=1636557&r1=1636556&r2=1636557&view=diff
==============================================================================
--- incubator/flink/site/news/2014/05/31/release-0.5.html (original)
+++ incubator/flink/site/news/2014/05/31/release-0.5.html Tue Nov 4 12:21:32 2014
@@ -237,7 +237,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/2014/08/26/release-0.6.html
URL: http://svn.apache.org/viewvc/incubator/flink/site/news/2014/08/26/release-0.6.html?rev=1636557&r1=1636556&r2=1636557&view=diff
==============================================================================
--- incubator/flink/site/news/2014/08/26/release-0.6.html (original)
+++ incubator/flink/site/news/2014/08/26/release-0.6.html Tue Nov 4 12:21:32 2014
@@ -230,7 +230,7 @@ robust, as well as breaking API changes.
<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/2014/09/26/release-0.6.1.html
URL: http://svn.apache.org/viewvc/incubator/flink/site/news/2014/09/26/release-0.6.1.html?rev=1636557&r1=1636556&r2=1636557&view=diff
==============================================================================
--- incubator/flink/site/news/2014/09/26/release-0.6.1.html (original)
+++ incubator/flink/site/news/2014/09/26/release-0.6.1.html Tue Nov 4 12:21:32 2014
@@ -161,7 +161,7 @@ of the system. We suggest all users of F
<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/2014/10/03/upcoming_events.html
URL: http://svn.apache.org/viewvc/incubator/flink/site/news/2014/10/03/upcoming_events.html?rev=1636557&r1=1636556&r2=1636557&view=diff
==============================================================================
--- incubator/flink/site/news/2014/10/03/upcoming_events.html (original)
+++ incubator/flink/site/news/2014/10/03/upcoming_events.html Tue Nov 4 12:21:32 2014
@@ -229,7 +229,7 @@ properties, some algorithms)</p></li>
<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/2014/11/04/release-0.7.0.html
URL: http://svn.apache.org/viewvc/incubator/flink/site/news/2014/11/04/release-0.7.0.html?rev=1636557&r1=1636556&r2=1636557&view=diff
==============================================================================
--- incubator/flink/site/news/2014/11/04/release-0.7.0.html (original)
+++ incubator/flink/site/news/2014/11/04/release-0.7.0.html Tue Nov 4 12:21:32 2014
@@ -219,7 +219,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/privacy-policy.html
URL: http://svn.apache.org/viewvc/incubator/flink/site/privacy-policy.html?rev=1636557&r1=1636556&r2=1636557&view=diff
==============================================================================
--- incubator/flink/site/privacy-policy.html (original)
+++ incubator/flink/site/privacy-policy.html Tue Nov 4 12:21:32 2014
@@ -141,7 +141,7 @@ manner and for the purpose described abo
<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/project.html
URL: http://svn.apache.org/viewvc/incubator/flink/site/project.html?rev=1636557&r1=1636556&r2=1636557&view=diff
==============================================================================
--- incubator/flink/site/project.html (original)
+++ incubator/flink/site/project.html Tue Nov 4 12:21:32 2014
@@ -121,7 +121,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