You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by rm...@apache.org on 2016/08/30 09:29:18 UTC
[4/4] flink-web git commit: rebuild website
rebuild website
Project: http://git-wip-us.apache.org/repos/asf/flink-web/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink-web/commit/8d02e41d
Tree: http://git-wip-us.apache.org/repos/asf/flink-web/tree/8d02e41d
Diff: http://git-wip-us.apache.org/repos/asf/flink-web/diff/8d02e41d
Branch: refs/heads/asf-site
Commit: 8d02e41db140f49b50eb3f6fcbc7f835af1f5d8b
Parents: 8000aad
Author: Robert Metzger <rm...@apache.org>
Authored: Tue Aug 30 11:28:47 2016 +0200
Committer: Robert Metzger <rm...@apache.org>
Committed: Tue Aug 30 11:28:47 2016 +0200
----------------------------------------------------------------------
content/blog/feed.xml | 63 +++++++++++---------
content/blog/index.html | 4 +-
content/blog/page2/index.html | 4 +-
content/blog/page3/index.html | 4 +-
content/blog/page4/index.html | 4 +-
.../release_1.0.0-changelog_known_issues.html | 4 +-
content/blog/release_1.1.0-changelog.html | 4 +-
content/community.html | 10 ++--
content/community.md.orig | 4 +-
content/contribute-code.html | 4 +-
content/contribute-documentation.html | 4 +-
content/downloads.html | 20 +++----
content/faq.html | 4 +-
content/features.html | 12 ++--
content/how-to-contribute.html | 4 +-
content/improve-website.html | 4 +-
content/index.html | 12 ++--
content/material.html | 4 +-
content/news/2014/08/26/release-0.6.html | 4 +-
content/news/2014/09/26/release-0.6.1.html | 4 +-
content/news/2014/10/03/upcoming_events.html | 4 +-
content/news/2014/11/04/release-0.7.0.html | 4 +-
.../news/2014/11/18/hadoop-compatibility.html | 4 +-
content/news/2015/01/06/december-in-flink.html | 4 +-
content/news/2015/01/21/release-0.8.html | 4 +-
content/news/2015/02/04/january-in-flink.html | 4 +-
content/news/2015/02/09/streaming-example.html | 53 ++++++++--------
.../news/2015/03/02/february-2015-in-flink.html | 12 ++--
.../peeking-into-Apache-Flinks-Engine-Room.html | 4 +-
content/news/2015/04/07/march-in-flink.html | 4 +-
.../2015/04/13/release-0.9.0-milestone1.html | 4 +-
.../05/11/Juggling-with-Bits-and-Bytes.html | 4 +-
.../news/2015/05/14/Community-update-April.html | 4 +-
.../announcing-apache-flink-0.9.0-release.html | 4 +-
.../2015/08/24/introducing-flink-gelly.html | 4 +-
content/news/2015/09/01/release-0.9.1.html | 4 +-
content/news/2015/09/03/flink-forward.html | 4 +-
content/news/2015/09/16/off-heap-memory.html | 4 +-
content/news/2015/11/16/release-0.10.0.html | 4 +-
content/news/2015/11/27/release-0.10.1.html | 4 +-
.../news/2015/12/04/Introducing-windows.html | 4 +-
.../news/2015/12/11/storm-compatibility.html | 4 +-
content/news/2015/12/18/a-year-in-review.html | 4 +-
content/news/2016/02/11/release-0.10.2.html | 4 +-
content/news/2016/03/08/release-1.0.0.html | 4 +-
content/news/2016/04/06/cep-monitoring.html | 4 +-
content/news/2016/04/06/release-1.0.1.html | 4 +-
.../news/2016/04/14/flink-forward-announce.html | 4 +-
content/news/2016/04/22/release-1.0.2.html | 4 +-
content/news/2016/05/11/release-1.0.3.html | 4 +-
content/news/2016/05/24/stream-sql.html | 4 +-
content/news/2016/08/08/release-1.1.0.html | 10 +++-
content/news/2016/08/11/release-1.1.1.html | 4 +-
content/poweredby.html | 4 +-
content/privacy-policy.html | 4 +-
content/project.html | 4 +-
content/slides.html | 4 +-
57 files changed, 201 insertions(+), 187 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink-web/blob/8d02e41d/content/blog/feed.xml
----------------------------------------------------------------------
diff --git a/content/blog/feed.xml b/content/blog/feed.xml
index d6efbc4..98aac6e 100644
--- a/content/blog/feed.xml
+++ b/content/blog/feed.xml
@@ -134,6 +134,12 @@
<p>A more detailed introduction can be found in the <a href="http://flink.apache.org/news/2016/04/06/cep-monitoring.html">Flink blog</a> and the <a href="https://ci.apache.org/projects/flink/flink-docs-release-1.1/apis/streaming/libs/cep.html">CEP documentation</a>.</p>
+<h2 id="graph-generators-and-new-gelly-library-algorithms">Graph generators and new Gelly library algorithms</h2>
+
+<p>This release includes many enhancements and new features for graph processing. Gelly now provides a collection of scalable graph generators for common graph types, such as complete, cycle, grid, hypercube, and RMat graphs. A variety of new graph algorithms have been added to the Gelly library, including Global and Local Clustering Coefficient, HITS, and similarity measures (Jaccard and Adamic-Adar).</p>
+
+<p>For a full list of new graph processing features, check out the <a href="https://ci.apache.org/projects/flink/flink-docs-release-1.1/apis/batch/libs/gelly.html">Gelly documentation</a>.</p>
+
<h2 id="metrics">Metrics</h2>
<p>Flink\u2019s new metrics system allows you to easily gather and expose metrics from your user application to external systems. You can add counters, gauges, and histograms to your application via the runtime context:</p>
@@ -4176,11 +4182,11 @@ the web. Here are some examples:</p>
directly. Here\u2019s for example a calculation of shortest paths in a
graph:</p>
-<div class="highlight"><pre><code class="language-java" data-lang="java"><span class="n">Graph</span><span class="o">&lt;</span><span class="n">Long</span><span class="o">,</span> <span class="n">Double</span><span class="o">,</span> <span class="n">Double</span><span class="o">&gt;</span> <span class="n">graph</span> <span class="o">=</span> <span class="n">Graph</span><span class="o">.</span><span class="na">fromDataSet</span><span class="o">(</span><span class="n">vertices</span><span class="o">,</span> <span class="n">edges</span><span class="o"
;>,</span> <span class="n">env</span><span class="o">);</span>
+<figure class="highlight"><pre><code class="language-java" data-lang="java"><span class="n">Graph</span><span class="o">&lt;</span><span class="n">Long</span><span class="o">,</span> <span class="n">Double</span><span class="o">,</span> <span class="n">Double</span><span class="o">&gt;</span> <span class="n">graph</span> <span class="o">=</span> <span class="n">Graph</span><span class="o">.</span><span class="na">fromDataSet</span><span class="o">(</span><span class="n">vertices</span><span class="o">,</span> <span class="n">edges</span><span class="o&q
uot;>,</span> <span class="n">env</span><span class="o">);</span>
<span class="n">DataSet</span><span class="o">&lt;</span><span class="n">Vertex</span><span class="o">&lt;</span><span class="n">Long</span><span class="o">,</span> <span class="n">Double</span><span class="o">&gt;&gt;</span> <span class="n">singleSourceShortestPaths</span> <span class="o">=</span> <span class="n">graph</span>
<span class="o">.</span><span class="na">run</span><span class="o">(</span><span class="k">new</span> <span class="n">SingleSourceShortestPaths</span><span class="o">&lt;</span><span class="n">Long</span><span class="o">&gt;(</span><span class="n">srcVertexId</span><span class="o">,</span>
- <span class="n">maxIterations</span><span class="o">)).</span><span class="na">getVertices</span><span class="o">();</span></code></pre></div>
+ <span class="n">maxIterations</span><span class="o">)).</span><span class="na">getVertices</span><span class="o">();</span></code></pre></figure>
<p>See more Gelly examples
<a href="https://github.com/apache/flink/tree/master/flink-libraries/flink-gelly-examples">here</a>.</p>
@@ -4194,7 +4200,7 @@ and SQL support. Here\u2019s a preview on how you can read two CSV file,
assign a logical schema to, and apply transformations like filters and
joins using logical attributes rather than physical data types.</p>
-<div class="highlight"><pre><code class="language-scala" data-lang="scala"><span class="k">val</span> <span class="n">customers</span> <span class="k">=</span> <span class="n">getCustomerDataSet</span><span class="o">(</span><span class="n">env</span><span class="o">)</span>
+<figure class="highlight"><pre><code class="language-scala" data-lang="scala"><span class="k">val</span> <span class="n">customers</span> <span class="k">=</span> <span class="n">getCustomerDataSet</span><span class="o">(</span><span class="n">env</span><span class="o">)</span>
<span class="o">.</span><span class="n">as</span><span class="o">(</span><span class="-Symbol">&#39;id</span><span class="o">,</span> <span class="-Symbol">&#39;mktSegment</span><span class="o">)</span>
<span class="o">.</span><span class="n">filter</span><span class="o">(</span> <span class="-Symbol">&#39;mktSegment</span> <span class="o">===</span> <span class="s">&quot;AUTOMOBILE&quot;</span> <span class="o">)</span>
@@ -4205,7 +4211,7 @@ joins using logical attributes rather than physical data types.</p>
<span class="k">val</span> <span class="n">items</span> <span class="k">=</span>
<span class="n">orders</span><span class="o">.</span><span class="n">join</span><span class="o">(</span><span class="n">customers</span><span class="o">)</span>
<span class="o">.</span><span class="n">where</span><span class="o">(</span><span class="-Symbol">&#39;custId</span> <span class="o">===</span> <span class="-Symbol">&#39;id</span><span class="o">)</span>
- <span class="o">.</span><span class="n">select</span><span class="o">(</span><span class="-Symbol">&#39;orderId</span><span class="o">,</span> <span class="-Symbol">&#39;orderDate</span><span class="o">,</span> <span class="-Symbol">&#39;shipPrio</span><span class="o">)</span></code></pre></div>
+ <span class="o">.</span><span class="n">select</span><span class="o">(</span><span class="-Symbol">&#39;orderId</span><span class="o">,</span> <span class="-Symbol">&#39;orderDate</span><span class="o">,</span> <span class="-Symbol">&#39;shipPrio</span><span class="o">)</span></code></pre></figure>
<h3 id="access-to-hcatalog-tables">Access to HCatalog tables</h3>
@@ -4273,7 +4279,7 @@ found <a href="https://github.com/mbalassi/flink/blob/stockprices/flink-
<div class="codetabs">
<div data-lang="scala">
- <div class="highlight"><pre><code class="language-scala" data-lang="scala"><span class="k">def</span> <span class="n">main</span><span class="o">(</span><span class="n">args</span><span class="k">:</span> <span class="kt">Array</span><span class="o">[</span><span class="kt">String</span><span class="o">])</span> <span class="o">{</span>
+ <figure class="highlight"><pre><code class="language-scala" data-lang="scala"><span class="k">def</span> <span class="n">main</span><span class="o">(</span><span class="n">args</span><span class="k">:</span> <span class="kt">Array</span><span class="o">[</span><span class="kt">String</span><span class="o">])</span> <span class="o">{</span>
<span class="k">val</span> <span class="n">env</span> <span class="k">=</span> <span class="nc">StreamExecutionEnvironment</span><span class="o">.</span><span class="n">getExecutionEnvironment</span>
@@ -4296,12 +4302,12 @@ found <a href="https://github.com/mbalassi/flink/blob/stockprices/flink-
<span class="n">stockStream</span><span class="o">.</span><span class="n">print</span><span class="o">()</span>
<span class="n">env</span><span class="o">.</span><span class="n">execute</span><span class="o">(</span><span class="s">&quot;Stock stream&quot;</span><span class="o">)</span>
-<span class="o">}</span></code></pre></div>
+<span class="o">}</span></code></pre></figure>
</div>
<div data-lang="java7">
- <div class="highlight"><pre><code class="language-java" data-lang="java"><span class="kd">public</span> <span class="kd">static</span> <span class="kt">void</span> <span class="nf">main</span><span class="o">(</span><span class="n">String</span><span class="o">[]</span> <span class="n">args</span><span class="o">)</span> <span class="kd">throws</span> <span class="n">Exception</span> <span class="o">{</span>
+ <figure class="highlight"><pre><code class="language-java" data-lang="java"><span class="kd">public</span> <span class="kd">static</span> <span class="kt">void</span> <span class="nf">main</span><span class="o">(</span><span class="n">String</span><span class="o">[]</span> <span class="n">args</span><span class="o">)</span> <span class="kd">throws</span> <span class="n">Exception</span> <span class="o">{</span>
<span class="kd">final</span> <span class="n">StreamExecutionEnvironment</span> <span class="n">env</span> <span class="o">=</span>
<span class="n">StreamExecutionEnvironment</span><span class="o">.</span><span class="na">getExecutionEnvironment</span><span class="o">();</span>
@@ -4332,7 +4338,8 @@ found <a href="https://github.com/mbalassi/flink/blob/stockprices/flink-
<span class="n">stockStream</span><span class="o">.</span><span class="na">print</span><span class="o">();</span>
- <span class="n">env</span><span class="o">.</span><span class="na">execute</span><span class="o">(</span><span class="s">&quot;Stock stream&quot;</span><span class="o">);</span></code></pre></div>
+ <span class="n">env</span><span class="o">.</span><span class="na">execute</span><span class="o">(</span><span class="s">&quot;Stock stream&quot;</span><span class="o">);</span>
+ </code></pre></figure>
</div>
</div>
@@ -4350,7 +4357,7 @@ of this example, the data streams are simply generated using the
<div class="codetabs">
<div data-lang="scala">
- <div class="highlight"><pre><code class="language-scala" data-lang="scala"><span class="k">val</span> <span class="n">symbols</span> <span class="k">=</span> <span class="nc">List</span><span class="o">(</span><span class="s">&quot;SPX&quot;</span><span class="o">,</span> <span class="s">&quot;FTSE&quot;</span><span class="o">,</span> <span class="s">&quot;DJI&quot;</span><span class="o">,</span> <span class="s">&quot;DJT&quot;</span><span class="o">,</span> <span class="s">&quot;BUX&quot;</span><span class="o">,</span> <span class="s">&quot;DAX&
;quot;</span><span class="o">,</span> <span class="s">&quot;GOOG&quot;</span><span class="o">)</span>
+ <figure class="highlight"><pre><code class="language-scala" data-lang="scala"><span class="k">val</span> <span class="n">symbols</span> <span class="k">=</span> <span class="nc">List</span><span class="o">(</span><span class="s">&quot;SPX&quot;</span><span class="o">,</span> <span class="s">&quot;FTSE&quot;</span><span class="o">,</span> <span class="s">&quot;DJI&quot;</span><span class="o">,</span> <span class="s">&quot;DJT&quot;</span><span class="o">,</span> <span class="s">&quot;BUX&quot;</span><span class="o">,</span> <span class="s">&quot;DAX&
amp;quot;</span><span class="o">,</span> <span class="s">&quot;GOOG&quot;</span><span class="o">)</span>
<span class="k">case</span> <span class="k">class</span> <span class="nc">StockPrice</span><span class="o">(</span><span class="n">symbol</span><span class="k">:</span> <span class="kt">String</span><span class="o">,</span> <span class="n">price</span><span class="k">:</span> <span class="kt">Double</span><span class="o">)</span>
@@ -4361,12 +4368,12 @@ of this example, the data streams are simply generated using the
<span class="n">out</span><span class="o">.</span><span class="n">collect</span><span class="o">(</span><span class="nc">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="nc">Thread</span><span class="o">.</span><span class="n">sleep</span><span class="o">(</span><span class="nc">Random</span><span class="o">.</span><span class="n">nextInt</span><span class="o">(</span><span class="mi">200</span><span class="o">))</span>
<span class="o">}</span>
-<span class="o">}</span></code></pre></div>
+<span class="o">}</span></code></pre></figure>
</div>
<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">ArrayList</span><span class="o">&lt;</span><span class="n">String</span><span class="o">&gt;</span> <span class="n">SYMBOLS</span> <span class="o">=</span> <span class="k">new</span> <span class="n">ArrayList</span><span class="o">&lt;</span><span class="n">String</span><span class="o">&gt;(</span>
+ <figure 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">ArrayList</span><span class="o">&lt;</span><span class="n">String</span><span class="o">&gt;</span> <span class="n">SYMBOLS</span> <span class="o">=</span> <span class="k">new</span> <span class="n">ArrayList</span><span class="o">&lt;</span><span class="n">String</span><span class="o">&gt;(</span>
<span class="n">Arrays</span><span class="o">.</span><span class="na">asList</span><span class="o">(</span><span class="s">&quot;SPX&quot;</span><span class="o">,</span> <span class="s">&quot;FTSE&quot;</span><span class="o">,</span> <span class="s">&quot;DJI&quot;</span><span class="o">,</span> <span class="s">&quot;DJT&quot;</span><span class="o">,</span> <span class="s">&quot;BUX&quot;</span><span class="o">,</span> <span class="s">&quot;DAX&quot;</span><span class="o">,</span> <span class="s">&quot;GOOG&quot;</span><span class="o">));<
;/span>
<span class="kd">public</span> <span class="kd">static</span> <span class="kd">class</span> <span class="nc">StockPrice</span> <span class="kd">implements</span> <span class="n">Serializable</span> <span class="o">{</span>
@@ -4413,7 +4420,7 @@ of this example, the data streams are simply generated using the
<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>
-<span class="o">}</span></code></pre></div>
+<span class="o">}</span></code></pre></figure>
</div>
</div>
@@ -4466,7 +4473,7 @@ performed on named fields of POJOs, making the code more readable.</p>
<div data-lang="scala">
- <div class="highlight"><pre><code class="language-scala" data-lang="scala"><span class="c1">//Define the desired time window</span>
+ <figure class="highlight"><pre><code class="language-scala" data-lang="scala"><span class="c1">//Define the desired time window</span>
<span class="k">val</span> <span class="n">windowedStream</span> <span class="k">=</span> <span class="n">stockStream</span>
<span class="o">.</span><span class="n">window</span><span class="o">(</span><span class="nc">Time</span><span class="o">.</span><span class="n">of</span><span class="o">(</span><span class="mi">10</span><span class="o">,</span> <span class="nc">SECONDS</span><span class="o">)).</span><span class="n">every</span><span class="o">(</span><span class="nc">Time</span><span class="o">.</span><span class="n">of</span><span class="o">(</span><span class="mi">5</span><span class="o">,</span> <span class="nc">SECONDS</span><span class="o">))&
lt;/span>
@@ -4480,13 +4487,13 @@ performed on named fields of POJOs, making the code more readable.</p>
<span class="k">if</span> <span class="o">(</span><span class="n">ts</span><span class="o">.</span><span class="n">nonEmpty</span><span class="o">)</span> <span class="o">{</span>
<span class="n">out</span><span class="o">.</span><span class="n">collect</span><span class="o">(</span><span class="nc">StockPrice</span><span class="o">(</span><span class="n">ts</span><span class="o">.</span><span class="n">head</span><span class="o">.</span><span class="n">symbol</span><span class="o">,</span> <span class="n">ts</span><span class="o">.</span><span class="n">foldLeft</span><span class="o">(</span><span class="mi">0</span><span class="k">:</span> <span class="kt">Double</span><span class="o">)(</span><span class="k"
>_</span> <span class="o">+</span> <span class="k">_</span><span class="o">.</span><span class="n">price</span><span class="o">)</span> <span class="o">/</span> <span class="n">ts</span><span class="o">.</span><span class="n">size</span><span class="o">))</span>
<span class="o">}</span>
-<span class="o">}</span></code></pre></div>
+<span class="o">}</span></code></pre></figure>
</div>
<div data-lang="java7">
- <div class="highlight"><pre><code class="language-java" data-lang="java"><span class="c1">//Define the desired time window</span>
+ <figure class="highlight"><pre><code class="language-java" data-lang="java"><span class="c1">//Define the desired time window</span>
<span class="n">WindowedDataStream</span><span class="o">&lt;</span><span class="n">StockPrice</span><span class="o">&gt;</span> <span class="n">windowedStream</span> <span class="o">=</span> <span class="n">stockStream</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">10</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">every</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">5</span><span class="o">,</span> <span class="n">TimeUnit</span><span class="o">.</span><span class="na">SECONDS</span><span class="o">));</span>
@@ -4519,7 +4526,7 @@ performed on named fields of POJOs, making the code more readable.</p>
<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="o">}</span>
<span class="o">}</span>
-<span class="o">}</span></code></pre></div>
+<span class="o">}</span></code></pre></figure>
</div>
@@ -4549,7 +4556,7 @@ every 30 seconds.</p>
<div data-lang="scala">
- <div class="highlight"><pre><code class="language-scala" data-lang="scala"><span class="k">case</span> <span class="k">class</span> <span class="nc">Count</span><span class="o">(</span><span class="n">symbol</span><span class="k">:</span> <span class="kt">String</span><span class="o">,</span> <span class="n">count</span><span class="k">:</span> <span class="kt">Int</span><span class="o">)</span>
+ <figure class="highlight"><pre><code class="language-scala" data-lang="scala"><span class="k">case</span> <span class="k">class</span> <span class="nc">Count</span><span class="o">(</span><span class="n">symbol</span><span class="k">:</span> <span class="kt">String</span><span class="o">,</span> <span class="n">count</span><span class="k">:</span> <span class="kt">Int</span><span class="o">)</span>
<span class="k">val</span> <span class="n">defaultPrice</span> <span class="k">=</span> <span class="nc">StockPrice</span><span class="o">(</span><span class="s">&quot;&quot;</span><span class="o">,</span> <span class="mi">1000</span><span class="o">)</span>
<span class="c1">//Use delta policy to create price change warnings</span>
@@ -4569,13 +4576,13 @@ every 30 seconds.</p>
<span class="k">def</span> <span class="n">sendWarning</span><span class="o">(</span><span class="n">ts</span><span class="k">:</span> <span class="kt">Iterable</span><span class="o">[</span><span class="kt">StockPrice</span><span class="o">],</span> <span class="n">out</span><span class="k">:</span> <span class="kt">Collector</span><span class="o">[</span><span class="kt">String</span><span class="o">])</span> <span class="k">=</span> <span class="o">{</span>
<span class="k">if</span> <span class="o">(</span><span class="n">ts</span><span class="o">.</span><span class="n">nonEmpty</span><span class="o">)</span> <span class="n">out</span><span class="o">.</span><span class="n">collect</span><span class="o">(</span><span class="n">ts</span><span class="o">.</span><span class="n">head</span><span class="o">.</span><span class="n">symbol</span><span class="o">)</span>
-<span class="o">}</span></code></pre></div>
+<span class="o">}</span></code></pre></figure>
</div>
<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>
+ <figure 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">&quot;&quot;</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>
@@ -4626,7 +4633,7 @@ every 30 seconds.</p>
<span class="n">out</span><span class="o">.</span><span class="na">collect</span><span class="o">(</span><span class="n">values</span><span class="o">.</span><span class="na">iterator</span><span class="o">().</span><span class="na">next</span><span class="o">().</span><span class="na">symbol</span><span class="o">);</span>
<span class="o">}</span>
<span class="o">}</span>
-<span class="o">}</span></code></pre></div>
+<span class="o">}</span></code></pre></figure>
</div>
@@ -4647,7 +4654,7 @@ but for the sake of this example we generate dummy tweet data.</p>
<div data-lang="scala">
- <div class="highlight"><pre><code class="language-scala" data-lang="scala"><span class="c1">//Read a stream of tweets</span>
+ <figure class="highlight"><pre><code class="language-scala" data-lang="scala"><span class="c1">//Read a stream of tweets</span>
<span class="k">val</span> <span class="n">tweetStream</span> <span class="k">=</span> <span class="n">env</span><span class="o">.</span><span class="n">addSource</span><span class="o">(</span><span class="n">generateTweets</span> <span class="k">_</span><span class="o">)</span>
<span class="c1">//Extract the stock symbols</span>
@@ -4667,13 +4674,13 @@ but for the sake of this example we generate dummy tweet data.</p>
<span class="n">out</span><span class="o">.</span><span class="n">collect</span><span class="o">(</span><span class="n">s</span><span class="o">.</span><span class="n">mkString</span><span class="o">(</span><span class="s">&quot; &quot;</span><span class="o">))</span>
<span class="nc">Thread</span><span class="o">.</span><span class="n">sleep</span><span class="o">(</span><span class="nc">Random</span><span class="o">.</span><span class="n">nextInt</span><span class="o">(</span><span class="mi">500</span><span class="o">))</span>
<span class="o">}</span>
-<span class="o">}</span></code></pre></div>
+<span class="o">}</span></code></pre></figure>
</div>
<div data-lang="java7">
- <div class="highlight"><pre><code class="language-java" data-lang="java"><span class="c1">//Read a stream of tweets</span>
+ <figure 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">&lt;</span><span class="n">String</span><span class="o">&gt;</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="c1">//Extract the stock symbols</span>
@@ -4721,7 +4728,7 @@ but for the sake of this example we generate dummy tweet data.</p>
<span class="o">}</span>
<span class="o">}</span>
-<span class="o">}</span></code></pre></div>
+<span class="o">}</span></code></pre></figure>
</div>
@@ -4743,7 +4750,7 @@ these data streams are potentially infinite, we apply the join on a
<div data-lang="scala">
- <div class="highlight"><pre><code class="language-scala" data-lang="scala"><span class="c1">//Join warnings and parsed tweets</span>
+ <figure class="highlight"><pre><code class="language-scala" data-lang="scala"><span class="c1">//Join warnings and parsed tweets</span>
<span class="k">val</span> <span class="n">tweetsAndWarning</span> <span class="k">=</span> <span class="n">warningsPerStock</span><span class="o">.</span><span class="n">join</span><span class="o">(</span><span class="n">tweetsPerStock</span><span class="o">)</span>
<span class="o">.</span><span class="n">onWindow</span><span class="o">(</span><span class="mi">30</span><span class="o">,</span> <span class="nc">SECONDS</span><span class="o">)</span>
<span class="o">.</span><span class="n">where</span><span class="o">(</span><span class="s">&quot;symbol&quot;</span><span class="o">)</span>
@@ -4768,13 +4775,13 @@ these data streams are potentially infinite, we apply the join on a
<span class="n">out</span><span class="o">.</span><span class="n">collect</span><span class="o">(</span><span class="n">cov</span> <span class="o">/</span> <span class="o">(</span><span class="n">d1</span> <span class="o">*</span> <span class="n">d2</span><span class="o">))</span>
<span class="o">}</span>
-<span class="o">}</span></code></pre></div>
+<span class="o">}</span></code></pre></figure>
</div>
<div data-lang="java7">
- <div class="highlight"><pre><code class="language-java" data-lang="java"><span class="c1">//Join warnings and parsed tweets</span>
+ <figure class="highlight"><pre><code class="language-java" data-lang="java"><span class="c1">//Join warnings and parsed tweets</span>
<span class="n">DataStream</span><span class="o">&lt;</span><span class="n">Tuple2</span><span class="o">&lt;</span><span class="n">Integer</span><span class="o">,</span> <span class="n">Integer</span><span class="o">&gt;&gt;</span> <span class="n">tweetsAndWarning</span> <span class="o">=</span> <span class="n">warningsPerStock</span>
<span class="o">.</span><span class="na">join</span><span class="o">(</span><span class="n">tweetsPerStock</span><span class="o">)</span>
<span class="o">.</span><span class="na">onWindow</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>
@@ -4844,7 +4851,7 @@ these data streams are potentially infinite, we apply the join on a
<span class="n">out</span><span class="o">.</span><span class="na">collect</span><span class="o">(</span><span class="n">cov</span> <span class="o">/</span> <span class="o">(</span><span class="n">leftSd</span> <span class="o">*</span> <span class="n">rightSd</span><span class="o">));</span>
<span class="o">}</span>
-<span class="o">}</span></code></pre></div>
+<span class="o">}</span></code></pre></figure>
</div>
http://git-wip-us.apache.org/repos/asf/flink-web/blob/8d02e41d/content/blog/index.html
----------------------------------------------------------------------
diff --git a/content/blog/index.html b/content/blog/index.html
index 1cd47a8..1b8ab38 100644
--- a/content/blog/index.html
+++ b/content/blog/index.html
@@ -680,8 +680,8 @@
<hr />
<div class="footer text-center">
- <p>Copyright � 2014-2015 <a href="http://apache.org">The Apache Software Foundation</a>. All Rights Reserved.</p>
- <p>Apache Flink, Apache, and the Apache feather logo are trademarks of The Apache Software Foundation.</p>
+ <p>Copyright � 2014-2016 <a href="http://apache.org">The Apache Software Foundation</a>. All Rights Reserved.</p>
+ <p>Apache Flink, Apache, and the Apache feather logo are either registered trademarks or trademarks of The Apache Software Foundation.</p>
<p><a href="/privacy-policy.html">Privacy Policy</a> · <a href="/blog/feed.xml">RSS feed</a></p>
</div>
http://git-wip-us.apache.org/repos/asf/flink-web/blob/8d02e41d/content/blog/page2/index.html
----------------------------------------------------------------------
diff --git a/content/blog/page2/index.html b/content/blog/page2/index.html
index 6ece937..0aa3f88 100644
--- a/content/blog/page2/index.html
+++ b/content/blog/page2/index.html
@@ -684,8 +684,8 @@ vertex-centric or gather-sum-apply to Flink dataflows.</p>
<hr />
<div class="footer text-center">
- <p>Copyright � 2014-2015 <a href="http://apache.org">The Apache Software Foundation</a>. All Rights Reserved.</p>
- <p>Apache Flink, Apache, and the Apache feather logo are trademarks of The Apache Software Foundation.</p>
+ <p>Copyright � 2014-2016 <a href="http://apache.org">The Apache Software Foundation</a>. All Rights Reserved.</p>
+ <p>Apache Flink, Apache, and the Apache feather logo are either registered trademarks or trademarks of The Apache Software Foundation.</p>
<p><a href="/privacy-policy.html">Privacy Policy</a> · <a href="/blog/feed.xml">RSS feed</a></p>
</div>
http://git-wip-us.apache.org/repos/asf/flink-web/blob/8d02e41d/content/blog/page3/index.html
----------------------------------------------------------------------
diff --git a/content/blog/page3/index.html b/content/blog/page3/index.html
index 0d5cf40..0b3c591 100644
--- a/content/blog/page3/index.html
+++ b/content/blog/page3/index.html
@@ -690,8 +690,8 @@ and offers a new API including definition of flexible windows.</p>
<hr />
<div class="footer text-center">
- <p>Copyright � 2014-2015 <a href="http://apache.org">The Apache Software Foundation</a>. All Rights Reserved.</p>
- <p>Apache Flink, Apache, and the Apache feather logo are trademarks of The Apache Software Foundation.</p>
+ <p>Copyright � 2014-2016 <a href="http://apache.org">The Apache Software Foundation</a>. All Rights Reserved.</p>
+ <p>Apache Flink, Apache, and the Apache feather logo are either registered trademarks or trademarks of The Apache Software Foundation.</p>
<p><a href="/privacy-policy.html">Privacy Policy</a> · <a href="/blog/feed.xml">RSS feed</a></p>
</div>
http://git-wip-us.apache.org/repos/asf/flink-web/blob/8d02e41d/content/blog/page4/index.html
----------------------------------------------------------------------
diff --git a/content/blog/page4/index.html b/content/blog/page4/index.html
index fffd0ca..290c472 100644
--- a/content/blog/page4/index.html
+++ b/content/blog/page4/index.html
@@ -621,8 +621,8 @@ academic and open source project that Flink originates from.</p>
<hr />
<div class="footer text-center">
- <p>Copyright � 2014-2015 <a href="http://apache.org">The Apache Software Foundation</a>. All Rights Reserved.</p>
- <p>Apache Flink, Apache, and the Apache feather logo are trademarks of The Apache Software Foundation.</p>
+ <p>Copyright � 2014-2016 <a href="http://apache.org">The Apache Software Foundation</a>. All Rights Reserved.</p>
+ <p>Apache Flink, Apache, and the Apache feather logo are either registered trademarks or trademarks of The Apache Software Foundation.</p>
<p><a href="/privacy-policy.html">Privacy Policy</a> · <a href="/blog/feed.xml">RSS feed</a></p>
</div>
http://git-wip-us.apache.org/repos/asf/flink-web/blob/8d02e41d/content/blog/release_1.0.0-changelog_known_issues.html
----------------------------------------------------------------------
diff --git a/content/blog/release_1.0.0-changelog_known_issues.html b/content/blog/release_1.0.0-changelog_known_issues.html
index 38bc5d2..b759165 100644
--- a/content/blog/release_1.0.0-changelog_known_issues.html
+++ b/content/blog/release_1.0.0-changelog_known_issues.html
@@ -1124,8 +1124,8 @@
<hr />
<div class="footer text-center">
- <p>Copyright � 2014-2015 <a href="http://apache.org">The Apache Software Foundation</a>. All Rights Reserved.</p>
- <p>Apache Flink, Apache, and the Apache feather logo are trademarks of The Apache Software Foundation.</p>
+ <p>Copyright � 2014-2016 <a href="http://apache.org">The Apache Software Foundation</a>. All Rights Reserved.</p>
+ <p>Apache Flink, Apache, and the Apache feather logo are either registered trademarks or trademarks of The Apache Software Foundation.</p>
<p><a href="/privacy-policy.html">Privacy Policy</a> · <a href="/blog/feed.xml">RSS feed</a></p>
</div>
http://git-wip-us.apache.org/repos/asf/flink-web/blob/8d02e41d/content/blog/release_1.1.0-changelog.html
----------------------------------------------------------------------
diff --git a/content/blog/release_1.1.0-changelog.html b/content/blog/release_1.1.0-changelog.html
index e60aaf2..a276f6f 100644
--- a/content/blog/release_1.1.0-changelog.html
+++ b/content/blog/release_1.1.0-changelog.html
@@ -674,8 +674,8 @@
<hr />
<div class="footer text-center">
- <p>Copyright � 2014-2015 <a href="http://apache.org">The Apache Software Foundation</a>. All Rights Reserved.</p>
- <p>Apache Flink, Apache, and the Apache feather logo are trademarks of The Apache Software Foundation.</p>
+ <p>Copyright � 2014-2016 <a href="http://apache.org">The Apache Software Foundation</a>. All Rights Reserved.</p>
+ <p>Apache Flink, Apache, and the Apache feather logo are either registered trademarks or trademarks of The Apache Software Foundation.</p>
<p><a href="/privacy-policy.html">Privacy Policy</a> · <a href="/blog/feed.xml">RSS feed</a></p>
</div>
http://git-wip-us.apache.org/repos/asf/flink-web/blob/8d02e41d/content/community.html
----------------------------------------------------------------------
diff --git a/content/community.html b/content/community.html
index 3f06251..acbf076 100644
--- a/content/community.html
+++ b/content/community.html
@@ -489,7 +489,7 @@ See Suneel Marthi\u2019s <a href="http://www.slideshare.net/FlinkForward/suneel-mar
<td class="text-center">senorcarbone</td>
</tr>
<tr>
- <td class="text-center" width="10%"><img src="https://avatars3.githubusercontent.com/u/1756620?s=50" /></td>
+ <td class="text-center" width="10%"><img src="https://avatars3.githubusercontent.com/u/1756620?s=50" /></a></td>
<td class="text-center">Ufuk Celebi</td>
<td class="text-center">PMC, Committer</td>
<td class="text-center">uce</td>
@@ -524,7 +524,7 @@ See Suneel Marthi\u2019s <a href="http://www.slideshare.net/FlinkForward/suneel-mar
<td class="text-center">PMC, Committer</td>
<td class="text-center">vasia</td>
</tr>
-
+ </tr>
<tr>
<td class="text-center"><img src="https://avatars0.githubusercontent.com/u/68551?s=50" /></td>
<td class="text-center">Aljoscha Krettek</td>
@@ -648,7 +648,7 @@ See Suneel Marthi\u2019s <a href="http://www.slideshare.net/FlinkForward/suneel-mar
<td class="text-center">Former PPMC, Mentor</td>
<td class="text-center">gates</td>
</tr>
-
+ </tr>
<tr>
<td class="text-center"></td>
<td class="text-center">Owen O'Malley</td>
@@ -676,8 +676,8 @@ See Suneel Marthi\u2019s <a href="http://www.slideshare.net/FlinkForward/suneel-mar
<hr />
<div class="footer text-center">
- <p>Copyright � 2014-2015 <a href="http://apache.org">The Apache Software Foundation</a>. All Rights Reserved.</p>
- <p>Apache Flink, Apache, and the Apache feather logo are trademarks of The Apache Software Foundation.</p>
+ <p>Copyright � 2014-2016 <a href="http://apache.org">The Apache Software Foundation</a>. All Rights Reserved.</p>
+ <p>Apache Flink, Apache, and the Apache feather logo are either registered trademarks or trademarks of The Apache Software Foundation.</p>
<p><a href="/privacy-policy.html">Privacy Policy</a> · <a href="/blog/feed.xml">RSS feed</a></p>
</div>
http://git-wip-us.apache.org/repos/asf/flink-web/blob/8d02e41d/content/community.md.orig
----------------------------------------------------------------------
diff --git a/content/community.md.orig b/content/community.md.orig
index f85ddaa..1f1b112 100644
--- a/content/community.md.orig
+++ b/content/community.md.orig
@@ -639,8 +639,8 @@ The following people were very kind to mentor the project while in incubation.
<hr />
<div class="footer text-center">
- <p>Copyright � 2014-2015 <a href="http://apache.org">The Apache Software Foundation</a>. All Rights Reserved.</p>
- <p>Apache Flink, Apache, and the Apache feather logo are trademarks of The Apache Software Foundation.</p>
+ <p>Copyright � 2014-2016 <a href="http://apache.org">The Apache Software Foundation</a>. All Rights Reserved.</p>
+ <p>Apache Flink, Apache, and the Apache feather logo are either registered trademarks or trademarks of The Apache Software Foundation.</p>
<p><a href="/privacy-policy.html">Privacy Policy</a> · <a href="/blog/feed.xml">RSS feed</a></p>
</div>
http://git-wip-us.apache.org/repos/asf/flink-web/blob/8d02e41d/content/contribute-code.html
----------------------------------------------------------------------
diff --git a/content/contribute-code.html b/content/contribute-code.html
index 43f20a2..b09c61e 100644
--- a/content/contribute-code.html
+++ b/content/contribute-code.html
@@ -501,8 +501,8 @@ before its release. Only builds that pass all tests are published here.</p>
<hr />
<div class="footer text-center">
- <p>Copyright � 2014-2015 <a href="http://apache.org">The Apache Software Foundation</a>. All Rights Reserved.</p>
- <p>Apache Flink, Apache, and the Apache feather logo are trademarks of The Apache Software Foundation.</p>
+ <p>Copyright � 2014-2016 <a href="http://apache.org">The Apache Software Foundation</a>. All Rights Reserved.</p>
+ <p>Apache Flink, Apache, and the Apache feather logo are either registered trademarks or trademarks of The Apache Software Foundation.</p>
<p><a href="/privacy-policy.html">Privacy Policy</a> · <a href="/blog/feed.xml">RSS feed</a></p>
</div>
http://git-wip-us.apache.org/repos/asf/flink-web/blob/8d02e41d/content/contribute-documentation.html
----------------------------------------------------------------------
diff --git a/content/contribute-documentation.html b/content/contribute-documentation.html
index 2b8dc27..4621bfc 100644
--- a/content/contribute-documentation.html
+++ b/content/contribute-documentation.html
@@ -233,8 +233,8 @@
<hr />
<div class="footer text-center">
- <p>Copyright � 2014-2015 <a href="http://apache.org">The Apache Software Foundation</a>. All Rights Reserved.</p>
- <p>Apache Flink, Apache, and the Apache feather logo are trademarks of The Apache Software Foundation.</p>
+ <p>Copyright � 2014-2016 <a href="http://apache.org">The Apache Software Foundation</a>. All Rights Reserved.</p>
+ <p>Apache Flink, Apache, and the Apache feather logo are either registered trademarks or trademarks of The Apache Software Foundation.</p>
<p><a href="/privacy-policy.html">Privacy Policy</a> · <a href="/blog/feed.xml">RSS feed</a></p>
</div>
http://git-wip-us.apache.org/repos/asf/flink-web/blob/8d02e41d/content/downloads.html
----------------------------------------------------------------------
diff --git a/content/downloads.html b/content/downloads.html
index 13e5674..9b6da78 100644
--- a/content/downloads.html
+++ b/content/downloads.html
@@ -185,7 +185,7 @@ $( document ).ready(function() {
<h2 id="latest-stable-release-v111">Latest stable release (v1.1.1)</h2>
-<p>Apache Flink 1.1.1 is our latest stable release.</p>
+<p>Apache Flink� 1.1.1 is our latest stable release.</p>
<p>You
<a href="faq.html#do-i-have-to-install-apache-hadoop-to-use-flink">don\u2019t have to install Hadoop</a>
@@ -203,36 +203,36 @@ pick the Hadoop 1 version.</p>
</thead>
<tbody>
<tr>
- <th>Hadoop 1.2.1</th>
+ <th>Hadoop� 1.2.1</th>
<td><a href="http://www.apache.org/dyn/closer.lua/flink/flink-1.1.1/flink-1.1.1-bin-hadoop1-scala_2.10.tgz" class="ga-track" id="download-hadoop1">Download</a></td>
<td></td>
</tr>
<tr>
- <th>Hadoop 2.3.0</th>
+ <th>Hadoop� 2.3.0</th>
<td><a href="http://www.apache.org/dyn/closer.lua/flink/flink-1.1.1/flink-1.1.1-bin-hadoop2-scala_2.10.tgz" class="ga-track" id="download-hadoop2">Download</a></td>
<td><a href="http://www.apache.org/dyn/closer.lua/flink/flink-1.1.1/flink-1.1.1-bin-hadoop2-scala_2.11.tgz" class="ga-track" id="download-hadoop2_211">Download</a></td>
</tr>
<tr>
- <th>Hadoop 2.4.1</th>
+ <th>Hadoop� 2.4.1</th>
<td><a href="http://www.apache.org/dyn/closer.lua/flink/flink-1.1.1/flink-1.1.1-bin-hadoop24-scala_2.10.tgz" class="ga-track" id="download-hadoop24">Download</a></td>
<td><a href="http://www.apache.org/dyn/closer.lua/flink/flink-1.1.1/flink-1.1.1-bin-hadoop24-scala_2.11.tgz" class="ga-track" id="download-hadoop24_211">Download</a></td>
</tr>
<tr>
- <th>Hadoop 2.6.0</th>
+ <th>Hadoop� 2.6.0</th>
<td><a href="http://www.apache.org/dyn/closer.lua/flink/flink-1.1.1/flink-1.1.1-bin-hadoop26-scala_2.10.tgz" class="ga-track" id="download-hadoop26">Download</a></td>
<td><a href="http://www.apache.org/dyn/closer.lua/flink/flink-1.1.1/flink-1.1.1-bin-hadoop26-scala_2.11.tgz" class="ga-track" id="download-hadoop26_211">Download</a></td>
</tr>
<tr>
- <th>Hadoop 2.7.0</th>
+ <th>Hadoop� 2.7.0</th>
<td><a href="http://www.apache.org/dyn/closer.lua/flink/flink-1.1.1/flink-1.1.1-bin-hadoop27-scala_2.10.tgz" class="ga-track" id="download-hadoop27">Download</a></td>
<td><a href="http://www.apache.org/dyn/closer.lua/flink/flink-1.1.1/flink-1.1.1-bin-hadoop27-scala_2.11.tgz" class="ga-track" id="download-hadoop27_211">Download</a></td>
</tr>
-
+ </tr>
</tbody>
</table>
@@ -241,7 +241,7 @@ pick the Hadoop 1 version.</p>
<div class="list-group">
<!-- Source -->
<a href="http://www.apache.org/dyn/closer.lua/flink/flink-1.1.1/flink-1.1.1-src.tgz" class="list-group-item ga-track" id="download-source">
- <h4><span class="glyphicon glyphicon-download" aria-hidden="true"></span> <strong>Flink 1.1.1</strong> Source Release</h4>
+ <h4><span class="glyphicon glyphicon-download" aria-hidden="true"></span> <strong>Apache Flink� 1.1.1</strong> Source Release</h4>
<p>Review the source code or build Flink on your own, using this package</p>
</a>
</div>
@@ -298,8 +298,8 @@ pick the Hadoop 1 version.</p>
<hr />
<div class="footer text-center">
- <p>Copyright � 2014-2015 <a href="http://apache.org">The Apache Software Foundation</a>. All Rights Reserved.</p>
- <p>Apache Flink, Apache, and the Apache feather logo are trademarks of The Apache Software Foundation.</p>
+ <p>Copyright � 2014-2016 <a href="http://apache.org">The Apache Software Foundation</a>. All Rights Reserved.</p>
+ <p>Apache Flink, Apache, and the Apache feather logo are either registered trademarks or trademarks of The Apache Software Foundation.</p>
<p><a href="/privacy-policy.html">Privacy Policy</a> · <a href="/blog/feed.xml">RSS feed</a></p>
</div>
http://git-wip-us.apache.org/repos/asf/flink-web/blob/8d02e41d/content/faq.html
----------------------------------------------------------------------
diff --git a/content/faq.html b/content/faq.html
index ace7514..d02be20 100644
--- a/content/faq.html
+++ b/content/faq.html
@@ -668,8 +668,8 @@ Hadoop\u2019s counters, but are more powerful.</p>
<hr />
<div class="footer text-center">
- <p>Copyright � 2014-2015 <a href="http://apache.org">The Apache Software Foundation</a>. All Rights Reserved.</p>
- <p>Apache Flink, Apache, and the Apache feather logo are trademarks of The Apache Software Foundation.</p>
+ <p>Copyright � 2014-2016 <a href="http://apache.org">The Apache Software Foundation</a>. All Rights Reserved.</p>
+ <p>Apache Flink, Apache, and the Apache feather logo are either registered trademarks or trademarks of The Apache Software Foundation.</p>
<p><a href="/privacy-policy.html">Privacy Policy</a> · <a href="/blog/feed.xml">RSS feed</a></p>
</div>
http://git-wip-us.apache.org/repos/asf/flink-web/blob/8d02e41d/content/features.html
----------------------------------------------------------------------
diff --git a/content/features.html b/content/features.html
index fb076f7..c834d46 100644
--- a/content/features.html
+++ b/content/features.html
@@ -389,7 +389,7 @@
<div class="col-sm-7">
<p class="lead">WindowWordCount in Flink's DataStream API</p>
-<div class="highlight"><pre><code class="language-scala" data-lang="scala"><span class="k">case</span> <span class="k">class</span> <span class="nc">Word</span><span class="o">(</span><span class="n">word</span><span class="k">:</span> <span class="kt">String</span><span class="o">,</span> <span class="n">freq</span><span class="k">:</span> <span class="kt">Long</span><span class="o">)</span>
+<figure class="highlight"><pre><code class="language-scala" data-lang="scala"><span class="k">case</span> <span class="k">class</span> <span class="nc">Word</span><span class="o">(</span><span class="n">word</span><span class="k">:</span> <span class="kt">String</span><span class="o">,</span> <span class="n">freq</span><span class="k">:</span> <span class="kt">Long</span><span class="o">)</span>
<span class="k">val</span> <span class="n">texts</span><span class="k">:</span> <span class="kt">DataStream</span><span class="o">[</span><span class="kt">String</span><span class="o">]</span> <span class="k">=</span> <span class="o">...</span>
@@ -398,7 +398,7 @@
<span class="o">.</span><span class="n">map</span> <span class="o">{</span> <span class="n">token</span> <span class="k">=></span> <span class="nc">Word</span><span class="o">(</span><span class="n">token</span><span class="o">,</span> <span class="mi">1</span><span class="o">)</span> <span class="o">}</span>
<span class="o">.</span><span class="n">keyBy</span><span class="o">(</span><span class="s">"word"</span><span class="o">)</span>
<span class="o">.</span><span class="n">timeWindow</span><span class="o">(</span><span class="nc">Time</span><span class="o">.</span><span class="n">seconds</span><span class="o">(</span><span class="mi">5</span><span class="o">),</span> <span class="nc">Time</span><span class="o">.</span><span class="n">seconds</span><span class="o">(</span><span class="mi">1</span><span class="o">))</span>
- <span class="o">.</span><span class="n">sum</span><span class="o">(</span><span class="s">"freq"</span><span class="o">)</span></code></pre></div>
+ <span class="o">.</span><span class="n">sum</span><span class="o">(</span><span class="s">"freq"</span><span class="o">)</span></code></pre></figure>
</div>
</div>
@@ -418,7 +418,7 @@
</div>
<div class="col-sm-7">
-<div class="highlight"><pre><code class="language-scala" data-lang="scala"><span class="k">case</span> <span class="k">class</span> <span class="nc">Page</span><span class="o">(</span><span class="n">pageId</span><span class="k">:</span> <span class="kt">Long</span><span class="o">,</span> <span class="n">rank</span><span class="k">:</span> <span class="kt">Double</span><span class="o">)</span>
+<figure class="highlight"><pre><code class="language-scala" data-lang="scala"><span class="k">case</span> <span class="k">class</span> <span class="nc">Page</span><span class="o">(</span><span class="n">pageId</span><span class="k">:</span> <span class="kt">Long</span><span class="o">,</span> <span class="n">rank</span><span class="k">:</span> <span class="kt">Double</span><span class="o">)</span>
<span class="k">case</span> <span class="k">class</span> <span class="nc">Adjacency</span><span class="o">(</span><span class="n">id</span><span class="k">:</span> <span class="kt">Long</span><span class="o">,</span> <span class="n">neighbors</span><span class="k">:</span> <span class="kt">Array</span><span class="o">[</span><span class="kt">Long</span><span class="o">])</span>
<span class="k">val</span> <span class="n">result</span> <span class="k">=</span> <span class="n">initialRanks</span><span class="o">.</span><span class="n">iterate</span><span class="o">(</span><span class="mi">30</span><span class="o">)</span> <span class="o">{</span> <span class="n">pages</span> <span class="k">=></span>
@@ -433,7 +433,7 @@
<span class="o">}</span>
<span class="o">}</span>
<span class="o">.</span><span class="n">groupBy</span><span class="o">(</span><span class="s">"pageId"</span><span class="o">).</span><span class="n">sum</span><span class="o">(</span><span class="s">"rank"</span><span class="o">)</span>
-<span class="o">}</span></code></pre></div>
+<span class="o">}</span></code></pre></figure>
</div>
</div>
@@ -494,8 +494,8 @@
<hr />
<div class="footer text-center">
- <p>Copyright � 2014-2015 <a href="http://apache.org">The Apache Software Foundation</a>. All Rights Reserved.</p>
- <p>Apache Flink, Apache, and the Apache feather logo are trademarks of The Apache Software Foundation.</p>
+ <p>Copyright � 2014-2016 <a href="http://apache.org">The Apache Software Foundation</a>. All Rights Reserved.</p>
+ <p>Apache Flink, Apache, and the Apache feather logo are either registered trademarks or trademarks of The Apache Software Foundation.</p>
<p><a href="/privacy-policy.html">Privacy Policy</a> · <a href="/blog/feed.xml">RSS feed</a></p>
</div>
http://git-wip-us.apache.org/repos/asf/flink-web/blob/8d02e41d/content/how-to-contribute.html
----------------------------------------------------------------------
diff --git a/content/how-to-contribute.html b/content/how-to-contribute.html
index 163d0de..27db5f9 100644
--- a/content/how-to-contribute.html
+++ b/content/how-to-contribute.html
@@ -327,8 +327,8 @@
<hr />
<div class="footer text-center">
- <p>Copyright � 2014-2015 <a href="http://apache.org">The Apache Software Foundation</a>. All Rights Reserved.</p>
- <p>Apache Flink, Apache, and the Apache feather logo are trademarks of The Apache Software Foundation.</p>
+ <p>Copyright � 2014-2016 <a href="http://apache.org">The Apache Software Foundation</a>. All Rights Reserved.</p>
+ <p>Apache Flink, Apache, and the Apache feather logo are either registered trademarks or trademarks of The Apache Software Foundation.</p>
<p><a href="/privacy-policy.html">Privacy Policy</a> · <a href="/blog/feed.xml">RSS feed</a></p>
</div>
http://git-wip-us.apache.org/repos/asf/flink-web/blob/8d02e41d/content/improve-website.html
----------------------------------------------------------------------
diff --git a/content/improve-website.html b/content/improve-website.html
index 5df3a3b..70b2b9a 100644
--- a/content/improve-website.html
+++ b/content/improve-website.html
@@ -276,8 +276,8 @@ git checkout asf-site
<hr />
<div class="footer text-center">
- <p>Copyright � 2014-2015 <a href="http://apache.org">The Apache Software Foundation</a>. All Rights Reserved.</p>
- <p>Apache Flink, Apache, and the Apache feather logo are trademarks of The Apache Software Foundation.</p>
+ <p>Copyright � 2014-2016 <a href="http://apache.org">The Apache Software Foundation</a>. All Rights Reserved.</p>
+ <p>Apache Flink, Apache, and the Apache feather logo are either registered trademarks or trademarks of The Apache Software Foundation.</p>
<p><a href="/privacy-policy.html">Privacy Policy</a> · <a href="/blog/feed.xml">RSS feed</a></p>
</div>
http://git-wip-us.apache.org/repos/asf/flink-web/blob/8d02e41d/content/index.html
----------------------------------------------------------------------
diff --git a/content/index.html b/content/index.html
index ad96790..7626876 100644
--- a/content/index.html
+++ b/content/index.html
@@ -53,7 +53,7 @@
<ul class="nav navbar-nav">
<!-- Overview -->
- <li class="active"><a href="/index.html">Overview</a></li>
+ <li><a href="/index.html">Overview</a></li>
<!-- Features -->
<li><a href="/features.html">Features</a></li>
@@ -153,7 +153,7 @@
<div class="row">
- <div class="col-sm-12"><p class="lead"><strong>Apache Flink</strong> is an open source platform for distributed stream and batch data processing.</p></div>
+ <div class="col-sm-12"><p class="lead"><strong>Apache Flink�</strong> is an open source platform for distributed stream and batch data processing.</p></div>
</div>
<div class="row">
@@ -216,8 +216,8 @@
<p>Download the <strong>latest stable release</strong> and run Flink on your machine, cluster, or cloud:</p>
<div class="text-center download-button">
- <a href="downloads.html" class="btn btn-primary"><strong>Download</strong> Apache Flink 1.1</a>
- <a href="https://github.com/apache/flink" class="btn btn-info">Apache Flink on <strong>GitHub</strong></a>
+ <a href="downloads.html" class="btn btn-primary"><strong>Download</strong> Apache Flink� 1.1</a>
+ <a href="https://github.com/apache/flink" class="btn btn-info">Apache Flink� on <strong>GitHub</strong></a>
</div>
<p>The documentation contains a <a href="http://ci.apache.org/projects/flink/flink-docs-master/setup/building.html">setup guide</a> for all deployment options.</p>
@@ -290,8 +290,8 @@
<hr />
<div class="footer text-center">
- <p>Copyright � 2014-2015 <a href="http://apache.org">The Apache Software Foundation</a>. All Rights Reserved.</p>
- <p>Apache Flink, Apache, and the Apache feather logo are trademarks of The Apache Software Foundation.</p>
+ <p>Copyright � 2014-2016 <a href="http://apache.org">The Apache Software Foundation</a>. All Rights Reserved.</p>
+ <p>Apache Flink, Apache, and the Apache feather logo are either registered trademarks or trademarks of The Apache Software Foundation.</p>
<p><a href="/privacy-policy.html">Privacy Policy</a> · <a href="/blog/feed.xml">RSS feed</a></p>
</div>
http://git-wip-us.apache.org/repos/asf/flink-web/blob/8d02e41d/content/material.html
----------------------------------------------------------------------
diff --git a/content/material.html b/content/material.html
index 8b0f7e4..f746a4e 100644
--- a/content/material.html
+++ b/content/material.html
@@ -287,8 +287,8 @@
<hr />
<div class="footer text-center">
- <p>Copyright � 2014-2015 <a href="http://apache.org">The Apache Software Foundation</a>. All Rights Reserved.</p>
- <p>Apache Flink, Apache, and the Apache feather logo are trademarks of The Apache Software Foundation.</p>
+ <p>Copyright � 2014-2016 <a href="http://apache.org">The Apache Software Foundation</a>. All Rights Reserved.</p>
+ <p>Apache Flink, Apache, and the Apache feather logo are either registered trademarks or trademarks of The Apache Software Foundation.</p>
<p><a href="/privacy-policy.html">Privacy Policy</a> · <a href="/blog/feed.xml">RSS feed</a></p>
</div>
http://git-wip-us.apache.org/repos/asf/flink-web/blob/8d02e41d/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 c6dbd75..b3fa51b 100644
--- a/content/news/2014/08/26/release-0.6.html
+++ b/content/news/2014/08/26/release-0.6.html
@@ -258,8 +258,8 @@ robust, as well as breaking API changes.</p>
<hr />
<div class="footer text-center">
- <p>Copyright � 2014-2015 <a href="http://apache.org">The Apache Software Foundation</a>. All Rights Reserved.</p>
- <p>Apache Flink, Apache, and the Apache feather logo are trademarks of The Apache Software Foundation.</p>
+ <p>Copyright � 2014-2016 <a href="http://apache.org">The Apache Software Foundation</a>. All Rights Reserved.</p>
+ <p>Apache Flink, Apache, and the Apache feather logo are either registered trademarks or trademarks of The Apache Software Foundation.</p>
<p><a href="/privacy-policy.html">Privacy Policy</a> · <a href="/blog/feed.xml">RSS feed</a></p>
</div>
http://git-wip-us.apache.org/repos/asf/flink-web/blob/8d02e41d/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 b6748ac..80c012b 100644
--- a/content/news/2014/09/26/release-0.6.1.html
+++ b/content/news/2014/09/26/release-0.6.1.html
@@ -189,8 +189,8 @@ of the system. We suggest all users of Flink to work with this newest version.</
<hr />
<div class="footer text-center">
- <p>Copyright � 2014-2015 <a href="http://apache.org">The Apache Software Foundation</a>. All Rights Reserved.</p>
- <p>Apache Flink, Apache, and the Apache feather logo are trademarks of The Apache Software Foundation.</p>
+ <p>Copyright � 2014-2016 <a href="http://apache.org">The Apache Software Foundation</a>. All Rights Reserved.</p>
+ <p>Apache Flink, Apache, and the Apache feather logo are either registered trademarks or trademarks of The Apache Software Foundation.</p>
<p><a href="/privacy-policy.html">Privacy Policy</a> · <a href="/blog/feed.xml">RSS feed</a></p>
</div>
http://git-wip-us.apache.org/repos/asf/flink-web/blob/8d02e41d/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 701a7e4..428468c 100644
--- a/content/news/2014/10/03/upcoming_events.html
+++ b/content/news/2014/10/03/upcoming_events.html
@@ -274,8 +274,8 @@ properties, some algorithms)</p>
<hr />
<div class="footer text-center">
- <p>Copyright � 2014-2015 <a href="http://apache.org">The Apache Software Foundation</a>. All Rights Reserved.</p>
- <p>Apache Flink, Apache, and the Apache feather logo are trademarks of The Apache Software Foundation.</p>
+ <p>Copyright � 2014-2016 <a href="http://apache.org">The Apache Software Foundation</a>. All Rights Reserved.</p>
+ <p>Apache Flink, Apache, and the Apache feather logo are either registered trademarks or trademarks of The Apache Software Foundation.</p>
<p><a href="/privacy-policy.html">Privacy Policy</a> · <a href="/blog/feed.xml">RSS feed</a></p>
</div>
http://git-wip-us.apache.org/repos/asf/flink-web/blob/8d02e41d/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 76149c7..cb940ea 100644
--- a/content/news/2014/11/04/release-0.7.0.html
+++ b/content/news/2014/11/04/release-0.7.0.html
@@ -247,8 +247,8 @@
<hr />
<div class="footer text-center">
- <p>Copyright � 2014-2015 <a href="http://apache.org">The Apache Software Foundation</a>. All Rights Reserved.</p>
- <p>Apache Flink, Apache, and the Apache feather logo are trademarks of The Apache Software Foundation.</p>
+ <p>Copyright � 2014-2016 <a href="http://apache.org">The Apache Software Foundation</a>. All Rights Reserved.</p>
+ <p>Apache Flink, Apache, and the Apache feather logo are either registered trademarks or trademarks of The Apache Software Foundation.</p>
<p><a href="/privacy-policy.html">Privacy Policy</a> · <a href="/blog/feed.xml">RSS feed</a></p>
</div>
http://git-wip-us.apache.org/repos/asf/flink-web/blob/8d02e41d/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 c23f9b2..4fea474 100644
--- a/content/news/2014/11/18/hadoop-compatibility.html
+++ b/content/news/2014/11/18/hadoop-compatibility.html
@@ -262,8 +262,8 @@
<hr />
<div class="footer text-center">
- <p>Copyright � 2014-2015 <a href="http://apache.org">The Apache Software Foundation</a>. All Rights Reserved.</p>
- <p>Apache Flink, Apache, and the Apache feather logo are trademarks of The Apache Software Foundation.</p>
+ <p>Copyright � 2014-2016 <a href="http://apache.org">The Apache Software Foundation</a>. All Rights Reserved.</p>
+ <p>Apache Flink, Apache, and the Apache feather logo are either registered trademarks or trademarks of The Apache Software Foundation.</p>
<p><a href="/privacy-policy.html">Privacy Policy</a> · <a href="/blog/feed.xml">RSS feed</a></p>
</div>
http://git-wip-us.apache.org/repos/asf/flink-web/blob/8d02e41d/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 62c0751..17f031b 100644
--- a/content/news/2015/01/06/december-in-flink.html
+++ b/content/news/2015/01/06/december-in-flink.html
@@ -237,8 +237,8 @@ Flink serialization system improved a lot over time and by now surpasses the cap
<hr />
<div class="footer text-center">
- <p>Copyright � 2014-2015 <a href="http://apache.org">The Apache Software Foundation</a>. All Rights Reserved.</p>
- <p>Apache Flink, Apache, and the Apache feather logo are trademarks of The Apache Software Foundation.</p>
+ <p>Copyright � 2014-2016 <a href="http://apache.org">The Apache Software Foundation</a>. All Rights Reserved.</p>
+ <p>Apache Flink, Apache, and the Apache feather logo are either registered trademarks or trademarks of The Apache Software Foundation.</p>
<p><a href="/privacy-policy.html">Privacy Policy</a> · <a href="/blog/feed.xml">RSS feed</a></p>
</div>
http://git-wip-us.apache.org/repos/asf/flink-web/blob/8d02e41d/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 a215ae3..7080cbd 100644
--- a/content/news/2015/01/21/release-0.8.html
+++ b/content/news/2015/01/21/release-0.8.html
@@ -261,8 +261,8 @@
<hr />
<div class="footer text-center">
- <p>Copyright � 2014-2015 <a href="http://apache.org">The Apache Software Foundation</a>. All Rights Reserved.</p>
- <p>Apache Flink, Apache, and the Apache feather logo are trademarks of The Apache Software Foundation.</p>
+ <p>Copyright � 2014-2016 <a href="http://apache.org">The Apache Software Foundation</a>. All Rights Reserved.</p>
+ <p>Apache Flink, Apache, and the Apache feather logo are either registered trademarks or trademarks of The Apache Software Foundation.</p>
<p><a href="/privacy-policy.html">Privacy Policy</a> · <a href="/blog/feed.xml">RSS feed</a></p>
</div>
http://git-wip-us.apache.org/repos/asf/flink-web/blob/8d02e41d/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 4f9d3bd..4ed62d9 100644
--- a/content/news/2015/02/04/january-in-flink.html
+++ b/content/news/2015/02/04/january-in-flink.html
@@ -224,8 +224,8 @@
<hr />
<div class="footer text-center">
- <p>Copyright � 2014-2015 <a href="http://apache.org">The Apache Software Foundation</a>. All Rights Reserved.</p>
- <p>Apache Flink, Apache, and the Apache feather logo are trademarks of The Apache Software Foundation.</p>
+ <p>Copyright � 2014-2016 <a href="http://apache.org">The Apache Software Foundation</a>. All Rights Reserved.</p>
+ <p>Apache Flink, Apache, and the Apache feather logo are either registered trademarks or trademarks of The Apache Software Foundation.</p>
<p><a href="/privacy-policy.html">Privacy Policy</a> · <a href="/blog/feed.xml">RSS feed</a></p>
</div>