http://git-wip-us.apache.org/repos/asf/flink-web/blob/8d02e41d/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 cf03212..f02f80d 100644 --- a/content/news/2015/02/09/streaming-example.html +++ b/content/news/2015/02/09/streaming-example.html @@ -204,7 +204,7 @@ found <a href="https://github.com/mbalassi/flink/blob/stockprices/flink-staging/ <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> @@ -227,12 +227,12 @@ found <a href="https://github.com/mbalassi/flink/blob/stockprices/flink-staging/ <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">"Stock stream"</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> @@ -263,7 +263,8 @@ found <a href="https://github.com/mbalassi/flink/blob/stockprices/flink-staging/ <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">"Stock stream"</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">"Stock stream"</span><span class="o">);</span> + </code></pre></figure> </div> </div> @@ -281,7 +282,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">"SPX"</span><span class="o">,</span> <span class="s">"FTSE"</span><span class="o">,</span> <span class="s">"DJI"</span><span class="o">,</span> <span class="s">"DJT"</span><span class="o">,</span> <span class="s">"BUX"</span><span class="o">,</span> <span class="s">"DAX"</span><span class="o">,</span> <span class="s">"GOOG"</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">"SPX"</span><span class="o">,</span> <span class="s">"FTSE"</span><span class="o">,</span> <span class="s">"DJI"</span><span class="o">,</span> <span class="s">"DJT"</span><span class="o">,</span> <span class="s">"BUX"</span><span class="o">,</span> <span class="s">"DAX"</span><span class="o">,</span> <span class="s">"GOOG"</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> @@ -292,12 +293,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"><</span><span class="n">String</span><span class="o">></span> <span class="n">SYMBOLS</span> <span class="o">=</span> <span class="k">new</span> <span class="n">ArrayList</span><span class="o"><</span><span class="n">String</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">ArrayList</span><span class="o"><</span><span class="n">String</span><span class="o">></span> <span class="n">SYMBOLS</span> <span class="o">=</span> <span class="k">new</span> <span class="n">ArrayList</span><span class="o"><</span><span class="n">String</span><span class="o">>(</span> <span class="n">Arrays</span><span class="o">.</span><span class="na">asList</span><span class="o">(</span><span class="s">"SPX"</span><span class="o">,</span> <span class="s">"FTSE"</span><span class="o">,</span> <span class="s">"DJI"</span><span class="o">,</span> <span class="s">"DJT"</span><span class="o">,</span> <span class="s">"BUX"</span><span class="o">,</span> <span class="s">"DAX"</span><span class="o">,</span> <span class="s">"GOOG"</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> @@ -344,7 +345,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> @@ -397,7 +398,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">))</span> @@ -411,13 +412,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"><</span><span class="n">StockPrice</span><span class="o">></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> @@ -450,7 +451,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> @@ -480,7 +481,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">""</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> @@ -500,13 +501,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">""</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> @@ -557,7 +558,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> @@ -578,7 +579,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> @@ -598,13 +599,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">" "</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"><</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="c1">//Extract the stock symbols</span> @@ -652,7 +653,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> @@ -674,7 +675,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">"symbol"</span><span class="o">)</span> @@ -699,13 +700,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"><</span><span class="n">Tuple2</span><span class="o"><</span><span class="n">Integer</span><span class="o">,</span> <span class="n">Integer</span><span class="o">>></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> @@ -775,7 +776,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> @@ -820,8 +821,8 @@ internally, fault tolerance, and performance measurements!</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/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 997e1ac..c54885f 100644 --- a/content/news/2015/03/02/february-2015-in-flink.html +++ b/content/news/2015/03/02/february-2015-in-flink.html @@ -223,11 +223,11 @@ the web. Here are some examples:</p> directly. Hereâs 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"><</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">></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"><</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">></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> <span class="n">DataSet</span><span class="o"><</span><span class="n">Vertex</span><span class="o"><</span><span class="n">Long</span><span class="o">,</span> <span class="n">Double</span><span class="o">>></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"><</span><span class="n">Long</span><span class="o">>(</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> @@ -241,7 +241,7 @@ and SQL support. Hereâs 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">'id</span><span class="o">,</span> <span class="-Symbol">'mktSegment</span><span class="o">)</span> <span class="o">.</span><span class="n">filter</span><span class="o">(</span> <span class="-Symbol">'mktSegment</span> <span class="o">===</span> <span class="s">"AUTOMOBILE"</span> <span class="o">)</span> @@ -252,7 +252,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">'custId</span> <span class="o">===</span> <span class="-Symbol">'id</span><span class="o">)</span> - <span class="o">.</span><span class="n">select</span><span class="o">(</span><span class="-Symbol">'orderId</span><span class="o">,</span> <span class="-Symbol">'orderDate</span><span class="o">,</span> <span class="-Symbol">'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">'orderId</span><span class="o">,</span> <span class="-Symbol">'orderDate</span><span class="o">,</span> <span class="-Symbol">'shipPrio</span><span class="o">)</span></code></pre></figure> <h3 id="access-to-hcatalog-tables">Access to HCatalog tables</h3> @@ -291,8 +291,8 @@ a standalone Flink setup is now available.</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/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 8a8a104..86776d4 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 @@ -362,8 +362,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/04/07/march-in-flink.html ---------------------------------------------------------------------- diff --git a/content/news/2015/04/07/march-in-flink.html b/content/news/2015/04/07/march-in-flink.html index f4e7358..1a57dfe 100644 --- a/content/news/2015/04/07/march-in-flink.html +++ b/content/news/2015/04/07/march-in-flink.html @@ -242,8 +242,8 @@ programs.</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/2015/04/13/release-0.9.0-milestone1.html ---------------------------------------------------------------------- diff --git a/content/news/2015/04/13/release-0.9.0-milestone1.html b/content/news/2015/04/13/release-0.9.0-milestone1.html index 2d9e36c..68a9797 100644 --- a/content/news/2015/04/13/release-0.9.0-milestone1.html +++ b/content/news/2015/04/13/release-0.9.0-milestone1.html @@ -427,8 +427,8 @@ Improve usability of command line interface</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/2015/05/11/Juggling-with-Bits-and-Bytes.html ---------------------------------------------------------------------- diff --git a/content/news/2015/05/11/Juggling-with-Bits-and-Bytes.html b/content/news/2015/05/11/Juggling-with-Bits-and-Bytes.html index 91b8495..9864660 100644 --- a/content/news/2015/05/11/Juggling-with-Bits-and-Bytes.html +++ b/content/news/2015/05/11/Juggling-with-Bits-and-Bytes.html @@ -366,8 +366,8 @@ The following figure shows how two objects are compared.</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/2015/05/14/Community-update-April.html ---------------------------------------------------------------------- diff --git a/content/news/2015/05/14/Community-update-April.html b/content/news/2015/05/14/Community-update-April.html index 9bbcbe4..fab5ce2 100644 --- a/content/news/2015/05/14/Community-update-April.html +++ b/content/news/2015/05/14/Community-update-April.html @@ -214,8 +214,8 @@ including Apache Flink.</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/2015/06/24/announcing-apache-flink-0.9.0-release.html ---------------------------------------------------------------------- diff --git a/content/news/2015/06/24/announcing-apache-flink-0.9.0-release.html b/content/news/2015/06/24/announcing-apache-flink-0.9.0-release.html index 4d7cd08..6557fb0 100644 --- a/content/news/2015/06/24/announcing-apache-flink-0.9.0-release.html +++ b/content/news/2015/06/24/announcing-apache-flink-0.9.0-release.html @@ -414,8 +414,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/08/24/introducing-flink-gelly.html ---------------------------------------------------------------------- diff --git a/content/news/2015/08/24/introducing-flink-gelly.html b/content/news/2015/08/24/introducing-flink-gelly.html index 5c83e77..3eeffaa 100644 --- a/content/news/2015/08/24/introducing-flink-gelly.html +++ b/content/news/2015/08/24/introducing-flink-gelly.html @@ -632,8 +632,8 @@ tools, graph database systems and sampling techniques.</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/2015/09/01/release-0.9.1.html ---------------------------------------------------------------------- diff --git a/content/news/2015/09/01/release-0.9.1.html b/content/news/2015/09/01/release-0.9.1.html index 17e06ac..55a8cc8 100644 --- a/content/news/2015/09/01/release-0.9.1.html +++ b/content/news/2015/09/01/release-0.9.1.html @@ -236,8 +236,8 @@ for this release:</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/2015/09/03/flink-forward.html ---------------------------------------------------------------------- diff --git a/content/news/2015/09/03/flink-forward.html b/content/news/2015/09/03/flink-forward.html index 10b9a6e..61a32f8 100644 --- a/content/news/2015/09/03/flink-forward.html +++ b/content/news/2015/09/03/flink-forward.html @@ -227,8 +227,8 @@ register for the conference.</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/2015/09/16/off-heap-memory.html ---------------------------------------------------------------------- diff --git a/content/news/2015/09/16/off-heap-memory.html b/content/news/2015/09/16/off-heap-memory.html index 35c7859..678a631 100644 --- a/content/news/2015/09/16/off-heap-memory.html +++ b/content/news/2015/09/16/off-heap-memory.html @@ -1066,8 +1066,8 @@ Either <code>0 + absolutePointer</code> or <code>objectRefAddress + offset</code <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/11/16/release-0.10.0.html ---------------------------------------------------------------------- diff --git a/content/news/2015/11/16/release-0.10.0.html b/content/news/2015/11/16/release-0.10.0.html index eb317ed..a03abe9 100644 --- a/content/news/2015/11/16/release-0.10.0.html +++ b/content/news/2015/11/16/release-0.10.0.html @@ -350,8 +350,8 @@ Also note that some methods in the DataStream API had to be renamed as part of t <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/11/27/release-0.10.1.html ---------------------------------------------------------------------- diff --git a/content/news/2015/11/27/release-0.10.1.html b/content/news/2015/11/27/release-0.10.1.html index 3625640..21dc437 100644 --- a/content/news/2015/11/27/release-0.10.1.html +++ b/content/news/2015/11/27/release-0.10.1.html @@ -234,8 +234,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/12/04/Introducing-windows.html ---------------------------------------------------------------------- diff --git a/content/news/2015/12/04/Introducing-windows.html b/content/news/2015/12/04/Introducing-windows.html index 06f5eb1..2096d55 100644 --- a/content/news/2015/12/04/Introducing-windows.html +++ b/content/news/2015/12/04/Introducing-windows.html @@ -332,8 +332,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/12/11/storm-compatibility.html ---------------------------------------------------------------------- diff --git a/content/news/2015/12/11/storm-compatibility.html b/content/news/2015/12/11/storm-compatibility.html index 73e6051..749be9f 100644 --- a/content/news/2015/12/11/storm-compatibility.html +++ b/content/news/2015/12/11/storm-compatibility.html @@ -322,8 +322,8 @@ While you can embed Spouts/Bolts in a Flink program and mix-and-match them with <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/12/18/a-year-in-review.html ---------------------------------------------------------------------- diff --git a/content/news/2015/12/18/a-year-in-review.html b/content/news/2015/12/18/a-year-in-review.html index 3aea304..6ebfb84 100644 --- a/content/news/2015/12/18/a-year-in-review.html +++ b/content/news/2015/12/18/a-year-in-review.html @@ -399,8 +399,8 @@ on the Flink mailing lists.</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/2016/02/11/release-0.10.2.html ---------------------------------------------------------------------- diff --git a/content/news/2016/02/11/release-0.10.2.html b/content/news/2016/02/11/release-0.10.2.html index 8af8554..81c7fa6 100644 --- a/content/news/2016/02/11/release-0.10.2.html +++ b/content/news/2016/02/11/release-0.10.2.html @@ -212,8 +212,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/2016/03/08/release-1.0.0.html ---------------------------------------------------------------------- diff --git a/content/news/2016/03/08/release-1.0.0.html b/content/news/2016/03/08/release-1.0.0.html index 013ccd3..b88f30f 100644 --- a/content/news/2016/03/08/release-1.0.0.html +++ b/content/news/2016/03/08/release-1.0.0.html @@ -302,8 +302,8 @@ When using this backend, active state in streaming programs can grow well beyond <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/2016/04/06/cep-monitoring.html ---------------------------------------------------------------------- diff --git a/content/news/2016/04/06/cep-monitoring.html b/content/news/2016/04/06/cep-monitoring.html index b804bb3..e979b08 100644 --- a/content/news/2016/04/06/cep-monitoring.html +++ b/content/news/2016/04/06/cep-monitoring.html @@ -368,8 +368,8 @@ This feature will allow to prune unpromising event sequences early.</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/2016/04/06/release-1.0.1.html ---------------------------------------------------------------------- diff --git a/content/news/2016/04/06/release-1.0.1.html b/content/news/2016/04/06/release-1.0.1.html index ba5304d..d732344 100644 --- a/content/news/2016/04/06/release-1.0.1.html +++ b/content/news/2016/04/06/release-1.0.1.html @@ -246,8 +246,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/2016/04/14/flink-forward-announce.html ---------------------------------------------------------------------- diff --git a/content/news/2016/04/14/flink-forward-announce.html b/content/news/2016/04/14/flink-forward-announce.html index e606487..07ceddb 100644 --- a/content/news/2016/04/14/flink-forward-announce.html +++ b/content/news/2016/04/14/flink-forward-announce.html @@ -188,8 +188,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/2016/04/22/release-1.0.2.html ---------------------------------------------------------------------- diff --git a/content/news/2016/04/22/release-1.0.2.html b/content/news/2016/04/22/release-1.0.2.html index 0f4b45a..d1e984c 100644 --- a/content/news/2016/04/22/release-1.0.2.html +++ b/content/news/2016/04/22/release-1.0.2.html @@ -221,8 +221,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/2016/05/11/release-1.0.3.html ---------------------------------------------------------------------- diff --git a/content/news/2016/05/11/release-1.0.3.html b/content/news/2016/05/11/release-1.0.3.html index 04ad99e..f3ab6d3 100644 --- a/content/news/2016/05/11/release-1.0.3.html +++ b/content/news/2016/05/11/release-1.0.3.html @@ -219,8 +219,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/2016/05/24/stream-sql.html ---------------------------------------------------------------------- diff --git a/content/news/2016/05/24/stream-sql.html b/content/news/2016/05/24/stream-sql.html index 4faaada..8a40935 100644 --- a/content/news/2016/05/24/stream-sql.html +++ b/content/news/2016/05/24/stream-sql.html @@ -304,8 +304,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/2016/08/08/release-1.1.0.html ---------------------------------------------------------------------- diff --git a/content/news/2016/08/08/release-1.1.0.html b/content/news/2016/08/08/release-1.1.0.html index 1024ace..4f5b30b 100644 --- a/content/news/2016/08/08/release-1.1.0.html +++ b/content/news/2016/08/08/release-1.1.0.html @@ -255,6 +255,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âs 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> @@ -391,8 +397,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/2016/08/11/release-1.1.1.html ---------------------------------------------------------------------- diff --git a/content/news/2016/08/11/release-1.1.1.html b/content/news/2016/08/11/release-1.1.1.html index d4c17cc..9a243a1 100644 --- a/content/news/2016/08/11/release-1.1.1.html +++ b/content/news/2016/08/11/release-1.1.1.html @@ -206,8 +206,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/poweredby.html ---------------------------------------------------------------------- diff --git a/content/poweredby.html b/content/poweredby.html index f1f2f57..0bf90c1 100644 --- a/content/poweredby.html +++ b/content/poweredby.html @@ -237,8 +237,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/privacy-policy.html ---------------------------------------------------------------------- diff --git a/content/privacy-policy.html b/content/privacy-policy.html index d860722..332e84e 100644 --- a/content/privacy-policy.html +++ b/content/privacy-policy.html @@ -191,8 +191,8 @@ manner and for the purpose described above.</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/project.html ---------------------------------------------------------------------- diff --git a/content/project.html b/content/project.html index 81f3bb6..7a07822 100644 --- a/content/project.html +++ b/content/project.html @@ -173,8 +173,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/slides.html ---------------------------------------------------------------------- diff --git a/content/slides.html b/content/slides.html index 28b0b5c..3f213e8 100644 --- a/content/slides.html +++ b/content/slides.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>
