http://git-wip-us.apache.org/repos/asf/flink-web/blob/c3e5f146/content/news/2014/01/26/optimizer_plan_visualization_tool.html ---------------------------------------------------------------------- diff --git a/content/news/2014/01/26/optimizer_plan_visualization_tool.html b/content/news/2014/01/26/optimizer_plan_visualization_tool.html index f050f4a..2f5626a 100644 --- a/content/news/2014/01/26/optimizer_plan_visualization_tool.html +++ b/content/news/2014/01/26/optimizer_plan_visualization_tool.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/2014/01/28/querying_mongodb.html ---------------------------------------------------------------------- diff --git a/content/news/2014/01/28/querying_mongodb.html b/content/news/2014/01/28/querying_mongodb.html index 032ef83..b088ee5 100644 --- a/content/news/2014/01/28/querying_mongodb.html +++ b/content/news/2014/01/28/querying_mongodb.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> @@ -149,16 +150,16 @@ <p>We recently merged a <a href="https://github.com/stratosphere/stratosphere/pull/437";>pull request</a> that allows you to use any existing Hadoop <a href="http://developer.yahoo.com/hadoop/tutorial/module5.html#inputformat";>InputFormat</a> with Stratosphere. So you can now (in the <code>0.5-SNAPSHOT</code> and upwards versions) define a Hadoop-based data source:</p> -<div class="highlight"><pre><code class="language-java"><span class="n">HadoopDataSource</span> <span class="n">source</span> <span class="o">=</span> <span class="k">new</span> <span class="nf">HadoopDataSource</span><span class="o">(</span><span class="k">new</span> <span class="nf">TextInputFormat</span><span class="o">(),</span> <span class="k">new</span> <span class="nf">JobConf</span><span class="o">(),</span> <span class="s">"Input Lines"</span><span class="o">);</span> -<span class="n">TextInputFormat</span><span class="o">.</span><span class="na">addInputPath</span><span class="o">(</span><span class="n">source</span><span class="o">.</span><span class="na">getJobConf</span><span class="o">(),</span> <span class="k">new</span> <span class="nf">Path</span><span class="o">(</span><span class="n">dataInput</span><span class="o">));</span></code></pre></div> +<div class="highlight"><pre><code class="language-java"><span class="n">HadoopDataSource</span> <span class="n">source</span> <span class="o">=</span> <span class="k">new</span> <span class="n">HadoopDataSource</span><span class="o">(</span><span class="k">new</span> <span class="n">TextInputFormat</span><span class="o">(),</span> <span class="k">new</span> <span class="n">JobConf</span><span class="o">(),</span> <span class="s">"Input Lines"</span><span class="o">);</span> +<span class="n">TextInputFormat</span><span class="o">.</span><span class="na">addInputPath</span><span class="o">(</span><span class="n">source</span><span class="o">.</span><span class="na">getJobConf</span><span class="o">(),</span> <span class="k">new</span> <span class="n">Path</span><span class="o">(</span><span class="n">dataInput</span><span class="o">));</span></code></pre></div> <p>We describe in the following article how to access data stored in <a href="http://www.mongodb.org/";>MongoDB</a> with Stratosphere. This allows users to join data from multiple sources (e.g. MonogDB and HDFS) or perform machine learning with the documents stored in MongoDB.</p> <p>The approach here is to use the <code>MongoInputFormat</code> that was developed for Apache Hadoop but now also runs with Stratosphere.</p> -<div class="highlight"><pre><code class="language-java"><span class="n">JobConf</span> <span class="n">conf</span> <span class="o">=</span> <span class="k">new</span> <span class="nf">JobConf</span><span class="o">();</span> +<div class="highlight"><pre><code class="language-java"><span class="n">JobConf</span> <span class="n">conf</span> <span class="o">=</span> <span class="k">new</span> <span class="n">JobConf</span><span class="o">();</span> <span class="n">conf</span><span class="o">.</span><span class="na">set</span><span class="o">(</span><span class="s">"mongo.input.uri"</span><span class="o">,</span><span class="s">"mongodb://localhost:27017/enron_mail.messages"</span><span class="o">);</span> -<span class="n">HadoopDataSource</span> <span class="n">src</span> <span class="o">=</span> <span class="k">new</span> <span class="nf">HadoopDataSource</span><span class="o">(</span><span class="k">new</span> <span class="nf">MongoInputFormat</span><span class="o">(),</span> <span class="n">conf</span><span class="o">,</span> <span class="s">"Read from Mongodb"</span><span class="o">,</span> <span class="k">new</span> <span class="nf">WritableWrapperConverter</span><span class="o">());</span></code></pre></div> +<span class="n">HadoopDataSource</span> <span class="n">src</span> <span class="o">=</span> <span class="k">new</span> <span class="n">HadoopDataSource</span><span class="o">(</span><span class="k">new</span> <span class="n">MongoInputFormat</span><span class="o">(),</span> <span class="n">conf</span><span class="o">,</span> <span class="s">"Read from Mongodb"</span><span class="o">,</span> <span class="k">new</span> <span class="n">WritableWrapperConverter</span><span class="o">());</span></code></pre></div> <h3 id="example-program">Example Program</h3> <p>The example program reads data from the <a href="http://www.cs.cmu.edu/~enron/";>enron dataset</a> that contains about 500k internal e-mails. The data is stored in MongoDB and the Stratosphere program counts the number of e-mails per day.</p> http://git-wip-us.apache.org/repos/asf/flink-web/blob/c3e5f146/content/news/2014/02/18/amazon-elastic-mapreduce-cloud-yarn.html ---------------------------------------------------------------------- diff --git a/content/news/2014/02/18/amazon-elastic-mapreduce-cloud-yarn.html b/content/news/2014/02/18/amazon-elastic-mapreduce-cloud-yarn.html index fe528fc..7885978 100644 --- a/content/news/2014/02/18/amazon-elastic-mapreduce-cloud-yarn.html +++ b/content/news/2014/02/18/amazon-elastic-mapreduce-cloud-yarn.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/2014/02/24/stratosphere-google-summer-of-code-2014.html ---------------------------------------------------------------------- diff --git a/content/news/2014/02/24/stratosphere-google-summer-of-code-2014.html b/content/news/2014/02/24/stratosphere-google-summer-of-code-2014.html index bd55996..90fb77a 100644 --- a/content/news/2014/02/24/stratosphere-google-summer-of-code-2014.html +++ b/content/news/2014/02/24/stratosphere-google-summer-of-code-2014.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/2014/04/16/stratosphere-goes-apache-incubator.html ---------------------------------------------------------------------- diff --git a/content/news/2014/04/16/stratosphere-goes-apache-incubator.html b/content/news/2014/04/16/stratosphere-goes-apache-incubator.html index 6c3c696..3c37ed1 100644 --- a/content/news/2014/04/16/stratosphere-goes-apache-incubator.html +++ b/content/news/2014/04/16/stratosphere-goes-apache-incubator.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/2014/05/31/release-0.5.html ---------------------------------------------------------------------- diff --git a/content/news/2014/05/31/release-0.5.html b/content/news/2014/05/31/release-0.5.html index 98b2c7d..db805af 100644 --- a/content/news/2014/05/31/release-0.5.html +++ b/content/news/2014/05/31/release-0.5.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/2014/08/26/release-0.6.html ---------------------------------------------------------------------- diff --git a/content/news/2014/08/26/release-0.6.html b/content/news/2014/08/26/release-0.6.html index 55c0598..cef280e 100644 --- a/content/news/2014/08/26/release-0.6.html +++ b/content/news/2014/08/26/release-0.6.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/2014/09/26/release-0.6.1.html ---------------------------------------------------------------------- diff --git a/content/news/2014/09/26/release-0.6.1.html b/content/news/2014/09/26/release-0.6.1.html index 801af9f..989db25 100644 --- a/content/news/2014/09/26/release-0.6.1.html +++ b/content/news/2014/09/26/release-0.6.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/2014/10/03/upcoming_events.html ---------------------------------------------------------------------- diff --git a/content/news/2014/10/03/upcoming_events.html b/content/news/2014/10/03/upcoming_events.html index 2fc7d73..f094dc9 100644 --- a/content/news/2014/10/03/upcoming_events.html +++ b/content/news/2014/10/03/upcoming_events.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/2014/11/04/release-0.7.0.html ---------------------------------------------------------------------- diff --git a/content/news/2014/11/04/release-0.7.0.html b/content/news/2014/11/04/release-0.7.0.html index 22b035b..4fa97d0 100644 --- a/content/news/2014/11/04/release-0.7.0.html +++ b/content/news/2014/11/04/release-0.7.0.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/2014/11/18/hadoop-compatibility.html ---------------------------------------------------------------------- diff --git a/content/news/2014/11/18/hadoop-compatibility.html b/content/news/2014/11/18/hadoop-compatibility.html index 7786593..54cdaf7 100644 --- a/content/news/2014/11/18/hadoop-compatibility.html +++ b/content/news/2014/11/18/hadoop-compatibility.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> @@ -184,25 +185,25 @@ <span class="c1">// Setup Hadoop’s TextInputFormat</span> <span class="n">HadoopInputFormat</span><span class="o"><</span><span class="n">LongWritable</span><span class="o">,</span> <span class="n">Text</span><span class="o">></span> <span class="n">hadoopInputFormat</span> <span class="o">=</span> <span class="k">new</span> <span class="n">HadoopInputFormat</span><span class="o"><</span><span class="n">LongWritable</span><span class="o">,</span> <span class="n">Text</span><span class="o">>(</span> - <span class="k">new</span> <span class="nf">TextInputFormat</span><span class="o">(),</span> <span class="n">LongWritable</span><span class="o">.</span><span class="na">class</span><span class="o">,</span> <span class="n">Text</span><span class="o">.</span><span class="na">class</span><span class="o">,</span> <span class="k">new</span> <span class="nf">JobConf</span><span class="o">());</span> - <span class="n">TextInputFormat</span><span class="o">.</span><span class="na">addInputPath</span><span class="o">(</span><span class="n">hadoopInputFormat</span><span class="o">.</span><span class="na">getJobConf</span><span class="o">(),</span> <span class="k">new</span> <span class="nf">Path</span><span class="o">(</span><span class="n">inputPath</span><span class="o">));</span> + <span class="k">new</span> <span class="n">TextInputFormat</span><span class="o">(),</span> <span class="n">LongWritable</span><span class="o">.</span><span class="na">class</span><span class="o">,</span> <span class="n">Text</span><span class="o">.</span><span class="na">class</span><span class="o">,</span> <span class="k">new</span> <span class="n">JobConf</span><span class="o">());</span> + <span class="n">TextInputFormat</span><span class="o">.</span><span class="na">addInputPath</span><span class="o">(</span><span class="n">hadoopInputFormat</span><span class="o">.</span><span class="na">getJobConf</span><span class="o">(),</span> <span class="k">new</span> <span class="n">Path</span><span class="o">(</span><span class="n">inputPath</span><span class="o">));</span> <span class="c1">// Read a DataSet with the Hadoop InputFormat</span> <span class="n">DataSet</span><span class="o"><</span><span class="n">Tuple2</span><span class="o"><</span><span class="n">LongWritable</span><span class="o">,</span> <span class="n">Text</span><span class="o">>></span> <span class="n">text</span> <span class="o">=</span> <span class="n">env</span><span class="o">.</span><span class="na">createInput</span><span class="o">(</span><span class="n">hadoopInputFormat</span><span class="o">);</span> <span class="n">DataSet</span><span class="o"><</span><span class="n">Tuple2</span><span class="o"><</span><span class="n">Text</span><span class="o">,</span> <span class="n">LongWritable</span><span class="o">>></span> <span class="n">words</span> <span class="o">=</span> <span class="n">text</span> <span class="c1">// Wrap Tokenizer Mapper function</span> - <span class="o">.</span><span class="na">flatMap</span><span class="o">(</span><span class="k">new</span> <span class="n">HadoopMapFunction</span><span class="o"><</span><span class="n">LongWritable</span><span class="o">,</span> <span class="n">Text</span><span class="o">,</span> <span class="n">Text</span><span class="o">,</span> <span class="n">LongWritable</span><span class="o">>(</span><span class="k">new</span> <span class="nf">Tokenizer</span><span class="o">()))</span> + <span class="o">.</span><span class="na">flatMap</span><span class="o">(</span><span class="k">new</span> <span class="n">HadoopMapFunction</span><span class="o"><</span><span class="n">LongWritable</span><span class="o">,</span> <span class="n">Text</span><span class="o">,</span> <span class="n">Text</span><span class="o">,</span> <span class="n">LongWritable</span><span class="o">>(</span><span class="k">new</span> <span class="n">Tokenizer</span><span class="o">()))</span> <span class="o">.</span><span class="na">groupBy</span><span class="o">(</span><span class="mi">0</span><span class="o">)</span> <span class="c1">// Wrap Counter Reducer function (used as Reducer and Combiner)</span> <span class="o">.</span><span class="na">reduceGroup</span><span class="o">(</span><span class="k">new</span> <span class="n">HadoopReduceCombineFunction</span><span class="o"><</span><span class="n">Text</span><span class="o">,</span> <span class="n">LongWritable</span><span class="o">,</span> <span class="n">Text</span><span class="o">,</span> <span class="n">LongWritable</span><span class="o">>(</span> - <span class="k">new</span> <span class="nf">Counter</span><span class="o">(),</span> <span class="k">new</span> <span class="nf">Counter</span><span class="o">()));</span> + <span class="k">new</span> <span class="n">Counter</span><span class="o">(),</span> <span class="k">new</span> <span class="n">Counter</span><span class="o">()));</span> <span class="c1">// Setup Hadoop’s TextOutputFormat</span> <span class="n">HadoopOutputFormat</span><span class="o"><</span><span class="n">Text</span><span class="o">,</span> <span class="n">LongWritable</span><span class="o">></span> <span class="n">hadoopOutputFormat</span> <span class="o">=</span> <span class="k">new</span> <span class="n">HadoopOutputFormat</span><span class="o"><</span><span class="n">Text</span><span class="o">,</span> <span class="n">LongWritable</span><span class="o">>(</span> - <span class="k">new</span> <span class="n">TextOutputFormat</span><span class="o"><</span><span class="n">Text</span><span class="o">,</span> <span class="n">LongWritable</span><span class="o">>(),</span> <span class="k">new</span> <span class="nf">JobConf</span><span class="o">());</span> + <span class="k">new</span> <span class="n">TextOutputFormat</span><span class="o"><</span><span class="n">Text</span><span class="o">,</span> <span class="n">LongWritable</span><span class="o">>(),</span> <span class="k">new</span> <span class="n">JobConf</span><span class="o">());</span> <span class="n">hadoopOutputFormat</span><span class="o">.</span><span class="na">getJobConf</span><span class="o">().</span><span class="na">set</span><span class="o">(</span><span class="s">"mapred.textoutputformat.separator"</span><span class="o">,</span> <span class="s">" "</span><span class="o">);</span> - <span class="n">TextOutputFormat</span><span class="o">.</span><span class="na">setOutputPath</span><span class="o">(</span><span class="n">hadoopOutputFormat</span><span class="o">.</span><span class="na">getJobConf</span><span class="o">(),</span> <span class="k">new</span> <span class="nf">Path</span><span class="o">(</span><span class="n">outputPath</span><span class="o">));</span> + <span class="n">TextOutputFormat</span><span class="o">.</span><span class="na">setOutputPath</span><span class="o">(</span><span class="n">hadoopOutputFormat</span><span class="o">.</span><span class="na">getJobConf</span><span class="o">(),</span> <span class="k">new</span> <span class="n">Path</span><span class="o">(</span><span class="n">outputPath</span><span class="o">));</span> <span class="c1">// Output & Execute</span> <span class="n">words</span><span class="o">.</span><span class="na">output</span><span class="o">(</span><span class="n">hadoopOutputFormat</span><span class="o">);</span> http://git-wip-us.apache.org/repos/asf/flink-web/blob/c3e5f146/content/news/2015/01/06/december-in-flink.html ---------------------------------------------------------------------- diff --git a/content/news/2015/01/06/december-in-flink.html b/content/news/2015/01/06/december-in-flink.html index 0fd101f..03a3ab2 100644 --- a/content/news/2015/01/06/december-in-flink.html +++ b/content/news/2015/01/06/december-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/01/21/release-0.8.html ---------------------------------------------------------------------- diff --git a/content/news/2015/01/21/release-0.8.html b/content/news/2015/01/21/release-0.8.html index 933606c..af2b51e 100644 --- a/content/news/2015/01/21/release-0.8.html +++ b/content/news/2015/01/21/release-0.8.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/02/04/january-in-flink.html ---------------------------------------------------------------------- diff --git a/content/news/2015/02/04/january-in-flink.html b/content/news/2015/02/04/january-in-flink.html index 74f3565..3cb02ff 100644 --- a/content/news/2015/02/04/january-in-flink.html +++ b/content/news/2015/02/04/january-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/02/09/streaming-example.html ---------------------------------------------------------------------- diff --git a/content/news/2015/02/09/streaming-example.html b/content/news/2015/02/09/streaming-example.html index 4cf0561..60b8ca3 100644 --- a/content/news/2015/02/09/streaming-example.html +++ b/content/news/2015/02/09/streaming-example.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> @@ -233,16 +234,16 @@ found <a href="https://github.com/mbalassi/flink/blob/stockprices/flink-staging/ <span class="nd">@Override</span> <span class="kd">public</span> <span class="n">StockPrice</span> <span class="nf">map</span><span class="o">(</span><span class="n">String</span> <span class="n">value</span><span class="o">)</span> <span class="kd">throws</span> <span class="n">Exception</span> <span class="o">{</span> <span class="n">tokens</span> <span class="o">=</span> <span class="n">value</span><span class="o">.</span><span class="na">split</span><span class="o">(</span><span class="s">","</span><span class="o">);</span> - <span class="k">return</span> <span class="k">new</span> <span class="nf">StockPrice</span><span class="o">(</span><span class="n">tokens</span><span class="o">[</span><span class="mi">0</span><span class="o">],</span> + <span class="k">return</span> <span class="k">new</span> <span class="n">StockPrice</span><span class="o">(</span><span class="n">tokens</span><span class="o">[</span><span class="mi">0</span><span class="o">],</span> <span class="n">Double</span><span class="o">.</span><span class="na">parseDouble</span><span class="o">(</span><span class="n">tokens</span><span class="o">[</span><span class="mi">1</span><span class="o">]));</span> <span class="o">}</span> <span class="o">});</span> <span class="c1">//Generate other stock streams</span> - <span class="n">DataStream</span><span class="o"><</span><span class="n">StockPrice</span><span class="o">></span> <span class="n">SPX_stream</span> <span class="o">=</span> <span class="n">env</span><span class="o">.</span><span class="na">addSource</span><span class="o">(</span><span class="k">new</span> <span class="nf">StockSource</span><span class="o">(</span><span class="s">"SPX"</span><span class="o">,</span> <span class="mi">10</span><span class="o">));</span> - <span class="n">DataStream</span><span class="o"><</span><span class="n">StockPrice</span><span class="o">></span> <span class="n">FTSE_stream</span> <span class="o">=</span> <span class="n">env</span><span class="o">.</span><span class="na">addSource</span><span class="o">(</span><span class="k">new</span> <span class="nf">StockSource</span><span class="o">(</span><span class="s">"FTSE"</span><span class="o">,</span> <span class="mi">20</span><span class="o">));</span> - <span class="n">DataStream</span><span class="o"><</span><span class="n">StockPrice</span><span class="o">></span> <span class="n">DJI_stream</span> <span class="o">=</span> <span class="n">env</span><span class="o">.</span><span class="na">addSource</span><span class="o">(</span><span class="k">new</span> <span class="nf">StockSource</span><span class="o">(</span><span class="s">"DJI"</span><span class="o">,</span> <span class="mi">30</span><span class="o">));</span> - <span class="n">DataStream</span><span class="o"><</span><span class="n">StockPrice</span><span class="o">></span> <span class="n">BUX_stream</span> <span class="o">=</span> <span class="n">env</span><span class="o">.</span><span class="na">addSource</span><span class="o">(</span><span class="k">new</span> <span class="nf">StockSource</span><span class="o">(</span><span class="s">"BUX"</span><span class="o">,</span> <span class="mi">40</span><span class="o">));</span> + <span class="n">DataStream</span><span class="o"><</span><span class="n">StockPrice</span><span class="o">></span> <span class="n">SPX_stream</span> <span class="o">=</span> <span class="n">env</span><span class="o">.</span><span class="na">addSource</span><span class="o">(</span><span class="k">new</span> <span class="n">StockSource</span><span class="o">(</span><span class="s">"SPX"</span><span class="o">,</span> <span class="mi">10</span><span class="o">));</span> + <span class="n">DataStream</span><span class="o"><</span><span class="n">StockPrice</span><span class="o">></span> <span class="n">FTSE_stream</span> <span class="o">=</span> <span class="n">env</span><span class="o">.</span><span class="na">addSource</span><span class="o">(</span><span class="k">new</span> <span class="n">StockSource</span><span class="o">(</span><span class="s">"FTSE"</span><span class="o">,</span> <span class="mi">20</span><span class="o">));</span> + <span class="n">DataStream</span><span class="o"><</span><span class="n">StockPrice</span><span class="o">></span> <span class="n">DJI_stream</span> <span class="o">=</span> <span class="n">env</span><span class="o">.</span><span class="na">addSource</span><span class="o">(</span><span class="k">new</span> <span class="n">StockSource</span><span class="o">(</span><span class="s">"DJI"</span><span class="o">,</span> <span class="mi">30</span><span class="o">));</span> + <span class="n">DataStream</span><span class="o"><</span><span class="n">StockPrice</span><span class="o">></span> <span class="n">BUX_stream</span> <span class="o">=</span> <span class="n">env</span><span class="o">.</span><span class="na">addSource</span><span class="o">(</span><span class="k">new</span> <span class="n">StockSource</span><span class="o">(</span><span class="s">"BUX"</span><span class="o">,</span> <span class="mi">40</span><span class="o">));</span> <span class="c1">//Merge all stock streams together</span> <span class="n">DataStream</span><span class="o"><</span><span class="n">StockPrice</span><span class="o">></span> <span class="n">stockStream</span> <span class="o">=</span> <span class="n">socketStockStream</span> @@ -323,11 +324,11 @@ of this example, the data streams are simply generated using the <span class="nd">@Override</span> <span class="kd">public</span> <span class="kt">void</span> <span class="nf">invoke</span><span class="o">(</span><span class="n">Collector</span><span class="o"><</span><span class="n">StockPrice</span><span class="o">></span> <span class="n">collector</span><span class="o">)</span> <span class="kd">throws</span> <span class="n">Exception</span> <span class="o">{</span> <span class="n">price</span> <span class="o">=</span> <span class="n">DEFAULT_PRICE</span><span class="o">;</span> - <span class="n">Random</span> <span class="n">random</span> <span class="o">=</span> <span class="k">new</span> <span class="nf">Random</span><span class="o">();</span> + <span class="n">Random</span> <span class="n">random</span> <span class="o">=</span> <span class="k">new</span> <span class="n">Random</span><span class="o">();</span> <span class="k">while</span> <span class="o">(</span><span class="kc">true</span><span class="o">)</span> <span class="o">{</span> <span class="n">price</span> <span class="o">=</span> <span class="n">price</span> <span class="o">+</span> <span class="n">random</span><span class="o">.</span><span class="na">nextGaussian</span><span class="o">()</span> <span class="o">*</span> <span class="n">sigma</span><span class="o">;</span> - <span class="n">collector</span><span class="o">.</span><span class="na">collect</span><span class="o">(</span><span class="k">new</span> <span class="nf">StockPrice</span><span class="o">(</span><span class="n">symbol</span><span class="o">,</span> <span class="n">price</span><span class="o">));</span> + <span class="n">collector</span><span class="o">.</span><span class="na">collect</span><span class="o">(</span><span class="k">new</span> <span class="n">StockPrice</span><span class="o">(</span><span class="n">symbol</span><span class="o">,</span> <span class="n">price</span><span class="o">));</span> <span class="n">Thread</span><span class="o">.</span><span class="na">sleep</span><span class="o">(</span><span class="n">random</span><span class="o">.</span><span class="na">nextInt</span><span class="o">(</span><span class="mi">200</span><span class="o">));</span> <span class="o">}</span> <span class="o">}</span> @@ -414,7 +415,7 @@ performed on named fields of POJOs, making the code more readable.</p> <span class="n">DataStream</span><span class="o"><</span><span class="n">StockPrice</span><span class="o">></span> <span class="n">maxByStock</span> <span class="o">=</span> <span class="n">windowedStream</span><span class="o">.</span><span class="na">groupBy</span><span class="o">(</span><span class="s">"symbol"</span><span class="o">)</span> <span class="o">.</span><span class="na">maxBy</span><span class="o">(</span><span class="s">"price"</span><span class="o">).</span><span class="na">flatten</span><span class="o">();</span> <span class="n">DataStream</span><span class="o"><</span><span class="n">StockPrice</span><span class="o">></span> <span class="n">rollingMean</span> <span class="o">=</span> <span class="n">windowedStream</span><span class="o">.</span><span class="na">groupBy</span><span class="o">(</span><span class="s">"symbol"</span><span class="o">)</span> - <span class="o">.</span><span class="na">mapWindow</span><span class="o">(</span><span class="k">new</span> <span class="nf">WindowMean</span><span class="o">()).</span><span class="na">flatten</span><span class="o">();</span> + <span class="o">.</span><span class="na">mapWindow</span><span class="o">(</span><span class="k">new</span> <span class="n">WindowMean</span><span class="o">()).</span><span class="na">flatten</span><span class="o">();</span> <span class="c1">//Compute the mean of a window</span> <span class="kd">public</span> <span class="kd">final</span> <span class="kd">static</span> <span class="kd">class</span> <span class="nc">WindowMean</span> <span class="kd">implements</span> @@ -434,7 +435,7 @@ performed on named fields of POJOs, making the code more readable.</p> <span class="n">symbol</span> <span class="o">=</span> <span class="n">sp</span><span class="o">.</span><span class="na">symbol</span><span class="o">;</span> <span class="n">count</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">StockPrice</span><span class="o">(</span><span class="n">symbol</span><span class="o">,</span> <span class="n">sum</span> <span class="o">/</span> <span class="n">count</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">StockPrice</span><span class="o">(</span><span class="n">symbol</span><span class="o">,</span> <span class="n">sum</span> <span class="o">/</span> <span class="n">count</span><span class="o">));</span> <span class="o">}</span> <span class="o">}</span> <span class="o">}</span></code></pre></div> @@ -494,7 +495,7 @@ every 30 seconds.</p> <div data-lang="java7"> <div class="highlight"><pre><code class="language-java" data-lang="java"><span class="kd">private</span> <span class="kd">static</span> <span class="kd">final</span> <span class="n">Double</span> <span class="n">DEFAULT_PRICE</span> <span class="o">=</span> <span class="mi">1000</span><span class="o">.;</span> -<span class="kd">private</span> <span class="kd">static</span> <span class="kd">final</span> <span class="n">StockPrice</span> <span class="n">DEFAULT_STOCK_PRICE</span> <span class="o">=</span> <span class="k">new</span> <span class="nf">StockPrice</span><span class="o">(</span><span class="s">""</span><span class="o">,</span> <span class="n">DEFAULT_PRICE</span><span class="o">);</span> +<span class="kd">private</span> <span class="kd">static</span> <span class="kd">final</span> <span class="n">StockPrice</span> <span class="n">DEFAULT_STOCK_PRICE</span> <span class="o">=</span> <span class="k">new</span> <span class="n">StockPrice</span><span class="o">(</span><span class="s">""</span><span class="o">,</span> <span class="n">DEFAULT_PRICE</span><span class="o">);</span> <span class="c1">//Use delta policy to create price change warnings</span> <span class="n">DataStream</span><span class="o"><</span><span class="n">String</span><span class="o">></span> <span class="n">priceWarnings</span> <span class="o">=</span> <span class="n">stockStream</span><span class="o">.</span><span class="na">groupBy</span><span class="o">(</span><span class="s">"symbol"</span><span class="o">)</span> @@ -504,13 +505,13 @@ every 30 seconds.</p> <span class="k">return</span> <span class="n">Math</span><span class="o">.</span><span class="na">abs</span><span class="o">(</span><span class="n">oldDataPoint</span><span class="o">.</span><span class="na">price</span> <span class="o">-</span> <span class="n">newDataPoint</span><span class="o">.</span><span class="na">price</span><span class="o">);</span> <span class="o">}</span> <span class="o">},</span> <span class="n">DEFAULT_STOCK_PRICE</span><span class="o">))</span> -<span class="o">.</span><span class="na">mapWindow</span><span class="o">(</span><span class="k">new</span> <span class="nf">SendWarning</span><span class="o">()).</span><span class="na">flatten</span><span class="o">();</span> +<span class="o">.</span><span class="na">mapWindow</span><span class="o">(</span><span class="k">new</span> <span class="n">SendWarning</span><span class="o">()).</span><span class="na">flatten</span><span class="o">();</span> <span class="c1">//Count the number of warnings every half a minute</span> <span class="n">DataStream</span><span class="o"><</span><span class="n">Count</span><span class="o">></span> <span class="n">warningsPerStock</span> <span class="o">=</span> <span class="n">priceWarnings</span><span class="o">.</span><span class="na">map</span><span class="o">(</span><span class="k">new</span> <span class="n">MapFunction</span><span class="o"><</span><span class="n">String</span><span class="o">,</span> <span class="n">Count</span><span class="o">>()</span> <span class="o">{</span> <span class="nd">@Override</span> <span class="kd">public</span> <span class="n">Count</span> <span class="nf">map</span><span class="o">(</span><span class="n">String</span> <span class="n">value</span><span class="o">)</span> <span class="kd">throws</span> <span class="n">Exception</span> <span class="o">{</span> - <span class="k">return</span> <span class="k">new</span> <span class="nf">Count</span><span class="o">(</span><span class="n">value</span><span class="o">,</span> <span class="mi">1</span><span class="o">);</span> + <span class="k">return</span> <span class="k">new</span> <span class="n">Count</span><span class="o">(</span><span class="n">value</span><span class="o">,</span> <span class="mi">1</span><span class="o">);</span> <span class="o">}</span> <span class="o">}).</span><span class="na">groupBy</span><span class="o">(</span><span class="s">"symbol"</span><span class="o">).</span><span class="na">window</span><span class="o">(</span><span class="n">Time</span><span class="o">.</span><span class="na">of</span><span class="o">(</span><span class="mi">30</span><span class="o">,</span> <span class="n">TimeUnit</span><span class="o">.</span><span class="na">SECONDS</span><span class="o">)).</span><span class="na">sum</span><span class="o">(</span><span class="s">"count"</span><span class="o">).</span><span class="na">flatten</span><span class="o">();</span> @@ -592,7 +593,7 @@ but for the sake of this example we generate dummy tweet data.</p> <div data-lang="java7"> <div class="highlight"><pre><code class="language-java" data-lang="java"><span class="c1">//Read a stream of tweets</span> -<span class="n">DataStream</span><span class="o"><</span><span class="n">String</span><span class="o">></span> <span class="n">tweetStream</span> <span class="o">=</span> <span class="n">env</span><span class="o">.</span><span class="na">addSource</span><span class="o">(</span><span class="k">new</span> <span class="nf">TweetSource</span><span class="o">());</span> +<span class="n">DataStream</span><span class="o"><</span><span class="n">String</span><span class="o">></span> <span class="n">tweetStream</span> <span class="o">=</span> <span class="n">env</span><span class="o">.</span><span class="na">addSource</span><span class="o">(</span><span class="k">new</span> <span class="n">TweetSource</span><span class="o">());</span> <span class="c1">//Extract the stock symbols</span> <span class="n">DataStream</span><span class="o"><</span><span class="n">String</span><span class="o">></span> <span class="n">mentionedSymbols</span> <span class="o">=</span> <span class="n">tweetStream</span><span class="o">.</span><span class="na">flatMap</span><span class="o">(</span> @@ -615,7 +616,7 @@ but for the sake of this example we generate dummy tweet data.</p> <span class="n">DataStream</span><span class="o"><</span><span class="n">Count</span><span class="o">></span> <span class="n">tweetsPerStock</span> <span class="o">=</span> <span class="n">mentionedSymbols</span><span class="o">.</span><span class="na">map</span><span class="o">(</span><span class="k">new</span> <span class="n">MapFunction</span><span class="o"><</span><span class="n">String</span><span class="o">,</span> <span class="n">Count</span><span class="o">>()</span> <span class="o">{</span> <span class="nd">@Override</span> <span class="kd">public</span> <span class="n">Count</span> <span class="nf">map</span><span class="o">(</span><span class="n">String</span> <span class="n">value</span><span class="o">)</span> <span class="kd">throws</span> <span class="n">Exception</span> <span class="o">{</span> - <span class="k">return</span> <span class="k">new</span> <span class="nf">Count</span><span class="o">(</span><span class="n">value</span><span class="o">,</span> <span class="mi">1</span><span class="o">);</span> + <span class="k">return</span> <span class="k">new</span> <span class="n">Count</span><span class="o">(</span><span class="n">value</span><span class="o">,</span> <span class="mi">1</span><span class="o">);</span> <span class="o">}</span> <span class="o">}).</span><span class="na">groupBy</span><span class="o">(</span><span class="s">"symbol"</span><span class="o">).</span><span class="na">window</span><span class="o">(</span><span class="n">Time</span><span class="o">.</span><span class="na">of</span><span class="o">(</span><span class="mi">30</span><span class="o">,</span> <span class="n">TimeUnit</span><span class="o">.</span><span class="na">SECONDS</span><span class="o">)).</span><span class="na">sum</span><span class="o">(</span><span class="s">"count"</span><span class="o">).</span><span class="na">flatten</span><span class="o">();</span> @@ -625,8 +626,8 @@ but for the sake of this example we generate dummy tweet data.</p> <span class="nd">@Override</span> <span class="kd">public</span> <span class="kt">void</span> <span class="nf">invoke</span><span class="o">(</span><span class="n">Collector</span><span class="o"><</span><span class="n">String</span><span class="o">></span> <span class="n">collector</span><span class="o">)</span> <span class="kd">throws</span> <span class="n">Exception</span> <span class="o">{</span> - <span class="n">random</span> <span class="o">=</span> <span class="k">new</span> <span class="nf">Random</span><span class="o">();</span> - <span class="n">stringBuilder</span> <span class="o">=</span> <span class="k">new</span> <span class="nf">StringBuilder</span><span class="o">();</span> + <span class="n">random</span> <span class="o">=</span> <span class="k">new</span> <span class="n">Random</span><span class="o">();</span> + <span class="n">stringBuilder</span> <span class="o">=</span> <span class="k">new</span> <span class="n">StringBuilder</span><span class="o">();</span> <span class="k">while</span> <span class="o">(</span><span class="kc">true</span><span class="o">)</span> <span class="o">{</span> <span class="n">stringBuilder</span><span class="o">.</span><span class="na">setLength</span><span class="o">(</span><span class="mi">0</span><span class="o">);</span> @@ -708,7 +709,7 @@ these data streams are potentially infinite, we apply the join on a <span class="c1">//Compute rolling correlation</span> <span class="n">DataStream</span><span class="o"><</span><span class="n">Double</span><span class="o">></span> <span class="n">rollingCorrelation</span> <span class="o">=</span> <span class="n">tweetsAndWarning</span> <span class="o">.</span><span class="na">window</span><span class="o">(</span><span class="n">Time</span><span class="o">.</span><span class="na">of</span><span class="o">(</span><span class="mi">30</span><span class="o">,</span> <span class="n">TimeUnit</span><span class="o">.</span><span class="na">SECONDS</span><span class="o">))</span> - <span class="o">.</span><span class="na">mapWindow</span><span class="o">(</span><span class="k">new</span> <span class="nf">WindowCorrelation</span><span class="o">());</span> + <span class="o">.</span><span class="na">mapWindow</span><span class="o">(</span><span class="k">new</span> <span class="n">WindowCorrelation</span><span class="o">());</span> <span class="n">rollingCorrelation</span><span class="o">.</span><span class="na">print</span><span class="o">();</span> http://git-wip-us.apache.org/repos/asf/flink-web/blob/c3e5f146/content/news/2015/03/02/february-2015-in-flink.html ---------------------------------------------------------------------- diff --git a/content/news/2015/03/02/february-2015-in-flink.html b/content/news/2015/03/02/february-2015-in-flink.html index f5305c7..92e9150 100644 --- a/content/news/2015/03/02/february-2015-in-flink.html +++ b/content/news/2015/03/02/february-2015-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/03/13/peeking-into-Apache-Flinks-Engine-Room.html ---------------------------------------------------------------------- diff --git a/content/news/2015/03/13/peeking-into-Apache-Flinks-Engine-Room.html b/content/news/2015/03/13/peeking-into-Apache-Flinks-Engine-Room.html index 3378ca6..665f6d1 100644 --- a/content/news/2015/03/13/peeking-into-Apache-Flinks-Engine-Room.html +++ b/content/news/2015/03/13/peeking-into-Apache-Flinks-Engine-Room.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>
