Repository: incubator-edgent-website Updated Branches: refs/heads/asf-site 33d7e84e1 -> 7cc4ad1bc
http://git-wip-us.apache.org/repos/asf/incubator-edgent-website/blob/7cc4ad1b/content/recipes/recipe_concurrent_analytics.html ---------------------------------------------------------------------- diff --git a/content/recipes/recipe_concurrent_analytics.html b/content/recipes/recipe_concurrent_analytics.html index 3f057a1..a46b77f 100644 --- a/content/recipes/recipe_concurrent_analytics.html +++ b/content/recipes/recipe_concurrent_analytics.html @@ -713,7 +713,7 @@ stream -> |-> isolate(1) -> pipeline2 -> |-> barrier(10) -> co <p>In this recipe we'll just define some very simple pipelines and use sleep to simulate some long processing times.</p> <p>Here's the A3 pipeline builder:</p> -<div class="highlight"><pre><code class="language-java" data-lang="java"><span class="kd">static</span> <span class="n">Function</span><span class="o"><</span><span class="n">TStream</span><span class="o"><</span><span class="n">Double</span><span class="o">>,</span><span class="n">TStream</span><span class="o"><</span><span class="n">String</span><span class="o">>></span> <span class="n">a3pipeline</span><span class="o">()</span> <span class="o">{</span> +<div class="highlight"><pre><code class="language-java" data-lang="java"><span class="kd">static</span> <span class="n">Function</span><span class="o"><</span><span class="n">TStream</span><span class="o"><</span><span class="n">Double</span><span class="o">>,</span><span class="n">TStream</span><span class="o"><</span><span class="n">String</span><span class="o">>></span> <span class="nf">a3pipeline</span><span class="o">()</span> <span class="o">{</span> <span class="c1">// simple 3 stage pipeline simulating some amount of work by sleeping</span> <span class="k">return</span> <span class="n">stream</span> <span class="o">-></span> <span class="n">stream</span><span class="o">.</span><span class="na">map</span><span class="o">(</span><span class="n">tuple</span> <span class="o">-></span> <span class="o">{</span> <span class="n">sleep</span><span class="o">(</span><span class="mi">800</span><span class="o">,</span> <span class="n">TimeUnit</span><span class="o">.</span><span class="na">MILLISECONDS</span><span class="o">);</span> @@ -752,7 +752,7 @@ stream -> |-> isolate(1) -> pipeline2 -> |-> barrier(10) -> co * Concurrently run a collection of long running independent * analytic pipelines on each tuple. */</span> - <span class="kd">public</span> <span class="kd">static</span> <span class="kt">void</span> <span class="n">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">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="n">DirectProvider</span> <span class="n">dp</span> <span class="o">=</span> <span class="k">new</span> <span class="n">DevelopmentProvider</span><span class="o">();</span> <span class="n">System</span><span class="o">.</span><span class="na">out</span><span class="o">.</span><span class="na">println</span><span class="o">(</span><span class="s">"development console url: "</span> @@ -791,7 +791,7 @@ stream -> |-> isolate(1) -> pipeline2 -> |-> barrier(10) -> co <span class="o">}</span> <span class="cm">/** Function to create analytic pipeline a1 and add it to a stream */</span> - <span class="kd">private</span> <span class="kd">static</span> <span class="n">Function</span><span class="o"><</span><span class="n">TStream</span><span class="o"><</span><span class="n">Double</span><span class="o">>,</span><span class="n">TStream</span><span class="o"><</span><span class="n">String</span><span class="o">>></span> <span class="n">a1pipeline</span><span class="o">()</span> <span class="o">{</span> + <span class="kd">private</span> <span class="kd">static</span> <span class="n">Function</span><span class="o"><</span><span class="n">TStream</span><span class="o"><</span><span class="n">Double</span><span class="o">>,</span><span class="n">TStream</span><span class="o"><</span><span class="n">String</span><span class="o">>></span> <span class="nf">a1pipeline</span><span class="o">()</span> <span class="o">{</span> <span class="c1">// a simple 1 stage pipeline simulating some amount of work by sleeping</span> <span class="k">return</span> <span class="n">stream</span> <span class="o">-></span> <span class="n">stream</span><span class="o">.</span><span class="na">map</span><span class="o">(</span><span class="n">tuple</span> <span class="o">-></span> <span class="o">{</span> <span class="n">sleep</span><span class="o">(</span><span class="mi">800</span><span class="o">,</span> <span class="n">TimeUnit</span><span class="o">.</span><span class="na">MILLISECONDS</span><span class="o">);</span> @@ -800,7 +800,7 @@ stream -> |-> isolate(1) -> pipeline2 -> |-> barrier(10) -> co <span class="o">}</span> <span class="cm">/** Function to create analytic pipeline a2 and add it to a stream */</span> - <span class="kd">private</span> <span class="kd">static</span> <span class="n">Function</span><span class="o"><</span><span class="n">TStream</span><span class="o"><</span><span class="n">Double</span><span class="o">>,</span><span class="n">TStream</span><span class="o"><</span><span class="n">String</span><span class="o">>></span> <span class="n">a2pipeline</span><span class="o">()</span> <span class="o">{</span> + <span class="kd">private</span> <span class="kd">static</span> <span class="n">Function</span><span class="o"><</span><span class="n">TStream</span><span class="o"><</span><span class="n">Double</span><span class="o">>,</span><span class="n">TStream</span><span class="o"><</span><span class="n">String</span><span class="o">>></span> <span class="nf">a2pipeline</span><span class="o">()</span> <span class="o">{</span> <span class="c1">// a simple 2 stage pipeline simulating some amount of work by sleeping</span> <span class="k">return</span> <span class="n">stream</span> <span class="o">-></span> <span class="n">stream</span><span class="o">.</span><span class="na">map</span><span class="o">(</span><span class="n">tuple</span> <span class="o">-></span> <span class="o">{</span> <span class="n">sleep</span><span class="o">(</span><span class="mi">800</span><span class="o">,</span> <span class="n">TimeUnit</span><span class="o">.</span><span class="na">MILLISECONDS</span><span class="o">);</span> @@ -810,7 +810,7 @@ stream -> |-> isolate(1) -> pipeline2 -> |-> barrier(10) -> co <span class="o">}</span> <span class="cm">/** Function to create analytic pipeline a3 and add it to a stream */</span> - <span class="kd">private</span> <span class="kd">static</span> <span class="n">Function</span><span class="o"><</span><span class="n">TStream</span><span class="o"><</span><span class="n">Double</span><span class="o">>,</span><span class="n">TStream</span><span class="o"><</span><span class="n">String</span><span class="o">>></span> <span class="n">a3pipeline</span><span class="o">()</span> <span class="o">{</span> + <span class="kd">private</span> <span class="kd">static</span> <span class="n">Function</span><span class="o"><</span><span class="n">TStream</span><span class="o"><</span><span class="n">Double</span><span class="o">>,</span><span class="n">TStream</span><span class="o"><</span><span class="n">String</span><span class="o">>></span> <span class="nf">a3pipeline</span><span class="o">()</span> <span class="o">{</span> <span class="c1">// a simple 3 stage pipeline simulating some amount of work by sleeping</span> <span class="k">return</span> <span class="n">stream</span> <span class="o">-></span> <span class="n">stream</span><span class="o">.</span><span class="na">map</span><span class="o">(</span><span class="n">tuple</span> <span class="o">-></span> <span class="o">{</span> <span class="n">sleep</span><span class="o">(</span><span class="mi">800</span><span class="o">,</span> <span class="n">TimeUnit</span><span class="o">.</span><span class="na">MILLISECONDS</span><span class="o">);</span> @@ -820,11 +820,11 @@ stream -> |-> isolate(1) -> pipeline2 -> |-> barrier(10) -> co <span class="o">.</span><span class="na">map</span><span class="o">(</span><span class="n">Functions</span><span class="o">.</span><span class="na">identity</span><span class="o">()).</span><span class="na">tag</span><span class="o">(</span><span class="s">"a3.stage3"</span><span class="o">);</span> <span class="o">}</span> - <span class="kd">private</span> <span class="kd">static</span> <span class="kt">void</span> <span class="n">sleep</span><span class="o">(</span><span class="kt">long</span> <span class="n">period</span><span class="o">,</span> <span class="n">TimeUnit</span> <span class="n">unit</span><span class="o">)</span> <span class="kd">throws</span> <span class="n">RuntimeException</span> <span class="o">{</span> + <span class="kd">private</span> <span class="kd">static</span> <span class="kt">void</span> <span class="nf">sleep</span><span class="o">(</span><span class="kt">long</span> <span class="n">period</span><span class="o">,</span> <span class="n">TimeUnit</span> <span class="n">unit</span><span class="o">)</span> <span class="kd">throws</span> <span class="n">RuntimeException</span> <span class="o">{</span> <span class="k">try</span> <span class="o">{</span> <span class="n">Thread</span><span class="o">.</span><span class="na">sleep</span><span class="o">(</span><span class="n">unit</span><span class="o">.</span><span class="na">toMillis</span><span class="o">(</span><span class="n">period</span><span class="o">));</span> <span class="o">}</span> <span class="k">catch</span> <span class="o">(</span><span class="n">InterruptedException</span> <span class="n">e</span><span class="o">)</span> <span class="o">{</span> - <span class="k">throw</span> <span class="k">new</span> <span class="n">RuntimeException</span><span class="o">(</span><span class="s">"Interrupted"</span><span class="o">,</span> <span class="n">e</span><span class="o">);</span> + <span class="k">throw</span> <span class="k">new</span> <span class="nf">RuntimeException</span><span class="o">(</span><span class="s">"Interrupted"</span><span class="o">,</span> <span class="n">e</span><span class="o">);</span> <span class="o">}</span> <span class="o">}</span> @@ -862,7 +862,7 @@ stream -> |-> isolate(1) -> pipeline2 -> |-> barrier(10) -> co <div class="col-lg-12 footer"> Site last - generated: Mar 24, 2017 <br/> + generated: Apr 25, 2017 <br/> </div> </div> @@ -886,6 +886,13 @@ stream -> |-> isolate(1) -> pipeline2 -> |-> barrier(10) -> co respective owners.</p> </div> </div> + + <div class="container"> + <div class="row"> + <div> + <img class="img-responsive center-block" src="../img/edgent_incubation.png" style="display: block; margin: auto;"alt=""> + </div> + </div> </footer> </div><!-- /.row --> http://git-wip-us.apache.org/repos/asf/incubator-edgent-website/blob/7cc4ad1b/content/recipes/recipe_different_processing_against_stream.html ---------------------------------------------------------------------- diff --git a/content/recipes/recipe_different_processing_against_stream.html b/content/recipes/recipe_different_processing_against_stream.html index ad61336..1c6e53d 100644 --- a/content/recipes/recipe_different_processing_against_stream.html +++ b/content/recipes/recipe_different_processing_against_stream.html @@ -700,7 +700,7 @@ $('#toc').on('click', 'a', function() { */</span> <span class="kd">static</span> <span class="kt">double</span> <span class="n">ROUTE_MILES</span> <span class="o">=</span> <span class="mi">80</span><span class="o">;</span> - <span class="kd">public</span> <span class="kd">static</span> <span class="kt">void</span> <span class="n">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">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="n">DirectProvider</span> <span class="n">dp</span> <span class="o">=</span> <span class="k">new</span> <span class="n">DevelopmentProvider</span><span class="o">();</span> @@ -814,7 +814,7 @@ Gallons of gas: 9.1 * gas mileage readings (in miles/gallon). Feed the stream of sensor * readings to different functions (filter, map, and modify). */</span> - <span class="kd">public</span> <span class="kd">static</span> <span class="kt">void</span> <span class="n">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">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="n">DirectProvider</span> <span class="n">dp</span> <span class="o">=</span> <span class="k">new</span> <span class="n">DevelopmentProvider</span><span class="o">();</span> @@ -884,7 +884,7 @@ Gallons of gas: 9.1 <div class="col-lg-12 footer"> Site last - generated: Mar 24, 2017 <br/> + generated: Apr 25, 2017 <br/> </div> </div> @@ -908,6 +908,13 @@ Gallons of gas: 9.1 respective owners.</p> </div> </div> + + <div class="container"> + <div class="row"> + <div> + <img class="img-responsive center-block" src="../img/edgent_incubation.png" style="display: block; margin: auto;"alt=""> + </div> + </div> </footer> </div><!-- /.row --> http://git-wip-us.apache.org/repos/asf/incubator-edgent-website/blob/7cc4ad1b/content/recipes/recipe_dynamic_analytic_control.html ---------------------------------------------------------------------- diff --git a/content/recipes/recipe_dynamic_analytic_control.html b/content/recipes/recipe_dynamic_analytic_control.html index 71892b8..c87b8c3 100644 --- a/content/recipes/recipe_dynamic_analytic_control.html +++ b/content/recipes/recipe_dynamic_analytic_control.html @@ -736,7 +736,7 @@ $('#toc').on('click', 'a', function() { <div class="col-lg-12 footer"> Site last - generated: Mar 24, 2017 <br/> + generated: Apr 25, 2017 <br/> </div> </div> @@ -760,6 +760,13 @@ $('#toc').on('click', 'a', function() { respective owners.</p> </div> </div> + + <div class="container"> + <div class="row"> + <div> + <img class="img-responsive center-block" src="../img/edgent_incubation.png" style="display: block; margin: auto;"alt=""> + </div> + </div> </footer> </div><!-- /.row --> http://git-wip-us.apache.org/repos/asf/incubator-edgent-website/blob/7cc4ad1b/content/recipes/recipe_external_filter_range.html ---------------------------------------------------------------------- diff --git a/content/recipes/recipe_external_filter_range.html b/content/recipes/recipe_external_filter_range.html index 9ace53c..d1c9760 100644 --- a/content/recipes/recipe_external_filter_range.html +++ b/content/recipes/recipe_external_filter_range.html @@ -720,7 +720,7 @@ optimalTempRange=[77.0..91.0] <span class="kd">static</span> <span class="n">Range</span><span class="o"><</span><span class="n">Double</span><span class="o">></span> <span class="n">optimalTempRange</span><span class="o">;</span> <span class="cm">/** Initialize the application's configuration */</span> - <span class="kd">static</span> <span class="kt">void</span> <span class="n">initializeConfiguration</span><span class="o">(</span><span class="n">String</span> <span class="n">configFilePath</span><span class="o">)</span> <span class="kd">throws</span> <span class="n">Exception</span> <span class="o">{</span> + <span class="kd">static</span> <span class="kt">void</span> <span class="nf">initializeConfiguration</span><span class="o">(</span><span class="n">String</span> <span class="n">configFilePath</span><span class="o">)</span> <span class="kd">throws</span> <span class="n">Exception</span> <span class="o">{</span> <span class="c1">// Load the configuration file</span> <span class="n">Properties</span> <span class="n">props</span> <span class="o">=</span> <span class="k">new</span> <span class="n">Properties</span><span class="o">();</span> <span class="n">props</span><span class="o">.</span><span class="na">load</span><span class="o">(</span><span class="n">Files</span><span class="o">.</span><span class="na">newBufferedReader</span><span class="o">(</span><span class="k">new</span> <span class="n">File</span><span class="o">(</span><span class="n">configFilePath</span><span class="o">).</span><span class="na">toPath</span><span class="o">()));</span> @@ -737,9 +737,9 @@ optimalTempRange=[77.0..91.0] * temperature readings (in Fahrenheit). Use a simple filter * to determine when the temperature is out of the optimal range. */</span> - <span class="kd">public</span> <span class="kd">static</span> <span class="kt">void</span> <span class="n">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">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="k">if</span> <span class="o">(</span><span class="n">args</span><span class="o">.</span><span class="na">length</span> <span class="o">!=</span> <span class="mi">1</span><span class="o">)</span> - <span class="k">throw</span> <span class="k">new</span> <span class="n">Exception</span><span class="o">(</span><span class="s">"missing pathname to configuration file"</span><span class="o">);</span> + <span class="k">throw</span> <span class="k">new</span> <span class="nf">Exception</span><span class="o">(</span><span class="s">"missing pathname to configuration file"</span><span class="o">);</span> <span class="n">String</span> <span class="n">configFilePath</span> <span class="o">=</span> <span class="n">args</span><span class="o">[</span><span class="mi">0</span><span class="o">];</span> <span class="n">DirectProvider</span> <span class="n">dp</span> <span class="o">=</span> <span class="k">new</span> <span class="n">DirectProvider</span><span class="o">();</span> @@ -798,7 +798,7 @@ optimalTempRange=[77.0..91.0] <div class="col-lg-12 footer"> Site last - generated: Mar 24, 2017 <br/> + generated: Apr 25, 2017 <br/> </div> </div> @@ -822,6 +822,13 @@ optimalTempRange=[77.0..91.0] respective owners.</p> </div> </div> + + <div class="container"> + <div class="row"> + <div> + <img class="img-responsive center-block" src="../img/edgent_incubation.png" style="display: block; margin: auto;"alt=""> + </div> + </div> </footer> </div><!-- /.row --> http://git-wip-us.apache.org/repos/asf/incubator-edgent-website/blob/7cc4ad1b/content/recipes/recipe_hello_edgent.html ---------------------------------------------------------------------- diff --git a/content/recipes/recipe_hello_edgent.html b/content/recipes/recipe_hello_edgent.html index 9805c37..b2cc5f0 100644 --- a/content/recipes/recipe_hello_edgent.html +++ b/content/recipes/recipe_hello_edgent.html @@ -664,7 +664,7 @@ $('#toc').on('click', 'a', function() { <a target="_blank" href="https://github.com/apache/incubator-edgent-website/blob/master/site/recipes/recipe_hello_edgent.md"; class="btn btn-default githubEditButton" role="button"><i class="fa fa-github fa-lg"></i> Edit me</a> <p>Edgent's pure Java implementation is a powerful feature which allows it to be run on the majority of JVM-compatible systems. It also has the added benefit of enabling the developer to develop applications entirely within the Eclipse and IntelliJ ecosystems. For the purposes of this recipe, it will be assumed that the developer is using Eclipse. To begin the Hello Edgent recipe, create a new project and import the necessary libraries as outlined in the <a href="../docs/edgent-getting-started">Getting started guide</a>. Next, write the following template application:</p> -<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="p">(</span><span class="n">String</span><span class="o">[]</span> <span class="n">args</span><span class="o">)</span> <span class="o">{</span> +<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="o">{</span> <span class="n">DirectProvider</span> <span class="n">dp</span> <span class="o">=</span> <span class="k">new</span> <span class="n">DirectProvider</span><span class="o">();</span> @@ -676,7 +676,7 @@ $('#toc').on('click', 'a', function() { <h2 id="using-topology-strings">Using <code>Topology.strings()</code></h2> <p>The primary abstraction in Edgent is the <code>TStream</code>. A <em><code>TStream</code></em> represents the flow of data in an Edgent application; for example, the periodic floating point readings from a temperature sensor. The data items which are sent through a <code>TStream</code> are Java objects — in the "Hello Edgent!" example, we are sending two strings. There are a number of ways to create a <code>TStream</code>, and <code>Topology.strings()</code> is the simplest. The user specifies a number of strings which will be used as the stream's data items.</p> -<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="p">(</span><span class="n">String</span><span class="o">[]</span> <span class="n">args</span><span class="o">)</span> <span class="o">{</span> +<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="o">{</span> <span class="n">DirectProvider</span> <span class="n">dp</span> <span class="o">=</span> <span class="k">new</span> <span class="n">DirectProvider</span><span class="o">();</span> @@ -690,7 +690,7 @@ $('#toc').on('click', 'a', function() { <h2 id="printing-to-output">Printing to output</h2> <p><code>TStream.print()</code> can be used to print the data items of a stream to standard output by invoking the <code>toString()</code> method of each data item. In this case the data items are already strings, but in principle <code>TStream.print()</code> can be called on any stream, regardless of the datatype carried by the stream.</p> -<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="p">(</span><span class="n">String</span><span class="o">[]</span> <span class="n">args</span><span class="o">)</span> <span class="o">{</span> +<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="o">{</span> <span class="n">DirectProvider</span> <span class="n">dp</span> <span class="o">=</span> <span class="k">new</span> <span class="n">DirectProvider</span><span class="o">();</span> @@ -704,7 +704,7 @@ $('#toc').on('click', 'a', function() { <h2 id="submitting-the-application">Submitting the application</h2> <p>The only remaining step is to submit the application, which is performed by the <code>DirectProvider</code>. Submitting an Edgent application initializes the threads which execute the <code>Topology</code>, and begins processing its data sources.</p> -<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="p">(</span><span class="n">String</span><span class="o">[]</span> <span class="n">args</span><span class="o">)</span> <span class="o">{</span> +<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="o">{</span> <span class="n">DirectProvider</span> <span class="n">dp</span> <span class="o">=</span> <span class="k">new</span> <span class="n">DirectProvider</span><span class="o">();</span> @@ -752,7 +752,7 @@ Edgent! <div class="col-lg-12 footer"> Site last - generated: Mar 24, 2017 <br/> + generated: Apr 25, 2017 <br/> </div> </div> @@ -776,6 +776,13 @@ Edgent! respective owners.</p> </div> </div> + + <div class="container"> + <div class="row"> + <div> + <img class="img-responsive center-block" src="../img/edgent_incubation.png" style="display: block; margin: auto;"alt=""> + </div> + </div> </footer> </div><!-- /.row --> http://git-wip-us.apache.org/repos/asf/incubator-edgent-website/blob/7cc4ad1b/content/recipes/recipe_parallel_analytics.html ---------------------------------------------------------------------- diff --git a/content/recipes/recipe_parallel_analytics.html b/content/recipes/recipe_parallel_analytics.html index 4962cf6..c0fb330 100644 --- a/content/recipes/recipe_parallel_analytics.html +++ b/content/recipes/recipe_parallel_analytics.html @@ -710,7 +710,7 @@ stream -> split(width,splitter) -> |-> isolate(10) -> pipeline-ch1 - <p>Many pipelines don't care what channel they're being constructed for. While the pipeline function typically yields the same pipeline processing for each channel there is no requirement for it to do so.</p> <p>In this simple recipe the pipeline receives a <code>TStream<Double></code> as input and generates a <code>TStream<String></code> as output.</p> -<div class="highlight"><pre><code class="language-java" data-lang="java"><span class="kd">static</span> <span class="n">BiFunction</span><span class="o"><</span><span class="n">TStream</span><span class="o"><</span><span class="n">Double</span><span class="o">>,</span> <span class="n">Integer</span><span class="o">,</span> <span class="n">TStream</span><span class="o"><</span><span class="n">String</span><span class="o">>></span> <span class="n">pipeline</span><span class="o">()</span> <span class="o">{</span> +<div class="highlight"><pre><code class="language-java" data-lang="java"><span class="kd">static</span> <span class="n">BiFunction</span><span class="o"><</span><span class="n">TStream</span><span class="o"><</span><span class="n">Double</span><span class="o">>,</span> <span class="n">Integer</span><span class="o">,</span> <span class="n">TStream</span><span class="o"><</span><span class="n">String</span><span class="o">>></span> <span class="nf">pipeline</span><span class="o">()</span> <span class="o">{</span> <span class="c1">// a simple 4 stage pipeline simulating some amount of work by sleeping</span> <span class="k">return</span> <span class="o">(</span><span class="n">stream</span><span class="o">,</span> <span class="n">channel</span><span class="o">)</span> <span class="o">-></span> <span class="o">{</span> @@ -763,7 +763,7 @@ stream -> split(width,splitter) -> |-> isolate(10) -> pipeline-ch1 - <span class="cm">/** * Process several tuples in parallel in a replicated pipeline. */</span> - <span class="kd">public</span> <span class="kd">static</span> <span class="kt">void</span> <span class="n">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">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="n">DirectProvider</span> <span class="n">dp</span> <span class="o">=</span> <span class="k">new</span> <span class="n">DevelopmentProvider</span><span class="o">();</span> <span class="n">System</span><span class="o">.</span><span class="na">out</span><span class="o">.</span><span class="na">println</span><span class="o">(</span><span class="s">"development console url: "</span> @@ -796,7 +796,7 @@ stream -> split(width,splitter) -> |-> isolate(10) -> pipeline-ch1 - <span class="o">}</span> <span class="cm">/** Function to create analytic pipeline and add it to a stream */</span> - <span class="kd">private</span> <span class="kd">static</span> <span class="n">BiFunction</span><span class="o"><</span><span class="n">TStream</span><span class="o"><</span><span class="n">Double</span><span class="o">>,</span><span class="n">Integer</span><span class="o">,</span><span class="n">TStream</span><span class="o"><</span><span class="n">String</span><span class="o">>></span> <span class="n">pipeline</span><span class="o">()</span> <span class="o">{</span> + <span class="kd">private</span> <span class="kd">static</span> <span class="n">BiFunction</span><span class="o"><</span><span class="n">TStream</span><span class="o"><</span><span class="n">Double</span><span class="o">>,</span><span class="n">Integer</span><span class="o">,</span><span class="n">TStream</span><span class="o"><</span><span class="n">String</span><span class="o">>></span> <span class="nf">pipeline</span><span class="o">()</span> <span class="o">{</span> <span class="c1">// a simple 3 stage pipeline simulating some amount of work by sleeping</span> <span class="k">return</span> <span class="o">(</span><span class="n">stream</span><span class="o">,</span> <span class="n">channel</span><span class="o">)</span> <span class="o">-></span> <span class="o">{</span> @@ -810,11 +810,11 @@ stream -> split(width,splitter) -> |-> isolate(10) -> pipeline-ch1 - <span class="o">};</span> <span class="o">}</span> - <span class="kd">private</span> <span class="kd">static</span> <span class="kt">void</span> <span class="n">sleep</span><span class="o">(</span><span class="kt">long</span> <span class="n">period</span><span class="o">,</span> <span class="n">TimeUnit</span> <span class="n">unit</span><span class="o">)</span> <span class="kd">throws</span> <span class="n">RuntimeException</span> <span class="o">{</span> + <span class="kd">private</span> <span class="kd">static</span> <span class="kt">void</span> <span class="nf">sleep</span><span class="o">(</span><span class="kt">long</span> <span class="n">period</span><span class="o">,</span> <span class="n">TimeUnit</span> <span class="n">unit</span><span class="o">)</span> <span class="kd">throws</span> <span class="n">RuntimeException</span> <span class="o">{</span> <span class="k">try</span> <span class="o">{</span> <span class="n">Thread</span><span class="o">.</span><span class="na">sleep</span><span class="o">(</span><span class="n">unit</span><span class="o">.</span><span class="na">toMillis</span><span class="o">(</span><span class="n">period</span><span class="o">));</span> <span class="o">}</span> <span class="k">catch</span> <span class="o">(</span><span class="n">InterruptedException</span> <span class="n">e</span><span class="o">)</span> <span class="o">{</span> - <span class="k">throw</span> <span class="k">new</span> <span class="n">RuntimeException</span><span class="o">(</span><span class="s">"Interrupted"</span><span class="o">,</span> <span class="n">e</span><span class="o">);</span> + <span class="k">throw</span> <span class="k">new</span> <span class="nf">RuntimeException</span><span class="o">(</span><span class="s">"Interrupted"</span><span class="o">,</span> <span class="n">e</span><span class="o">);</span> <span class="o">}</span> <span class="o">}</span> @@ -851,7 +851,7 @@ stream -> split(width,splitter) -> |-> isolate(10) -> pipeline-ch1 - <div class="col-lg-12 footer"> Site last - generated: Mar 24, 2017 <br/> + generated: Apr 25, 2017 <br/> </div> </div> @@ -875,6 +875,13 @@ stream -> split(width,splitter) -> |-> isolate(10) -> pipeline-ch1 - respective owners.</p> </div> </div> + + <div class="container"> + <div class="row"> + <div> + <img class="img-responsive center-block" src="../img/edgent_incubation.png" style="display: block; margin: auto;"alt=""> + </div> + </div> </footer> </div><!-- /.row --> http://git-wip-us.apache.org/repos/asf/incubator-edgent-website/blob/7cc4ad1b/content/recipes/recipe_source_function.html ---------------------------------------------------------------------- diff --git a/content/recipes/recipe_source_function.html b/content/recipes/recipe_source_function.html index 95f6f06..2560924 100644 --- a/content/recipes/recipe_source_function.html +++ b/content/recipes/recipe_source_function.html @@ -670,7 +670,7 @@ $('#toc').on('click', 'a', function() { <div class="alert alert-info" role="alert"><i class="fa fa-info-circle"></i> <b>Note: </b> Edgent's API provides convenience methods for performing HTTP requests. For the sake of example we are writing a HTTP data source manually, but in principle there are easier methods. </div> <p>One example of a custom data source could be retrieving the contents of a web page and printing each line to output. For example, the user could be querying the Yahoo Finance website for the most recent stock price data of Bank of America, Cabot Oil & Gas, and Freeport-McMoRan Inc.:</p> -<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="p">(</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> +<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> <span class="n">DirectProvider</span> <span class="n">dp</span> <span class="o">=</span> <span class="k">new</span> <span class="n">DirectProvider</span><span class="o">();</span> <span class="n">Topology</span> <span class="n">top</span> <span class="o">=</span> <span class="n">dp</span><span class="o">.</span><span class="na">newTopology</span><span class="o">();</span> @@ -684,7 +684,7 @@ $('#toc').on('click', 'a', function() { <span class="k">try</span> <span class="o">{</span> <span class="n">InputStream</span> <span class="n">is</span> <span class="o">=</span> <span class="n">url</span><span class="o">.</span><span class="na">openStream</span><span class="o">();</span> <span class="n">BufferedReader</span> <span class="n">br</span> <span class="o">=</span> <span class="k">new</span> <span class="n">BufferedReader</span><span class="o">(</span> - <span class="k">new</span> <span class="n">InputStreamReader</span><span class="o">(</span><span class="n">is</span><span class="o">));</span> + <span class="k">new</span> <span class="nf">InputStreamReader</span><span class="o">(</span><span class="n">is</span><span class="o">));</span> <span class="k">for</span><span class="o">(</span><span class="n">String</span> <span class="n">s</span> <span class="o">=</span> <span class="n">br</span><span class="o">.</span><span class="na">readLine</span><span class="o">();</span> <span class="n">s</span> <span class="o">!=</span> <span class="kc">null</span><span class="o">;</span> <span class="n">s</span> <span class="o">=</span> <span class="n">br</span><span class="o">.</span><span class="na">readLine</span><span class="o">())</span> <span class="n">lines</span><span class="o">.</span><span class="na">add</span><span class="o">(</span><span class="n">s</span><span class="o">);</span> @@ -697,7 +697,7 @@ $('#toc').on('click', 'a', function() { <span class="o">}</span> </code></pre></div> <p>When invoking <code>Topology.source()</code>, we can use <code>queryWebsite</code> to return the required supplier, passing in the URL.</p> -<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="p">(</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> +<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> <span class="n">DirectProvider</span> <span class="n">dp</span> <span class="o">=</span> <span class="k">new</span> <span class="n">DirectProvider</span><span class="o">();</span> <span class="n">Topology</span> <span class="n">top</span> <span class="o">=</span> <span class="n">dp</span><span class="o">.</span><span class="na">newTopology</span><span class="o">();</span> @@ -718,7 +718,7 @@ $('#toc').on('click', 'a', function() { <h2 id="polling-source-reading-data-periodically">Polling source: reading data periodically</h2> <p>A much more common scenario for a developer is the periodic generation of data from a source operator — a data source may need to be polled every 5 seconds, 3 hours, or any time frame. To this end, <code>Topology</code> exposes the <code>poll()</code> method which can be used to call a function at the frequency of the user's choosing. For example, a user might want to query Yahoo Finance every two seconds to retrieve the most up to date ticker price for a stock:</p> -<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="p">(</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> +<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> <span class="n">DirectProvider</span> <span class="n">dp</span> <span class="o">=</span> <span class="k">new</span> <span class="n">DirectProvider</span><span class="o">();</span> <span class="n">Topology</span> <span class="n">top</span> <span class="o">=</span> <span class="n">dp</span><span class="o">.</span><span class="na">newTopology</span><span class="o">();</span> @@ -767,7 +767,7 @@ $('#toc').on('click', 'a', function() { <div class="col-lg-12 footer"> Site last - generated: Mar 24, 2017 <br/> + generated: Apr 25, 2017 <br/> </div> </div> @@ -791,6 +791,13 @@ $('#toc').on('click', 'a', function() { respective owners.</p> </div> </div> + + <div class="container"> + <div class="row"> + <div> + <img class="img-responsive center-block" src="../img/edgent_incubation.png" style="display: block; margin: auto;"alt=""> + </div> + </div> </footer> </div><!-- /.row --> http://git-wip-us.apache.org/repos/asf/incubator-edgent-website/blob/7cc4ad1b/content/recipes/recipe_value_out_of_range.html ---------------------------------------------------------------------- diff --git a/content/recipes/recipe_value_out_of_range.html b/content/recipes/recipe_value_out_of_range.html index 5b89a73..7aa98fb 100644 --- a/content/recipes/recipe_value_out_of_range.html +++ b/content/recipes/recipe_value_out_of_range.html @@ -692,7 +692,7 @@ $('#toc').on('click', 'a', function() { <span class="kd">static</span> <span class="kt">double</span> <span class="n">OPTIMAL_TEMP_HIGH</span> <span class="o">=</span> <span class="mf">91.0</span><span class="o">;</span> <span class="kd">static</span> <span class="n">Range</span><span class="o"><</span><span class="n">Double</span><span class="o">></span> <span class="n">optimalTempRange</span> <span class="o">=</span> <span class="n">Ranges</span><span class="o">.</span><span class="na">closed</span><span class="o">(</span><span class="n">OPTIMAL_TEMP_LOW</span><span class="o">,</span> <span class="n">OPTIMAL_TEMP_HIGH</span><span class="o">);</span> - <span class="kd">public</span> <span class="kd">static</span> <span class="kt">void</span> <span class="n">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">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="n">DirectProvider</span> <span class="n">dp</span> <span class="o">=</span> <span class="k">new</span> <span class="n">DirectProvider</span><span class="o">();</span> @@ -815,7 +815,7 @@ Temperature may not be optimal! It is 77.5°F! * and a deadband filter to determine when the temperature * is out of the optimal range. */</span> - <span class="kd">public</span> <span class="kd">static</span> <span class="kt">void</span> <span class="n">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">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="n">DirectProvider</span> <span class="n">dp</span> <span class="o">=</span> <span class="k">new</span> <span class="n">DirectProvider</span><span class="o">();</span> @@ -880,7 +880,7 @@ Temperature may not be optimal! It is 77.5°F! <div class="col-lg-12 footer"> Site last - generated: Mar 24, 2017 <br/> + generated: Apr 25, 2017 <br/> </div> </div> @@ -904,6 +904,13 @@ Temperature may not be optimal! It is 77.5°F! respective owners.</p> </div> </div> + + <div class="container"> + <div class="row"> + <div> + <img class="img-responsive center-block" src="../img/edgent_incubation.png" style="display: block; margin: auto;"alt=""> + </div> + </div> </footer> </div><!-- /.row --> http://git-wip-us.apache.org/repos/asf/incubator-edgent-website/blob/7cc4ad1b/content/recipes/recipe_writing_a_connector.html ---------------------------------------------------------------------- diff --git a/content/recipes/recipe_writing_a_connector.html b/content/recipes/recipe_writing_a_connector.html index cf7c5cc..03ed5dc 100644 --- a/content/recipes/recipe_writing_a_connector.html +++ b/content/recipes/recipe_writing_a_connector.html @@ -700,7 +700,7 @@ $('#toc').on('click', 'a', function() { <div class="col-lg-12 footer"> Site last - generated: Mar 24, 2017 <br/> + generated: Apr 25, 2017 <br/> </div> </div> @@ -724,6 +724,13 @@ $('#toc').on('click', 'a', function() { respective owners.</p> </div> </div> + + <div class="container"> + <div class="row"> + <div> + <img class="img-responsive center-block" src="../img/edgent_incubation.png" style="display: block; margin: auto;"alt=""> + </div> + </div> </footer> </div><!-- /.row --> http://git-wip-us.apache.org/repos/asf/incubator-edgent-website/blob/7cc4ad1b/content/titlepage.html ---------------------------------------------------------------------- diff --git a/content/titlepage.html b/content/titlepage.html index 37c500d..6e647ff 100644 --- a/content/titlepage.html +++ b/content/titlepage.html @@ -666,7 +666,7 @@ $('#toc').on('click', 'a', function() { <div class="printTitleArea"> <div class="printTitle"></div> <div class="printSubtitle"></div> - <div class="lastGeneratedDate">Last generated: March 24, 2017</div> + <div class="lastGeneratedDate">Last generated: April 25, 2017</div> <hr /> <div class="printTitleImage"> @@ -713,7 +713,7 @@ $('#toc').on('click', 'a', function() { <div class="col-lg-12 footer"> Site last - generated: Mar 24, 2017 <br/> + generated: Apr 25, 2017 <br/> </div> </div> @@ -737,6 +737,13 @@ $('#toc').on('click', 'a', function() { respective owners.</p> </div> </div> + + <div class="container"> + <div class="row"> + <div> + <img class="img-responsive center-block" src="../img/edgent_incubation.png" style="display: block; margin: auto;"alt=""> + </div> + </div> </footer> </div><!-- /.row --> http://git-wip-us.apache.org/repos/asf/incubator-edgent-website/blob/7cc4ad1b/content/tocpage.html ---------------------------------------------------------------------- diff --git a/content/tocpage.html b/content/tocpage.html index 7fc5dad..8ec3766 100644 --- a/content/tocpage.html +++ b/content/tocpage.html @@ -907,7 +907,7 @@ $('#toc').on('click', 'a', function() { <div class="col-lg-12 footer"> Site last - generated: Mar 24, 2017 <br/> + generated: Apr 25, 2017 <br/> </div> </div> @@ -931,6 +931,13 @@ $('#toc').on('click', 'a', function() { respective owners.</p> </div> </div> + + <div class="container"> + <div class="row"> + <div> + <img class="img-responsive center-block" src="../img/edgent_incubation.png" style="display: block; margin: auto;"alt=""> + </div> + </div> </footer> </div><!-- /.row -->
