http://git-wip-us.apache.org/repos/asf/flink-web/blob/c3e5f146/content/news/2015/04/07/march-in-flink.html ---------------------------------------------------------------------- diff --git a/content/news/2015/04/07/march-in-flink.html b/content/news/2015/04/07/march-in-flink.html index dbb3544..fc9eb19 100644 --- a/content/news/2015/04/07/march-in-flink.html +++ b/content/news/2015/04/07/march-in-flink.html @@ -38,7 +38,7 @@ <span class="icon-bar"></span> </button> <div class="navbar-logo"> - <a href="/"><img alt="Apache Flink" src="/img/navbar-brand-logo.jpg" width="78px" height="40px"></a> + <img alt="Apache Flink" src="/img/navbar-brand-logo.jpg" width="78px" height="40px"> </div> </div><!-- /.navbar-header --> @@ -50,7 +50,7 @@ <!-- Quickstart --> <li class="dropdown"> - <a href="#" class="dropdown-toggle" data-toggle="dropdown" role="button" aria-expanded="false">Quickstart <span class="caret"></span></a> + <a href="#" class="dropdown-toggle" data-toggle="dropdown" role="button" aria-expanded="false"><small><span class="glyphicon glyphicon-new-window"></span></small> Quickstart <span class="caret"></span></a> <ul class="dropdown-menu" role="menu"> <li><a href="http://ci.apache.org/projects/flink/flink-docs-release-0.9/quickstart/setup_quickstart.html";>Setup</a></li> <li><a href="http://ci.apache.org/projects/flink/flink-docs-release-0.9/quickstart/java_api_quickstart.html";>Java API</a></li> @@ -67,7 +67,7 @@ <!-- Documentation --> <li class="dropdown"> - <a href="" class="dropdown-toggle" data-toggle="dropdown" role="button" aria-expanded="false">Documentation <span class="caret"></span></a> + <a href="" class="dropdown-toggle" data-toggle="dropdown" role="button" aria-expanded="false"><small><span class="glyphicon glyphicon-new-window"></span></small> Documentation <span class="caret"></span></a> <ul class="dropdown-menu" role="menu"> <!-- Latest stable release --> <li role="presentation" class="dropdown-header"><strong>Latest Release</strong> (Stable)</li> @@ -84,7 +84,7 @@ <!-- Wiki --> <li class="divider"></li> - <li><a href="https://cwiki.apache.org/confluence/display/FLINK/Apache+Flink+Home";><small><span class="glyphicon glyphicon-new-window"></span></small> Wiki</a></li> + <li><a href="https://cwiki.apache.org/confluence/display/FLINK/Apache+Flink+Home";>Wiki</a></li> </ul> </li> @@ -105,6 +105,7 @@ <li><a href="/community.html#irc">IRC</a></li> <li><a href="/community.html#stack-overflow">Stack Overflow</a></li> <li><a href="/community.html#issue-tracker">Issue Tracker</a></li> + <li><a href="/community.html#third-party-packages">Third Party Packages</a></li> <li><a href="/community.html#source-code">Source Code</a></li> <li><a href="/community.html#people">People</a></li>
http://git-wip-us.apache.org/repos/asf/flink-web/blob/c3e5f146/content/news/2015/04/13/release-0.9.0-milestone1.html ---------------------------------------------------------------------- diff --git a/content/news/2015/04/13/release-0.9.0-milestone1.html b/content/news/2015/04/13/release-0.9.0-milestone1.html index 56cfd10..c3c8bf2 100644 --- a/content/news/2015/04/13/release-0.9.0-milestone1.html +++ b/content/news/2015/04/13/release-0.9.0-milestone1.html @@ -38,7 +38,7 @@ <span class="icon-bar"></span> </button> <div class="navbar-logo"> - <a href="/"><img alt="Apache Flink" src="/img/navbar-brand-logo.jpg" width="78px" height="40px"></a> + <img alt="Apache Flink" src="/img/navbar-brand-logo.jpg" width="78px" height="40px"> </div> </div><!-- /.navbar-header --> @@ -50,7 +50,7 @@ <!-- Quickstart --> <li class="dropdown"> - <a href="#" class="dropdown-toggle" data-toggle="dropdown" role="button" aria-expanded="false">Quickstart <span class="caret"></span></a> + <a href="#" class="dropdown-toggle" data-toggle="dropdown" role="button" aria-expanded="false"><small><span class="glyphicon glyphicon-new-window"></span></small> Quickstart <span class="caret"></span></a> <ul class="dropdown-menu" role="menu"> <li><a href="http://ci.apache.org/projects/flink/flink-docs-release-0.9/quickstart/setup_quickstart.html";>Setup</a></li> <li><a href="http://ci.apache.org/projects/flink/flink-docs-release-0.9/quickstart/java_api_quickstart.html";>Java API</a></li> @@ -67,7 +67,7 @@ <!-- Documentation --> <li class="dropdown"> - <a href="" class="dropdown-toggle" data-toggle="dropdown" role="button" aria-expanded="false">Documentation <span class="caret"></span></a> + <a href="" class="dropdown-toggle" data-toggle="dropdown" role="button" aria-expanded="false"><small><span class="glyphicon glyphicon-new-window"></span></small> Documentation <span class="caret"></span></a> <ul class="dropdown-menu" role="menu"> <!-- Latest stable release --> <li role="presentation" class="dropdown-header"><strong>Latest Release</strong> (Stable)</li> @@ -84,7 +84,7 @@ <!-- Wiki --> <li class="divider"></li> - <li><a href="https://cwiki.apache.org/confluence/display/FLINK/Apache+Flink+Home";><small><span class="glyphicon glyphicon-new-window"></span></small> Wiki</a></li> + <li><a href="https://cwiki.apache.org/confluence/display/FLINK/Apache+Flink+Home";>Wiki</a></li> </ul> </li> @@ -105,6 +105,7 @@ <li><a href="/community.html#irc">IRC</a></li> <li><a href="/community.html#stack-overflow">Stack Overflow</a></li> <li><a href="/community.html#issue-tracker">Issue Tracker</a></li> + <li><a href="/community.html#third-party-packages">Third Party Packages</a></li> <li><a href="/community.html#source-code">Source Code</a></li> <li><a href="/community.html#people">People</a></li> http://git-wip-us.apache.org/repos/asf/flink-web/blob/c3e5f146/content/news/2015/05/11/Juggling-with-Bits-and-Bytes.html ---------------------------------------------------------------------- diff --git a/content/news/2015/05/11/Juggling-with-Bits-and-Bytes.html b/content/news/2015/05/11/Juggling-with-Bits-and-Bytes.html index b02e679..7c2b53f 100644 --- a/content/news/2015/05/11/Juggling-with-Bits-and-Bytes.html +++ b/content/news/2015/05/11/Juggling-with-Bits-and-Bytes.html @@ -38,7 +38,7 @@ <span class="icon-bar"></span> </button> <div class="navbar-logo"> - <a href="/"><img alt="Apache Flink" src="/img/navbar-brand-logo.jpg" width="78px" height="40px"></a> + <img alt="Apache Flink" src="/img/navbar-brand-logo.jpg" width="78px" height="40px"> </div> </div><!-- /.navbar-header --> @@ -50,7 +50,7 @@ <!-- Quickstart --> <li class="dropdown"> - <a href="#" class="dropdown-toggle" data-toggle="dropdown" role="button" aria-expanded="false">Quickstart <span class="caret"></span></a> + <a href="#" class="dropdown-toggle" data-toggle="dropdown" role="button" aria-expanded="false"><small><span class="glyphicon glyphicon-new-window"></span></small> Quickstart <span class="caret"></span></a> <ul class="dropdown-menu" role="menu"> <li><a href="http://ci.apache.org/projects/flink/flink-docs-release-0.9/quickstart/setup_quickstart.html";>Setup</a></li> <li><a href="http://ci.apache.org/projects/flink/flink-docs-release-0.9/quickstart/java_api_quickstart.html";>Java API</a></li> @@ -67,7 +67,7 @@ <!-- Documentation --> <li class="dropdown"> - <a href="" class="dropdown-toggle" data-toggle="dropdown" role="button" aria-expanded="false">Documentation <span class="caret"></span></a> + <a href="" class="dropdown-toggle" data-toggle="dropdown" role="button" aria-expanded="false"><small><span class="glyphicon glyphicon-new-window"></span></small> Documentation <span class="caret"></span></a> <ul class="dropdown-menu" role="menu"> <!-- Latest stable release --> <li role="presentation" class="dropdown-header"><strong>Latest Release</strong> (Stable)</li> @@ -84,7 +84,7 @@ <!-- Wiki --> <li class="divider"></li> - <li><a href="https://cwiki.apache.org/confluence/display/FLINK/Apache+Flink+Home";><small><span class="glyphicon glyphicon-new-window"></span></small> Wiki</a></li> + <li><a href="https://cwiki.apache.org/confluence/display/FLINK/Apache+Flink+Home";>Wiki</a></li> </ul> </li> @@ -105,6 +105,7 @@ <li><a href="/community.html#irc">IRC</a></li> <li><a href="/community.html#stack-overflow">Stack Overflow</a></li> <li><a href="/community.html#issue-tracker">Issue Tracker</a></li> + <li><a href="/community.html#third-party-packages">Third Party Packages</a></li> <li><a href="/community.html#source-code">Source Code</a></li> <li><a href="/community.html#people">People</a></li> http://git-wip-us.apache.org/repos/asf/flink-web/blob/c3e5f146/content/news/2015/05/14/Community-update-April.html ---------------------------------------------------------------------- diff --git a/content/news/2015/05/14/Community-update-April.html b/content/news/2015/05/14/Community-update-April.html index ec9c204..141fd7b 100644 --- a/content/news/2015/05/14/Community-update-April.html +++ b/content/news/2015/05/14/Community-update-April.html @@ -38,7 +38,7 @@ <span class="icon-bar"></span> </button> <div class="navbar-logo"> - <a href="/"><img alt="Apache Flink" src="/img/navbar-brand-logo.jpg" width="78px" height="40px"></a> + <img alt="Apache Flink" src="/img/navbar-brand-logo.jpg" width="78px" height="40px"> </div> </div><!-- /.navbar-header --> @@ -50,7 +50,7 @@ <!-- Quickstart --> <li class="dropdown"> - <a href="#" class="dropdown-toggle" data-toggle="dropdown" role="button" aria-expanded="false">Quickstart <span class="caret"></span></a> + <a href="#" class="dropdown-toggle" data-toggle="dropdown" role="button" aria-expanded="false"><small><span class="glyphicon glyphicon-new-window"></span></small> Quickstart <span class="caret"></span></a> <ul class="dropdown-menu" role="menu"> <li><a href="http://ci.apache.org/projects/flink/flink-docs-release-0.9/quickstart/setup_quickstart.html";>Setup</a></li> <li><a href="http://ci.apache.org/projects/flink/flink-docs-release-0.9/quickstart/java_api_quickstart.html";>Java API</a></li> @@ -67,7 +67,7 @@ <!-- Documentation --> <li class="dropdown"> - <a href="" class="dropdown-toggle" data-toggle="dropdown" role="button" aria-expanded="false">Documentation <span class="caret"></span></a> + <a href="" class="dropdown-toggle" data-toggle="dropdown" role="button" aria-expanded="false"><small><span class="glyphicon glyphicon-new-window"></span></small> Documentation <span class="caret"></span></a> <ul class="dropdown-menu" role="menu"> <!-- Latest stable release --> <li role="presentation" class="dropdown-header"><strong>Latest Release</strong> (Stable)</li> @@ -84,7 +84,7 @@ <!-- Wiki --> <li class="divider"></li> - <li><a href="https://cwiki.apache.org/confluence/display/FLINK/Apache+Flink+Home";><small><span class="glyphicon glyphicon-new-window"></span></small> Wiki</a></li> + <li><a href="https://cwiki.apache.org/confluence/display/FLINK/Apache+Flink+Home";>Wiki</a></li> </ul> </li> @@ -105,6 +105,7 @@ <li><a href="/community.html#irc">IRC</a></li> <li><a href="/community.html#stack-overflow">Stack Overflow</a></li> <li><a href="/community.html#issue-tracker">Issue Tracker</a></li> + <li><a href="/community.html#third-party-packages">Third Party Packages</a></li> <li><a href="/community.html#source-code">Source Code</a></li> <li><a href="/community.html#people">People</a></li> http://git-wip-us.apache.org/repos/asf/flink-web/blob/c3e5f146/content/news/2015/06/24/announcing-apache-flink-0.9.0-release.html ---------------------------------------------------------------------- diff --git a/content/news/2015/06/24/announcing-apache-flink-0.9.0-release.html b/content/news/2015/06/24/announcing-apache-flink-0.9.0-release.html index 6cc3e35..36173c8 100644 --- a/content/news/2015/06/24/announcing-apache-flink-0.9.0-release.html +++ b/content/news/2015/06/24/announcing-apache-flink-0.9.0-release.html @@ -38,7 +38,7 @@ <span class="icon-bar"></span> </button> <div class="navbar-logo"> - <a href="/"><img alt="Apache Flink" src="/img/navbar-brand-logo.jpg" width="78px" height="40px"></a> + <img alt="Apache Flink" src="/img/navbar-brand-logo.jpg" width="78px" height="40px"> </div> </div><!-- /.navbar-header --> @@ -50,7 +50,7 @@ <!-- Quickstart --> <li class="dropdown"> - <a href="#" class="dropdown-toggle" data-toggle="dropdown" role="button" aria-expanded="false">Quickstart <span class="caret"></span></a> + <a href="#" class="dropdown-toggle" data-toggle="dropdown" role="button" aria-expanded="false"><small><span class="glyphicon glyphicon-new-window"></span></small> Quickstart <span class="caret"></span></a> <ul class="dropdown-menu" role="menu"> <li><a href="http://ci.apache.org/projects/flink/flink-docs-release-0.9/quickstart/setup_quickstart.html";>Setup</a></li> <li><a href="http://ci.apache.org/projects/flink/flink-docs-release-0.9/quickstart/java_api_quickstart.html";>Java API</a></li> @@ -67,7 +67,7 @@ <!-- Documentation --> <li class="dropdown"> - <a href="" class="dropdown-toggle" data-toggle="dropdown" role="button" aria-expanded="false">Documentation <span class="caret"></span></a> + <a href="" class="dropdown-toggle" data-toggle="dropdown" role="button" aria-expanded="false"><small><span class="glyphicon glyphicon-new-window"></span></small> Documentation <span class="caret"></span></a> <ul class="dropdown-menu" role="menu"> <!-- Latest stable release --> <li role="presentation" class="dropdown-header"><strong>Latest Release</strong> (Stable)</li> @@ -84,7 +84,7 @@ <!-- Wiki --> <li class="divider"></li> - <li><a href="https://cwiki.apache.org/confluence/display/FLINK/Apache+Flink+Home";><small><span class="glyphicon glyphicon-new-window"></span></small> Wiki</a></li> + <li><a href="https://cwiki.apache.org/confluence/display/FLINK/Apache+Flink+Home";>Wiki</a></li> </ul> </li> @@ -105,6 +105,7 @@ <li><a href="/community.html#irc">IRC</a></li> <li><a href="/community.html#stack-overflow">Stack Overflow</a></li> <li><a href="/community.html#issue-tracker">Issue Tracker</a></li> + <li><a href="/community.html#third-party-packages">Third Party Packages</a></li> <li><a href="/community.html#source-code">Source Code</a></li> <li><a href="/community.html#people">People</a></li> http://git-wip-us.apache.org/repos/asf/flink-web/blob/c3e5f146/content/news/2015/08/24/introducing-flink-gelly.html ---------------------------------------------------------------------- diff --git a/content/news/2015/08/24/introducing-flink-gelly.html b/content/news/2015/08/24/introducing-flink-gelly.html index 41a5f35..b0855b8 100644 --- a/content/news/2015/08/24/introducing-flink-gelly.html +++ b/content/news/2015/08/24/introducing-flink-gelly.html @@ -38,7 +38,7 @@ <span class="icon-bar"></span> </button> <div class="navbar-logo"> - <a href="/"><img alt="Apache Flink" src="/img/navbar-brand-logo.jpg" width="78px" height="40px"></a> + <img alt="Apache Flink" src="/img/navbar-brand-logo.jpg" width="78px" height="40px"> </div> </div><!-- /.navbar-header --> @@ -50,7 +50,7 @@ <!-- Quickstart --> <li class="dropdown"> - <a href="#" class="dropdown-toggle" data-toggle="dropdown" role="button" aria-expanded="false">Quickstart <span class="caret"></span></a> + <a href="#" class="dropdown-toggle" data-toggle="dropdown" role="button" aria-expanded="false"><small><span class="glyphicon glyphicon-new-window"></span></small> Quickstart <span class="caret"></span></a> <ul class="dropdown-menu" role="menu"> <li><a href="http://ci.apache.org/projects/flink/flink-docs-release-0.9/quickstart/setup_quickstart.html";>Setup</a></li> <li><a href="http://ci.apache.org/projects/flink/flink-docs-release-0.9/quickstart/java_api_quickstart.html";>Java API</a></li> @@ -67,7 +67,7 @@ <!-- Documentation --> <li class="dropdown"> - <a href="" class="dropdown-toggle" data-toggle="dropdown" role="button" aria-expanded="false">Documentation <span class="caret"></span></a> + <a href="" class="dropdown-toggle" data-toggle="dropdown" role="button" aria-expanded="false"><small><span class="glyphicon glyphicon-new-window"></span></small> Documentation <span class="caret"></span></a> <ul class="dropdown-menu" role="menu"> <!-- Latest stable release --> <li role="presentation" class="dropdown-header"><strong>Latest Release</strong> (Stable)</li> @@ -84,7 +84,7 @@ <!-- Wiki --> <li class="divider"></li> - <li><a href="https://cwiki.apache.org/confluence/display/FLINK/Apache+Flink+Home";><small><span class="glyphicon glyphicon-new-window"></span></small> Wiki</a></li> + <li><a href="https://cwiki.apache.org/confluence/display/FLINK/Apache+Flink+Home";>Wiki</a></li> </ul> </li> @@ -105,6 +105,7 @@ <li><a href="/community.html#irc">IRC</a></li> <li><a href="/community.html#stack-overflow">Stack Overflow</a></li> <li><a href="/community.html#issue-tracker">Issue Tracker</a></li> + <li><a href="/community.html#third-party-packages">Third Party Packages</a></li> <li><a href="/community.html#source-code">Source Code</a></li> <li><a href="/community.html#people">People</a></li> @@ -220,7 +221,7 @@ of vertices, edges and the node degrees. </p> the ones provided by the batch processing API. These transformations can be applied one after the other, yielding a new Graph after each step, in a fashion similar to operators on DataSets: </p> -<div class="highlight"><pre><code class="language-java"><span class="n">inputGraph</span><span class="o">.</span><span class="na">getUndirected</span><span class="o">().</span><span class="na">mapEdges</span><span class="o">(</span><span class="k">new</span> <span class="nf">CustomEdgeMapper</span><span class="o">());</span></code></pre></div> +<div class="highlight"><pre><code class="language-java"><span class="n">inputGraph</span><span class="o">.</span><span class="na">getUndirected</span><span class="o">().</span><span class="na">mapEdges</span><span class="o">(</span><span class="k">new</span> <span class="n">CustomEdgeMapper</span><span class="o">());</span></code></pre></div> <p>Transformations can be applied on:</p> @@ -256,7 +257,7 @@ one or more values per vertex, the more general <code>groupReduceOnEdges()</cod <p>Assume you would want to compute the sum of the values of all incoming neighbors for each vertex. We will call the <code>reduceOnNeighbors()</code> aggregation method since the sum is an associative and commutative operation and the neighborsâ values are needed:</p> -<div class="highlight"><pre><code class="language-java"><span class="n">graph</span><span class="o">.</span><span class="na">reduceOnNeighbors</span><span class="o">(</span><span class="k">new</span> <span class="nf">SumValues</span><span class="o">(),</span> <span class="n">EdgeDirection</span><span class="o">.</span><span class="na">IN</span><span class="o">);</span></code></pre></div> +<div class="highlight"><pre><code class="language-java"><span class="n">graph</span><span class="o">.</span><span class="na">reduceOnNeighbors</span><span class="o">(</span><span class="k">new</span> <span class="n">SumValues</span><span class="o">(),</span> <span class="n">EdgeDirection</span><span class="o">.</span><span class="na">IN</span><span class="o">);</span></code></pre></div> <p>The vertex with id 1 is the only node that has no incoming edges. The result is therefore:</p> @@ -442,7 +443,7 @@ playlist, we use a coGroup function to filter out the mismatches.</p> <span class="c1">// read the mismatches dataset and extract the songIDs</span> <span class="n">DataSet</span><span class="o"><</span><span class="n">Tuple3</span><span class="o"><</span><span class="n">String</span><span class="o">,</span> <span class="n">String</span><span class="o">,</span> <span class="n">Integer</span><span class="o">>></span> <span class="n">validTriplets</span> <span class="o">=</span> <span class="n">triplets</span> <span class="o">.</span><span class="na">coGroup</span><span class="o">(</span><span class="n">mismatches</span><span class="o">).</span><span class="na">where</span><span class="o">(</span><span class="mi">1</span><span class="o">).</span><span class="na">equalTo</span><span class="o">(</span><span class="mi">0</span><span class="o">)</span> - <span class="o">.</span><span class="na">with</span><span class="o">(</span><span class="k">new</span> <span class="nf">CoGroupFunction</span><span class="o">()</span> <span class="o">{</span> + <span class="o">.</span><span class="na">with</span><span class="o">(</span><span class="k">new</span> <span class="n">CoGroupFunction</span><span class="o">()</span> <span class="o">{</span> <span class="kt">void</span> <span class="nf">coGroup</span><span class="o">(</span><span class="n">Iterable</span> <span class="n">triplets</span><span class="o">,</span> <span class="n">Iterable</span> <span class="n">invalidSongs</span><span class="o">,</span> <span class="n">Collector</span> <span class="n">out</span><span class="o">)</span> <span class="o">{</span> <span class="k">if</span> <span class="o">(!</span><span class="n">invalidSongs</span><span class="o">.</span><span class="na">iterator</span><span class="o">().</span><span class="na">hasNext</span><span class="o">())</span> <span class="o">{</span> <span class="k">for</span> <span class="o">(</span><span class="n">Tuple3</span> <span class="n">triplet</span> <span class="o">:</span> <span class="n">triplets</span><span class="o">)</span> <span class="o">{</span> <span class="c1">// valid triplet</span> @@ -480,7 +481,7 @@ basically iterate through the edge value and collect the target (song) of the ma <div class="highlight"><pre><code class="language-java"><span class="c1">//get the top track (most listened to) for each user</span> <span class="n">DataSet</span><span class="o"><</span><span class="n">Tuple2</span><span class="o">></span> <span class="n">usersWithTopTrack</span> <span class="o">=</span> <span class="n">userSongGraph</span> - <span class="o">.</span><span class="na">groupReduceOnEdges</span><span class="o">(</span><span class="k">new</span> <span class="nf">GetTopSongPerUser</span><span class="o">(),</span> <span class="n">EdgeDirection</span><span class="o">.</span><span class="na">OUT</span><span class="o">);</span> + <span class="o">.</span><span class="na">groupReduceOnEdges</span><span class="o">(</span><span class="k">new</span> <span class="n">GetTopSongPerUser</span><span class="o">(),</span> <span class="n">EdgeDirection</span><span class="o">.</span><span class="na">OUT</span><span class="o">);</span> <span class="kd">class</span> <span class="nc">GetTopSongPerUser</span> <span class="kd">implements</span> <span class="n">EdgesFunctionWithVertexValue</span> <span class="o">{</span> <span class="kt">void</span> <span class="nf">iterateEdges</span><span class="o">(</span><span class="n">Vertex</span> <span class="n">vertex</span><span class="o">,</span> <span class="n">Iterable</span><span class="o"><</span><span class="n">Edge</span><span class="o">></span> <span class="n">edges</span><span class="o">)</span> <span class="o">{</span> @@ -493,7 +494,7 @@ basically iterate through the edge value and collect the target (song) of the ma <span class="n">topSong</span> <span class="o">=</span> <span class="n">edge</span><span class="o">.</span><span class="na">getTarget</span><span class="o">();</span> <span class="o">}</span> <span class="o">}</span> - <span class="k">return</span> <span class="k">new</span> <span class="nf">Tuple2</span><span class="o">(</span><span class="n">vertex</span><span class="o">.</span><span class="na">getId</span><span class="o">(),</span> <span class="n">topSong</span><span class="o">);</span> + <span class="k">return</span> <span class="k">new</span> <span class="n">Tuple2</span><span class="o">(</span><span class="n">vertex</span><span class="o">.</span><span class="na">getId</span><span class="o">(),</span> <span class="n">topSong</span><span class="o">);</span> <span class="o">}</span> <span class="o">}</span></code></pre></div> @@ -529,14 +530,14 @@ straightforward as a call to the <code>Graph.fromDataSet()</code> method.</p> <span class="o">}</span> <span class="o">})</span> <span class="o">.</span><span class="na">groupBy</span><span class="o">(</span><span class="mi">1</span><span class="o">)</span> - <span class="o">.</span><span class="na">reduceGroup</span><span class="o">(</span><span class="k">new</span> <span class="nf">GroupReduceFunction</span><span class="o">()</span> <span class="o">{</span> + <span class="o">.</span><span class="na">reduceGroup</span><span class="o">(</span><span class="k">new</span> <span class="n">GroupReduceFunction</span><span class="o">()</span> <span class="o">{</span> <span class="kt">void</span> <span class="nf">reduce</span><span class="o">(</span><span class="n">Iterable</span><span class="o"><</span><span class="n">Edge</span><span class="o">></span> <span class="n">edges</span><span class="o">,</span> <span class="n">Collector</span><span class="o"><</span><span class="n">Edge</span><span class="o">></span> <span class="n">out</span><span class="o">)</span> <span class="o">{</span> - <span class="n">List</span> <span class="n">users</span> <span class="o">=</span> <span class="k">new</span> <span class="nf">ArrayList</span><span class="o">();</span> + <span class="n">List</span> <span class="n">users</span> <span class="o">=</span> <span class="k">new</span> <span class="n">ArrayList</span><span class="o">();</span> <span class="k">for</span> <span class="o">(</span><span class="n">Edge</span> <span class="n">edge</span> <span class="o">:</span> <span class="n">edges</span><span class="o">)</span> <span class="o">{</span> <span class="n">users</span><span class="o">.</span><span class="na">add</span><span class="o">(</span><span class="n">edge</span><span class="o">.</span><span class="na">getSource</span><span class="o">());</span> <span class="k">for</span> <span class="o">(</span><span class="kt">int</span> <span class="n">i</span> <span class="o">=</span> <span class="mi">0</span><span class="o">;</span> <span class="n">i</span> <span class="o"><</span> <span class="n">users</span><span class="o">.</span><span class="na">size</span><span class="o">()</span> <span class="o">-</span> <span class="mi">1</span><span class="o">;</span> <span class="n">i</span><span class="o">++)</span> <span class="o">{</span> <span class="k">for</span> <span class="o">(</span><span class="kt">int</span> <span class="n">j</span> <span class="o">=</span> <span class="n">i</span><span class="o">+</span><span class="mi">1</span><span class="o">;</span> <span class="n">j</span> <span class="o"><</span> <span class="n">users</span><span class="o">.</span><span class="na">size</span><span class="o">()</span> <span class="o">-</span> <span class="mi">1</span><span class="o">;</span> <span class="n">j</span><span class="o">++)</span> <span class="o">{</span> - <span class="n">out</span><span class="o">.</span><span class="na">collect</span><span class="o">(</span><span class="k">new</span> <span class="nf">Edge</span><span class="o">(</span><span class="n">users</span><span class="o">.</span><span class="na">get</span><span class="o">(</span><span class="n">i</span><span class="o">),</span> <span class="n">users</span><span class="o">.</span><span class="na">get</span><span class="o">(</span><span class="n">j</span><span class="o">)));</span> + <span class="n">out</span><span class="o">.</span><span class="na">collect</span><span class="o">(</span><span class="k">new</span> <span class="n">Edge</span><span class="o">(</span><span class="n">users</span><span class="o">.</span><span class="na">get</span><span class="o">(</span><span class="n">i</span><span class="o">),</span> <span class="n">users</span><span class="o">.</span><span class="na">get</span><span class="o">(</span><span class="n">j</span><span class="o">)));</span> <span class="o">}</span> <span class="o">}</span> <span class="o">}</span> @@ -567,12 +568,12 @@ among their neighbors. </p> <span class="c1">// update the vertex values and run the label propagation algorithm</span> <span class="n">DataSet</span><span class="o"><</span><span class="n">Vertex</span><span class="o">></span> <span class="n">verticesWithCommunity</span> <span class="o">=</span> <span class="n">similarUsersGraph</span> - <span class="o">.</span><span class="na">joinWithVertices</span><span class="o">(</span><span class="n">idsWithlLabels</span><span class="o">,</span> <span class="k">new</span> <span class="nf">MapFunction</span><span class="o">()</span> <span class="o">{</span> + <span class="o">.</span><span class="na">joinWithVertices</span><span class="o">(</span><span class="n">idsWithlLabels</span><span class="o">,</span> <span class="k">new</span> <span class="n">MapFunction</span><span class="o">()</span> <span class="o">{</span> <span class="kd">public</span> <span class="n">Long</span> <span class="nf">map</span><span class="o">(</span><span class="n">Tuple2</span> <span class="n">idWithLabel</span><span class="o">)</span> <span class="o">{</span> <span class="k">return</span> <span class="n">idWithLabel</span><span class="o">.</span><span class="na">f1</span><span class="o">;</span> <span class="o">}</span> <span class="o">})</span> - <span class="o">.</span><span class="na">run</span><span class="o">(</span><span class="k">new</span> <span class="nf">LabelPropagation</span><span class="o">(</span><span class="n">numIterations</span><span class="o">))</span> + <span class="o">.</span><span class="na">run</span><span class="o">(</span><span class="k">new</span> <span class="n">LabelPropagation</span><span class="o">(</span><span class="n">numIterations</span><span class="o">))</span> <span class="o">.</span><span class="na">getVertices</span><span class="o">();</span></code></pre></div> <p><a href="#top">Back to top</a></p> http://git-wip-us.apache.org/repos/asf/flink-web/blob/c3e5f146/content/news/2015/09/01/release-0.9.1.html ---------------------------------------------------------------------- diff --git a/content/news/2015/09/01/release-0.9.1.html b/content/news/2015/09/01/release-0.9.1.html index f8246b9..73b959c 100644 --- a/content/news/2015/09/01/release-0.9.1.html +++ b/content/news/2015/09/01/release-0.9.1.html @@ -38,7 +38,7 @@ <span class="icon-bar"></span> </button> <div class="navbar-logo"> - <a href="/"><img alt="Apache Flink" src="/img/navbar-brand-logo.jpg" width="78px" height="40px"></a> + <img alt="Apache Flink" src="/img/navbar-brand-logo.jpg" width="78px" height="40px"> </div> </div><!-- /.navbar-header --> @@ -50,7 +50,7 @@ <!-- Quickstart --> <li class="dropdown"> - <a href="#" class="dropdown-toggle" data-toggle="dropdown" role="button" aria-expanded="false">Quickstart <span class="caret"></span></a> + <a href="#" class="dropdown-toggle" data-toggle="dropdown" role="button" aria-expanded="false"><small><span class="glyphicon glyphicon-new-window"></span></small> Quickstart <span class="caret"></span></a> <ul class="dropdown-menu" role="menu"> <li><a href="http://ci.apache.org/projects/flink/flink-docs-release-0.9/quickstart/setup_quickstart.html";>Setup</a></li> <li><a href="http://ci.apache.org/projects/flink/flink-docs-release-0.9/quickstart/java_api_quickstart.html";>Java API</a></li> @@ -67,7 +67,7 @@ <!-- Documentation --> <li class="dropdown"> - <a href="" class="dropdown-toggle" data-toggle="dropdown" role="button" aria-expanded="false">Documentation <span class="caret"></span></a> + <a href="" class="dropdown-toggle" data-toggle="dropdown" role="button" aria-expanded="false"><small><span class="glyphicon glyphicon-new-window"></span></small> Documentation <span class="caret"></span></a> <ul class="dropdown-menu" role="menu"> <!-- Latest stable release --> <li role="presentation" class="dropdown-header"><strong>Latest Release</strong> (Stable)</li> @@ -84,7 +84,7 @@ <!-- Wiki --> <li class="divider"></li> - <li><a href="https://cwiki.apache.org/confluence/display/FLINK/Apache+Flink+Home";><small><span class="glyphicon glyphicon-new-window"></span></small> Wiki</a></li> + <li><a href="https://cwiki.apache.org/confluence/display/FLINK/Apache+Flink+Home";>Wiki</a></li> </ul> </li> @@ -105,6 +105,7 @@ <li><a href="/community.html#irc">IRC</a></li> <li><a href="/community.html#stack-overflow">Stack Overflow</a></li> <li><a href="/community.html#issue-tracker">Issue Tracker</a></li> + <li><a href="/community.html#third-party-packages">Third Party Packages</a></li> <li><a href="/community.html#source-code">Source Code</a></li> <li><a href="/community.html#people">People</a></li> http://git-wip-us.apache.org/repos/asf/flink-web/blob/c3e5f146/content/news/2015/09/03/flink-forward.html ---------------------------------------------------------------------- diff --git a/content/news/2015/09/03/flink-forward.html b/content/news/2015/09/03/flink-forward.html index c4424c3..fdd53a7 100644 --- a/content/news/2015/09/03/flink-forward.html +++ b/content/news/2015/09/03/flink-forward.html @@ -38,7 +38,7 @@ <span class="icon-bar"></span> </button> <div class="navbar-logo"> - <a href="/"><img alt="Apache Flink" src="/img/navbar-brand-logo.jpg" width="78px" height="40px"></a> + <img alt="Apache Flink" src="/img/navbar-brand-logo.jpg" width="78px" height="40px"> </div> </div><!-- /.navbar-header --> @@ -50,7 +50,7 @@ <!-- Quickstart --> <li class="dropdown"> - <a href="#" class="dropdown-toggle" data-toggle="dropdown" role="button" aria-expanded="false">Quickstart <span class="caret"></span></a> + <a href="#" class="dropdown-toggle" data-toggle="dropdown" role="button" aria-expanded="false"><small><span class="glyphicon glyphicon-new-window"></span></small> Quickstart <span class="caret"></span></a> <ul class="dropdown-menu" role="menu"> <li><a href="http://ci.apache.org/projects/flink/flink-docs-release-0.9/quickstart/setup_quickstart.html";>Setup</a></li> <li><a href="http://ci.apache.org/projects/flink/flink-docs-release-0.9/quickstart/java_api_quickstart.html";>Java API</a></li> @@ -67,7 +67,7 @@ <!-- Documentation --> <li class="dropdown"> - <a href="" class="dropdown-toggle" data-toggle="dropdown" role="button" aria-expanded="false">Documentation <span class="caret"></span></a> + <a href="" class="dropdown-toggle" data-toggle="dropdown" role="button" aria-expanded="false"><small><span class="glyphicon glyphicon-new-window"></span></small> Documentation <span class="caret"></span></a> <ul class="dropdown-menu" role="menu"> <!-- Latest stable release --> <li role="presentation" class="dropdown-header"><strong>Latest Release</strong> (Stable)</li> @@ -84,7 +84,7 @@ <!-- Wiki --> <li class="divider"></li> - <li><a href="https://cwiki.apache.org/confluence/display/FLINK/Apache+Flink+Home";><small><span class="glyphicon glyphicon-new-window"></span></small> Wiki</a></li> + <li><a href="https://cwiki.apache.org/confluence/display/FLINK/Apache+Flink+Home";>Wiki</a></li> </ul> </li> @@ -105,6 +105,7 @@ <li><a href="/community.html#irc">IRC</a></li> <li><a href="/community.html#stack-overflow">Stack Overflow</a></li> <li><a href="/community.html#issue-tracker">Issue Tracker</a></li> + <li><a href="/community.html#third-party-packages">Third Party Packages</a></li> <li><a href="/community.html#source-code">Source Code</a></li> <li><a href="/community.html#people">People</a></li> http://git-wip-us.apache.org/repos/asf/flink-web/blob/c3e5f146/content/news/2015/09/16/off-heap-memory.html ---------------------------------------------------------------------- diff --git a/content/news/2015/09/16/off-heap-memory.html b/content/news/2015/09/16/off-heap-memory.html index 557f9ef..75898ee 100644 --- a/content/news/2015/09/16/off-heap-memory.html +++ b/content/news/2015/09/16/off-heap-memory.html @@ -38,7 +38,7 @@ <span class="icon-bar"></span> </button> <div class="navbar-logo"> - <a href="/"><img alt="Apache Flink" src="/img/navbar-brand-logo.jpg" width="78px" height="40px"></a> + <img alt="Apache Flink" src="/img/navbar-brand-logo.jpg" width="78px" height="40px"> </div> </div><!-- /.navbar-header --> @@ -50,7 +50,7 @@ <!-- Quickstart --> <li class="dropdown"> - <a href="#" class="dropdown-toggle" data-toggle="dropdown" role="button" aria-expanded="false">Quickstart <span class="caret"></span></a> + <a href="#" class="dropdown-toggle" data-toggle="dropdown" role="button" aria-expanded="false"><small><span class="glyphicon glyphicon-new-window"></span></small> Quickstart <span class="caret"></span></a> <ul class="dropdown-menu" role="menu"> <li><a href="http://ci.apache.org/projects/flink/flink-docs-release-0.9/quickstart/setup_quickstart.html";>Setup</a></li> <li><a href="http://ci.apache.org/projects/flink/flink-docs-release-0.9/quickstart/java_api_quickstart.html";>Java API</a></li> @@ -67,7 +67,7 @@ <!-- Documentation --> <li class="dropdown"> - <a href="" class="dropdown-toggle" data-toggle="dropdown" role="button" aria-expanded="false">Documentation <span class="caret"></span></a> + <a href="" class="dropdown-toggle" data-toggle="dropdown" role="button" aria-expanded="false"><small><span class="glyphicon glyphicon-new-window"></span></small> Documentation <span class="caret"></span></a> <ul class="dropdown-menu" role="menu"> <!-- Latest stable release --> <li role="presentation" class="dropdown-header"><strong>Latest Release</strong> (Stable)</li> @@ -84,7 +84,7 @@ <!-- Wiki --> <li class="divider"></li> - <li><a href="https://cwiki.apache.org/confluence/display/FLINK/Apache+Flink+Home";><small><span class="glyphicon glyphicon-new-window"></span></small> Wiki</a></li> + <li><a href="https://cwiki.apache.org/confluence/display/FLINK/Apache+Flink+Home";>Wiki</a></li> </ul> </li> @@ -105,6 +105,7 @@ <li><a href="/community.html#irc">IRC</a></li> <li><a href="/community.html#stack-overflow">Stack Overflow</a></li> <li><a href="/community.html#issue-tracker">Issue Tracker</a></li> + <li><a href="/community.html#third-party-packages">Third Party Packages</a></li> <li><a href="/community.html#source-code">Source Code</a></li> <li><a href="/community.html#people">People</a></li> http://git-wip-us.apache.org/repos/asf/flink-web/blob/c3e5f146/content/privacy-policy.html ---------------------------------------------------------------------- diff --git a/content/privacy-policy.html b/content/privacy-policy.html index 752de53..48d6bc8 100644 --- a/content/privacy-policy.html +++ b/content/privacy-policy.html @@ -38,7 +38,7 @@ <span class="icon-bar"></span> </button> <div class="navbar-logo"> - <a href="/"><img alt="Apache Flink" src="/img/navbar-brand-logo.jpg" width="78px" height="40px"></a> + <img alt="Apache Flink" src="/img/navbar-brand-logo.jpg" width="78px" height="40px"> </div> </div><!-- /.navbar-header --> @@ -50,7 +50,7 @@ <!-- Quickstart --> <li class="dropdown"> - <a href="#" class="dropdown-toggle" data-toggle="dropdown" role="button" aria-expanded="false">Quickstart <span class="caret"></span></a> + <a href="#" class="dropdown-toggle" data-toggle="dropdown" role="button" aria-expanded="false"><small><span class="glyphicon glyphicon-new-window"></span></small> Quickstart <span class="caret"></span></a> <ul class="dropdown-menu" role="menu"> <li><a href="http://ci.apache.org/projects/flink/flink-docs-release-0.9/quickstart/setup_quickstart.html";>Setup</a></li> <li><a href="http://ci.apache.org/projects/flink/flink-docs-release-0.9/quickstart/java_api_quickstart.html";>Java API</a></li> @@ -67,7 +67,7 @@ <!-- Documentation --> <li class="dropdown"> - <a href="" class="dropdown-toggle" data-toggle="dropdown" role="button" aria-expanded="false">Documentation <span class="caret"></span></a> + <a href="" class="dropdown-toggle" data-toggle="dropdown" role="button" aria-expanded="false"><small><span class="glyphicon glyphicon-new-window"></span></small> Documentation <span class="caret"></span></a> <ul class="dropdown-menu" role="menu"> <!-- Latest stable release --> <li role="presentation" class="dropdown-header"><strong>Latest Release</strong> (Stable)</li> @@ -84,7 +84,7 @@ <!-- Wiki --> <li class="divider"></li> - <li><a href="https://cwiki.apache.org/confluence/display/FLINK/Apache+Flink+Home";><small><span class="glyphicon glyphicon-new-window"></span></small> Wiki</a></li> + <li><a href="https://cwiki.apache.org/confluence/display/FLINK/Apache+Flink+Home";>Wiki</a></li> </ul> </li> @@ -105,6 +105,7 @@ <li><a href="/community.html#irc">IRC</a></li> <li><a href="/community.html#stack-overflow">Stack Overflow</a></li> <li><a href="/community.html#issue-tracker">Issue Tracker</a></li> + <li><a href="/community.html#third-party-packages">Third Party Packages</a></li> <li><a href="/community.html#source-code">Source Code</a></li> <li><a href="/community.html#people">People</a></li> http://git-wip-us.apache.org/repos/asf/flink-web/blob/c3e5f146/content/project.html ---------------------------------------------------------------------- diff --git a/content/project.html b/content/project.html index c22c6ed..9f1dbb6 100644 --- a/content/project.html +++ b/content/project.html @@ -38,7 +38,7 @@ <span class="icon-bar"></span> </button> <div class="navbar-logo"> - <a href="/"><img alt="Apache Flink" src="/img/navbar-brand-logo.jpg" width="78px" height="40px"></a> + <img alt="Apache Flink" src="/img/navbar-brand-logo.jpg" width="78px" height="40px"> </div> </div><!-- /.navbar-header --> @@ -50,7 +50,7 @@ <!-- Quickstart --> <li class="dropdown"> - <a href="#" class="dropdown-toggle" data-toggle="dropdown" role="button" aria-expanded="false">Quickstart <span class="caret"></span></a> + <a href="#" class="dropdown-toggle" data-toggle="dropdown" role="button" aria-expanded="false"><small><span class="glyphicon glyphicon-new-window"></span></small> Quickstart <span class="caret"></span></a> <ul class="dropdown-menu" role="menu"> <li><a href="http://ci.apache.org/projects/flink/flink-docs-release-0.9/quickstart/setup_quickstart.html";>Setup</a></li> <li><a href="http://ci.apache.org/projects/flink/flink-docs-release-0.9/quickstart/java_api_quickstart.html";>Java API</a></li> @@ -67,7 +67,7 @@ <!-- Documentation --> <li class="dropdown"> - <a href="" class="dropdown-toggle" data-toggle="dropdown" role="button" aria-expanded="false">Documentation <span class="caret"></span></a> + <a href="" class="dropdown-toggle" data-toggle="dropdown" role="button" aria-expanded="false"><small><span class="glyphicon glyphicon-new-window"></span></small> Documentation <span class="caret"></span></a> <ul class="dropdown-menu" role="menu"> <!-- Latest stable release --> <li role="presentation" class="dropdown-header"><strong>Latest Release</strong> (Stable)</li> @@ -84,7 +84,7 @@ <!-- Wiki --> <li class="divider"></li> - <li><a href="https://cwiki.apache.org/confluence/display/FLINK/Apache+Flink+Home";><small><span class="glyphicon glyphicon-new-window"></span></small> Wiki</a></li> + <li><a href="https://cwiki.apache.org/confluence/display/FLINK/Apache+Flink+Home";>Wiki</a></li> </ul> </li> @@ -105,6 +105,7 @@ <li><a href="/community.html#irc">IRC</a></li> <li><a href="/community.html#stack-overflow">Stack Overflow</a></li> <li><a href="/community.html#issue-tracker">Issue Tracker</a></li> + <li><a href="/community.html#third-party-packages">Third Party Packages</a></li> <li><a href="/community.html#source-code">Source Code</a></li> <li><a href="/community.html#people">People</a></li>
