http://git-wip-us.apache.org/repos/asf/incubator-edgent-website/blob/399cc808/content/docs/tag_special_layouts.html ---------------------------------------------------------------------- diff --git a/content/docs/tag_special_layouts.html b/content/docs/tag_special_layouts.html index e9f6dc3..535214a 100644 --- a/content/docs/tag_special_layouts.html +++ b/content/docs/tag_special_layouts.html @@ -165,6 +165,12 @@ + + <li class="dropdownActive"><a href="/">edgent.apache.org</a></li> + + + + </ul> </li> @@ -280,7 +286,7 @@ window.location.href = uri; <ul id="mysidebar" class="nav"> <span class="siteTagline">Edgent</span> - <span class="versionTagline">Version 1.0.0</span> + <span class="versionTagline">Version 1.0.0-incubating</span>
http://git-wip-us.apache.org/repos/asf/incubator-edgent-website/blob/399cc808/content/index.html ---------------------------------------------------------------------- diff --git a/content/index.html b/content/index.html index 65e1b68..5d85f69 100644 --- a/content/index.html +++ b/content/index.html @@ -13,7 +13,7 @@ <meta charset="utf-8"> <meta http-equiv="X-UA-Compatible" content="IE=edge"> <meta name="viewport" content="width=device-width, initial-scale=1"> - <meta name="description" content="Edgent is an open source community for accelerating analytics at the edge."> + <meta name="description" content="Apache Edgent is an open source community for accelerating analytics at the edge."> <meta name="author" content=""> <title>Edgent</title> @@ -88,7 +88,7 @@ <span class="icon-bar"></span> <span class="icon-bar"></span> </button> - <a class="navbar-brand page-scroll" href="http://edgent.incubator.apache.org/#home";>Home</a> + <a class="navbar-brand page-scroll" href="/#home">Home</a> </div> <!-- Collect the nav links, forms, and other content for toggling --> <div class="collapse navbar-collapse" id="bs-example-navbar-collapse-1"> @@ -96,7 +96,7 @@ <li class="dropdown"><a href="#" class="dropdown-toggle" data-toggle="dropdown" role="button" aria-haspopup="true" aria-expanded="false">About Edgent</a> <ul class="dropdown-menu"> <li><a href="/docs/overview">About Edgent</a></li> - <li><a href="http://edgent.incubator.apache.org/docs/downloads.html/blob/master/LICENSE";>License</a></li> + <li><a href="https://github.com/apache/incubator-edgent/blob/master/LICENSE";>License</a></li> </ul> </li> <li class="dropdown"><a href="#" class="dropdown-toggle" data-toggle="dropdown" role="button" aria-haspopup="true" aria-expanded="false">Community</a> @@ -111,7 +111,7 @@ <li class="dropdown"><a href="#" class="dropdown-toggle" data-toggle="dropdown" role="button" aria-haspopup="true" aria-expanded="false">Getting Started</a> <ul class="dropdown-menu"> <li><a href="docs/edgent-getting-started">Getting Started Guide</a></li> - <li><a href="docs/downloads">Download Source</a></li> + <li><a href="docs/downloads">Downloads</a></li> <li><a href="docs/samples">Sample Programs</a></li> <li><a href="docs/faq">FAQ</a></li> @@ -121,7 +121,7 @@ <a href="#" class="dropdown-toggle" data-toggle="dropdown" role="button" aria-haspopup="true" aria-expanded="false">Documentation</a> <ul class="dropdown-menu"> <li><a href="docs/home">Documentation Home</a></li> - <li><a href="http://edgent.incubator.apache.org/javadoc/latest/index.html";>Javadoc</a></li> + <li><a href="https://edgent.incubator.apache.org/javadoc/latest/index.html";>Javadoc</a></li> </ul> </li> <li class="dropdown"> @@ -136,7 +136,7 @@ </ul> <ul class="nav navbar-nav navbar-right"> <li> - <a href="http://edgent.incubator.apache.org/docs/downloads.html";>Download Source</a> + <a href="/docs/downloads">Downloads</a> </li> <!-- <li> <a class="page-scroll" href="#services">Services</a> http://git-wip-us.apache.org/repos/asf/incubator-edgent-website/blob/399cc808/content/recipes/recipe_adaptable_deadtime_filter.html ---------------------------------------------------------------------- diff --git a/content/recipes/recipe_adaptable_deadtime_filter.html b/content/recipes/recipe_adaptable_deadtime_filter.html index 669d40c..8e88e0a 100644 --- a/content/recipes/recipe_adaptable_deadtime_filter.html +++ b/content/recipes/recipe_adaptable_deadtime_filter.html @@ -165,6 +165,12 @@ + + <li class="dropdownActive"><a href="/">edgent.apache.org</a></li> + + + + </ul> </li> @@ -280,7 +286,7 @@ window.location.href = uri; <ul id="mysidebar" class="nav"> <span class="siteTagline">Edgent</span> - <span class="versionTagline">Version 1.0.0</span> + <span class="versionTagline">Version 1.0.0-incubating</span> @@ -673,7 +679,7 @@ $('#toc').on('click', 'a', function() { <span class="o">.</span><span class="na">tag</span><span class="o">(</span><span class="s">"deadtimeFilteredEngineTemp"</span><span class="o">);</span> </code></pre></div> <h2 id="define-a-quot-set-deadtime-period-quot-method">Define a "set deadtime period" method</h2> -<div class="highlight"><pre><code class="language-java" data-lang="java"><span class="kd">static</span> <span class="o"><</span><span class="n">T</span><span class="o">></span> <span class="kt">void</span> <span class="nf">setDeadtimePeriod</span><span class="o">(</span><span class="n">Deadtime</span><span class="o"><</span><span class="n">T</span><span class="o">></span> <span class="n">deadtime</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="o">{</span> +<div class="highlight"><pre><code class="language-java" data-lang="java"><span class="kd">static</span> <span class="o"><</span><span class="n">T</span><span class="o">></span> <span class="kt">void</span> <span class="n">setDeadtimePeriod</span><span class="o">(</span><span class="n">Deadtime</span><span class="o"><</span><span class="n">T</span><span class="o">></span> <span class="n">deadtime</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="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">"Setting deadtime period="</span><span class="o">+</span><span class="n">period</span><span class="o">+</span><span class="s">" "</span><span class="o">+</span><span class="n">unit</span><span class="o">);</span> <span class="n">deadtime</span><span class="o">.</span><span class="na">setPeriod</span><span class="o">(</span><span class="n">period</span><span class="o">,</span> <span class="n">unit</span><span class="o">);</span> <span class="o">}</span> @@ -716,7 +722,7 @@ $('#toc').on('click', 'a', function() { * Respond to a simulated command stream to change the deadtime window * duration. */</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="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="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> @@ -750,12 +756,12 @@ $('#toc').on('click', 'a', function() { <span class="n">dp</span><span class="o">.</span><span class="na">submit</span><span class="o">(</span><span class="n">top</span><span class="o">);</span> <span class="o">}</span> - <span class="kd">static</span> <span class="o"><</span><span class="n">T</span><span class="o">></span> <span class="kt">void</span> <span class="nf">setDeadtimePeriod</span><span class="o">(</span><span class="n">Deadtime</span><span class="o"><</span><span class="n">T</span><span class="o">></span> <span class="n">deadtime</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="o">{</span> + <span class="kd">static</span> <span class="o"><</span><span class="n">T</span><span class="o">></span> <span class="kt">void</span> <span class="n">setDeadtimePeriod</span><span class="o">(</span><span class="n">Deadtime</span><span class="o"><</span><span class="n">T</span><span class="o">></span> <span class="n">deadtime</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="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">"Setting deadtime period="</span><span class="o">+</span><span class="n">period</span><span class="o">+</span><span class="s">" "</span><span class="o">+</span><span class="n">unit</span><span class="o">);</span> <span class="n">deadtime</span><span class="o">.</span><span class="na">setPeriod</span><span class="o">(</span><span class="n">period</span><span class="o">,</span> <span class="n">unit</span><span class="o">);</span> <span class="o">}</span> - <span class="kd">static</span> <span class="n">TStream</span><span class="o"><</span><span class="n">JsonObject</span><span class="o">></span> <span class="nf">simulatedSetDeadtimePeriodCmds</span><span class="o">(</span><span class="n">Topology</span> <span class="n">top</span><span class="o">)</span> <span class="o">{</span> + <span class="kd">static</span> <span class="n">TStream</span><span class="o"><</span><span class="n">JsonObject</span><span class="o">></span> <span class="n">simulatedSetDeadtimePeriodCmds</span><span class="o">(</span><span class="n">Topology</span> <span class="n">top</span><span class="o">)</span> <span class="o">{</span> <span class="n">AtomicInteger</span> <span class="n">lastPeriod</span> <span class="o">=</span> <span class="k">new</span> <span class="n">AtomicInteger</span><span class="o">(-</span><span class="mi">1</span><span class="o">);</span> <span class="n">TStream</span><span class="o"><</span><span class="n">JsonObject</span><span class="o">></span> <span class="n">cmds</span> <span class="o">=</span> <span class="n">top</span><span class="o">.</span><span class="na">poll</span><span class="o">(()</span> <span class="o">-></span> <span class="o">{</span> <span class="c1">// don't change on first invocation</span> http://git-wip-us.apache.org/repos/asf/incubator-edgent-website/blob/399cc808/content/recipes/recipe_adaptable_filter_range.html ---------------------------------------------------------------------- diff --git a/content/recipes/recipe_adaptable_filter_range.html b/content/recipes/recipe_adaptable_filter_range.html index 8240ba6..7c776d5 100644 --- a/content/recipes/recipe_adaptable_filter_range.html +++ b/content/recipes/recipe_adaptable_filter_range.html @@ -165,6 +165,12 @@ + + <li class="dropdownActive"><a href="/">edgent.apache.org</a></li> + + + + </ul> </li> @@ -280,7 +286,7 @@ window.location.href = uri; <ul id="mysidebar" class="nav"> <span class="siteTagline">Edgent</span> - <span class="versionTagline">Version 1.0.0</span> + <span class="versionTagline">Version 1.0.0-incubating</span> @@ -641,7 +647,7 @@ $('#toc').on('click', 'a', function() { <a target="_blank" href="https://github.com/apache/incubator-edgent-website/blob/master/site/recipes/recipe_adaptable_filter_range.md"; class="btn btn-default githubEditButton" role="button"><i class="fa fa-github fa-lg"></i> Edit me</a> - <p>The <a href="recipe_value_out_of_range.html">Detecting a sensor value out of range</a> recipe introduced the basics of filtering as well as the use of a <a href="http://edgent.incubator.apache.org/javadoc/latest/index.html?org/apache/edgent/analytics/sensors/Range.html";>Range</a>.</p> + <p>The <a href="recipe_value_out_of_range.html">Detecting a sensor value out of range</a> recipe introduced the basics of filtering as well as the use of a <a href="https://edgent.incubator.apache.org/javadoc/latest/index.html?org/apache/edgent/analytics/sensors/Range.html";>Range</a>.</p> <p>Oftentimes, a user wants a filter's behavior to be adaptable rather than static. A filter's range can be made changeable via commands from some external source or just changed as a result of some other local analytics.</p> @@ -659,7 +665,7 @@ $('#toc').on('click', 'a', function() { <span class="k">new</span> <span class="n">AtomicReference</span><span class="o"><>(</span><span class="n">DEFAULT_TEMP_RANGE</span><span class="o">);</span> </code></pre></div> <h2 id="define-a-method-to-change-the-range">Define a method to change the range</h2> -<div class="highlight"><pre><code class="language-java" data-lang="java"><span class="kd">static</span> <span class="kt">void</span> <span class="nf">setOptimalTempRange</span><span class="o">(</span><span class="n">Range</span><span class="o"><</span><span class="n">Double</span><span class="o">></span> <span class="n">range</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="kt">void</span> <span class="nf">setOptimalTempRange</span><span class="p">(</span><span class="n">Range</span><span class="o"><</span><span class="n">Double</span><span class="o">></span> <span class="n">range</span><span class="o">)</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">"Using optimal temperature range: "</span> <span class="o">+</span> <span class="n">range</span><span class="o">);</span> <span class="n">optimalTempRangeRef</span><span class="o">.</span><span class="na">set</span><span class="o">(</span><span class="n">range</span><span class="o">);</span> <span class="o">}</span> @@ -705,7 +711,7 @@ $('#toc').on('click', 'a', function() { <span class="kd">static</span> <span class="n">AtomicReference</span><span class="o"><</span><span class="n">Range</span><span class="o"><</span><span class="n">Double</span><span class="o">>></span> <span class="n">optimalTempRangeRef</span> <span class="o">=</span> <span class="k">new</span> <span class="n">AtomicReference</span><span class="o"><>(</span><span class="n">DEFAULT_TEMP_RANGE</span><span class="o">);</span> - <span class="kd">static</span> <span class="kt">void</span> <span class="nf">setOptimalTempRange</span><span class="o">(</span><span class="n">Range</span><span class="o"><</span><span class="n">Double</span><span class="o">></span> <span class="n">range</span><span class="o">)</span> <span class="o">{</span> + <span class="kd">static</span> <span class="kt">void</span> <span class="n">setOptimalTempRange</span><span class="o">(</span><span class="n">Range</span><span class="o"><</span><span class="n">Double</span><span class="o">></span> <span class="n">range</span><span class="o">)</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">"Using optimal temperature range: "</span> <span class="o">+</span> <span class="n">range</span><span class="o">);</span> <span class="n">optimalTempRangeRef</span><span class="o">.</span><span class="na">set</span><span class="o">(</span><span class="n">range</span><span class="o">);</span> <span class="o">}</span> @@ -715,7 +721,7 @@ $('#toc').on('click', 'a', function() { * 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="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">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="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> http://git-wip-us.apache.org/repos/asf/incubator-edgent-website/blob/399cc808/content/recipes/recipe_adaptable_polling_source.html ---------------------------------------------------------------------- diff --git a/content/recipes/recipe_adaptable_polling_source.html b/content/recipes/recipe_adaptable_polling_source.html index a9894ba..ce39889 100644 --- a/content/recipes/recipe_adaptable_polling_source.html +++ b/content/recipes/recipe_adaptable_polling_source.html @@ -165,6 +165,12 @@ + + <li class="dropdownActive"><a href="/">edgent.apache.org</a></li> + + + + </ul> </li> @@ -280,7 +286,7 @@ window.location.href = uri; <ul id="mysidebar" class="nav"> <span class="siteTagline">Edgent</span> - <span class="versionTagline">Version 1.0.0</span> + <span class="versionTagline">Version 1.0.0-incubating</span> @@ -647,7 +653,7 @@ $('#toc').on('click', 'a', function() { <p>An Edgent <code>IotProvider</code> and <code>IoTDevice</code> with its command streams would be a natural way to control the application. In this recipe we will just simulate a "set poll period" command stream.</p> -<p>The <code>Topology.poll()</code> <a href="http://edgent.incubator.apache.org/javadoc/latest/org/apache/edgent/topology/Topology.html#poll-org.apache.edgent.function.Supplier-long-java.util.concurrent.TimeUnit-";>documentation</a> describes how the poll period may be changed at runtime.</p> +<p>The <code>Topology.poll()</code> <a href="https://edgent.incubator.apache.org/javadoc/latest/org/apache/edgent/topology/Topology.html#poll-org.apache.edgent.function.Supplier-long-java.util.concurrent.TimeUnit-";>documentation</a> describes how the poll period may be changed at runtime.</p> <p>The mechanism is based on a more general Edgent runtime <code>edgent.execution.services.ControlService</code> service. The runtime registers "control beans" for entities that are controllable. These controls can be retrieved at runtime via the service.</p> @@ -663,7 +669,7 @@ $('#toc').on('click', 'a', function() { <p>It's also a good practice to add tags to streams to improve the usability of the development mode Edgent console.</p> <h2 id="define-a-quot-set-poll-period-quot-method">Define a "set poll period" method</h2> -<div class="highlight"><pre><code class="language-java" data-lang="java"><span class="kd">static</span> <span class="o"><</span><span class="n">T</span><span class="o">></span> <span class="kt">void</span> <span class="nf">setPollPeriod</span><span class="o">(</span><span class="n">TStream</span><span class="o"><</span><span class="n">T</span><span class="o">></span> <span class="n">pollStream</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="o">{</span> +<div class="highlight"><pre><code class="language-java" data-lang="java"><span class="kd">static</span> <span class="o"><</span><span class="n">T</span><span class="o">></span> <span class="kt">void</span> <span class="n">setPollPeriod</span><span class="o">(</span><span class="n">TStream</span><span class="o"><</span><span class="n">T</span><span class="o">></span> <span class="n">pollStream</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="o">{</span> <span class="c1">// get the topology's runtime ControlService service</span> <span class="n">ControlService</span> <span class="n">cs</span> <span class="o">=</span> <span class="n">pollStream</span><span class="o">.</span><span class="na">topology</span><span class="o">().</span><span class="na">getRuntimeServiceSupplier</span><span class="o">()</span> <span class="o">.</span><span class="na">get</span><span class="o">().</span><span class="na">getService</span><span class="o">(</span><span class="n">ControlService</span><span class="o">.</span><span class="na">class</span><span class="o">);</span> @@ -707,7 +713,7 @@ $('#toc').on('click', 'a', function() { * Poll a temperature sensor to periodically obtain temperature readings. * Respond to a simulated command stream to change the poll period. */</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="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="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> @@ -733,7 +739,7 @@ $('#toc').on('click', 'a', function() { <span class="n">dp</span><span class="o">.</span><span class="na">submit</span><span class="o">(</span><span class="n">top</span><span class="o">);</span> <span class="o">}</span> - <span class="kd">static</span> <span class="o"><</span><span class="n">T</span><span class="o">></span> <span class="kt">void</span> <span class="nf">setPollPeriod</span><span class="o">(</span><span class="n">TStream</span><span class="o"><</span><span class="n">T</span><span class="o">></span> <span class="n">pollStream</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="o">{</span> + <span class="kd">static</span> <span class="o"><</span><span class="n">T</span><span class="o">></span> <span class="kt">void</span> <span class="n">setPollPeriod</span><span class="o">(</span><span class="n">TStream</span><span class="o"><</span><span class="n">T</span><span class="o">></span> <span class="n">pollStream</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="o">{</span> <span class="c1">// get the topology's runtime ControlService service</span> <span class="n">ControlService</span> <span class="n">cs</span> <span class="o">=</span> <span class="n">pollStream</span><span class="o">.</span><span class="na">topology</span><span class="o">().</span><span class="na">getRuntimeServiceSupplier</span><span class="o">()</span> <span class="o">.</span><span class="na">get</span><span class="o">().</span><span class="na">getService</span><span class="o">(</span><span class="n">ControlService</span><span class="o">.</span><span class="na">class</span><span class="o">);</span> @@ -746,7 +752,7 @@ $('#toc').on('click', 'a', function() { <span class="n">control</span><span class="o">.</span><span class="na">setPeriod</span><span class="o">(</span><span class="n">period</span><span class="o">,</span> <span class="n">unit</span><span class="o">);</span> <span class="o">}</span> - <span class="kd">static</span> <span class="n">TStream</span><span class="o"><</span><span class="n">JsonObject</span><span class="o">></span> <span class="nf">simulatedSetPollPeriodCmds</span><span class="o">(</span><span class="n">Topology</span> <span class="n">top</span><span class="o">)</span> <span class="o">{</span> + <span class="kd">static</span> <span class="n">TStream</span><span class="o"><</span><span class="n">JsonObject</span><span class="o">></span> <span class="n">simulatedSetPollPeriodCmds</span><span class="o">(</span><span class="n">Topology</span> <span class="n">top</span><span class="o">)</span> <span class="o">{</span> <span class="n">AtomicInteger</span> <span class="n">lastPeriod</span> <span class="o">=</span> <span class="k">new</span> <span class="n">AtomicInteger</span><span class="o">(</span><span class="mi">1</span><span class="o">);</span> <span class="n">TStream</span><span class="o"><</span><span class="n">JsonObject</span><span class="o">></span> <span class="n">cmds</span> <span class="o">=</span> <span class="n">top</span><span class="o">.</span><span class="na">poll</span><span class="o">(()</span> <span class="o">-></span> <span class="o">{</span> <span class="c1">// toggle between 1 and 2 sec period</span> http://git-wip-us.apache.org/repos/asf/incubator-edgent-website/blob/399cc808/content/recipes/recipe_combining_streams_processing_results.html ---------------------------------------------------------------------- diff --git a/content/recipes/recipe_combining_streams_processing_results.html b/content/recipes/recipe_combining_streams_processing_results.html index 5169e87..43566d6 100644 --- a/content/recipes/recipe_combining_streams_processing_results.html +++ b/content/recipes/recipe_combining_streams_processing_results.html @@ -165,6 +165,12 @@ + + <li class="dropdownActive"><a href="/">edgent.apache.org</a></li> + + + + </ul> </li> @@ -280,7 +286,7 @@ window.location.href = uri; <ul id="mysidebar" class="nav"> <span class="siteTagline">Edgent</span> - <span class="versionTagline">Version 1.0.0</span> + <span class="versionTagline">Version 1.0.0-incubating</span> @@ -665,7 +671,7 @@ $('#toc').on('click', 'a', function() { <span class="kd">public</span> <span class="n">Integer</span> <span class="n">currentDiastolic</span> <span class="o">=</span> <span class="mi">75</span><span class="o">;</span> <span class="n">Random</span> <span class="n">rand</span><span class="o">;</span> - <span class="kd">public</span> <span class="nf">HeartMonitorSensor</span><span class="o">()</span> <span class="o">{</span> + <span class="kd">public</span> <span class="n">HeartMonitorSensor</span><span class="o">()</span> <span class="o">{</span> <span class="n">rand</span> <span class="o">=</span> <span class="k">new</span> <span class="n">Random</span><span class="o">();</span> <span class="o">}</span> @@ -674,7 +680,7 @@ $('#toc').on('click', 'a', function() { * pressure and a random diastolic pressure. */</span> <span class="nd">@Override</span> - <span class="kd">public</span> <span class="n">Map</span><span class="o"><</span><span class="n">String</span><span class="o">,</span> <span class="n">Integer</span><span class="o">></span> <span class="nf">get</span><span class="o">()</span> <span class="o">{</span> + <span class="kd">public</span> <span class="n">Map</span><span class="o"><</span><span class="n">String</span><span class="o">,</span> <span class="n">Integer</span><span class="o">></span> <span class="n">get</span><span class="o">()</span> <span class="o">{</span> <span class="c1">// Change the current pressure by some random amount between -2 and 2</span> <span class="n">Integer</span> <span class="n">newSystolic</span> <span class="o">=</span> <span class="n">rand</span><span class="o">.</span><span class="na">nextInt</span><span class="o">(</span><span class="mi">2</span> <span class="o">+</span> <span class="mi">1</span> <span class="o">+</span> <span class="mi">2</span><span class="o">)</span> <span class="o">-</span> <span class="mi">2</span> <span class="o">+</span> <span class="n">currentSystolic</span><span class="o">;</span> <span class="n">currentSystolic</span> <span class="o">=</span> <span class="n">newSystolic</span><span class="o">;</span> @@ -705,7 +711,7 @@ $('#toc').on('click', 'a', function() { <span class="kn">import</span> <span class="nn">org.apache.edgent.topology.Topology</span><span class="o">;</span> <span class="kd">public</span> <span class="kd">class</span> <span class="nc">CombiningStreamsProcessingResults</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="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="o">{</span> <span class="n">HeartMonitorSensor</span> <span class="n">monitor</span> <span class="o">=</span> <span class="k">new</span> <span class="n">HeartMonitorSensor</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> @@ -729,8 +735,8 @@ $('#toc').on('click', 'a', function() { </code></pre></div> <h2 id="splitting-the-readings">Splitting the readings</h2> -<p>We are now ready to split the <code>readings</code> stream by the blood pressure category. Let's look more closely at the method declaration of <code>split</code> below. For more details about <code>split</code>, refer to the <a href="http://edgent.incubator.apache.org/javadoc/latest/org/apache/edgent/topology/TStream.html#split-int-org.apache.edgent.function.ToIntFunction-";>Javadoc</a>.</p> -<div class="highlight"><pre><code class="language-java" data-lang="java"><span class="n">java</span><span class="o">.</span><span class="na">util</span><span class="o">.</span><span class="na">List</span><span class="o"><</span><span class="n">TStream</span><span class="o"><</span><span class="n">T</span><span class="o">>></span> <span class="nf">split</span><span class="o">(</span><span class="kt">int</span> <span class="n">n</span><span class="o">,</span> <span class="n">ToIntFunction</span><span class="o"><</span><span class="n">T</span><span class="o">></span> <span class="n">splitter</span><span class="o">)</span> +<p>We are now ready to split the <code>readings</code> stream by the blood pressure category. Let's look more closely at the method declaration of <code>split</code> below. For more details about <code>split</code>, refer to the <a href="https://edgent.incubator.apache.org/javadoc/latest/org/apache/edgent/topology/TStream.html#split-int-org.apache.edgent.function.ToIntFunction-";>Javadoc</a>.</p> +<div class="highlight"><pre><code class="language-java" data-lang="java"><span class="n">java</span><span class="o">.</span><span class="na">util</span><span class="o">.</span><span class="na">List</span><span class="o"><</span><span class="n">TStream</span><span class="o"><</span><span class="n">T</span><span class="o">>></span> <span class="n">split</span><span class="o">(</span><span class="kt">int</span> <span class="n">n</span><span class="o">,</span> <span class="n">ToIntFunction</span><span class="o"><</span><span class="n">T</span><span class="o">></span> <span class="n">splitter</span><span class="o">)</span> </code></pre></div> <p><code>split</code> returns a <code>List</code> of <code>TStream</code> objects, where each item in the list is one of the resulting output streams. In this case, one stream in the list will contain a flow of tuples where the blood pressure reading belongs to one of the five blood pressure categories. Another stream will contain a flow of tuples where the blood pressure reading belongs to a different blood pressure category, and so on.</p> @@ -826,7 +832,7 @@ $('#toc').on('click', 'a', function() { </code></pre></div> <h2 id="combining-the-alert-streams">Combining the alert streams</h2> -<p>At this point, we have five streams of alerts. Suppose the doctors are interested in seeing a combination of the <em>Normal</em> alerts and <em>Prehypertension</em> alerts. Or, suppose that they would like to see all of the alerts from all categories together. Here, <code>union</code> comes in handy. For more details about <code>union</code>, refer to the <a href="http://edgent.incubator.apache.org/javadoc/latest/org/apache/edgent/topology/TStream.html#union-org.apache.edgent.topology.TStream-";>Javadoc</a>.</p> +<p>At this point, we have five streams of alerts. Suppose the doctors are interested in seeing a combination of the <em>Normal</em> alerts and <em>Prehypertension</em> alerts. Or, suppose that they would like to see all of the alerts from all categories together. Here, <code>union</code> comes in handy. For more details about <code>union</code>, refer to the <a href="https://edgent.incubator.apache.org/javadoc/latest/org/apache/edgent/topology/TStream.html#union-org.apache.edgent.topology.TStream-";>Javadoc</a>.</p> <p>There are two ways to define a union. You can either union a <code>TStream</code> with another <code>TStream</code>, or with a set of streams (<code>Set<TStream<T>></code>). In both cases, a single <code>TStream</code> is returned containing the tuples that flow on the input stream(s).</p> http://git-wip-us.apache.org/repos/asf/incubator-edgent-website/blob/399cc808/content/recipes/recipe_concurrent_analytics.html ---------------------------------------------------------------------- diff --git a/content/recipes/recipe_concurrent_analytics.html b/content/recipes/recipe_concurrent_analytics.html index a7bb30d..9b20409 100644 --- a/content/recipes/recipe_concurrent_analytics.html +++ b/content/recipes/recipe_concurrent_analytics.html @@ -165,6 +165,12 @@ + + <li class="dropdownActive"><a href="/">edgent.apache.org</a></li> + + + + </ul> </li> @@ -280,7 +286,7 @@ window.location.href = uri; <ul id="mysidebar" class="nav"> <span class="siteTagline">Edgent</span> - <span class="versionTagline">Version 1.0.0</span> + <span class="versionTagline">Version 1.0.0-incubating</span> @@ -691,7 +697,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="nf">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="n">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> @@ -730,7 +736,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="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">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="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> @@ -769,7 +775,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="nf">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="n">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> @@ -778,7 +784,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="nf">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="n">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> @@ -788,7 +794,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="nf">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="n">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> @@ -798,11 +804,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="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="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="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="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="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="o">}</span> <span class="o">}</span> http://git-wip-us.apache.org/repos/asf/incubator-edgent-website/blob/399cc808/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 b86b4f4..348a444 100644 --- a/content/recipes/recipe_different_processing_against_stream.html +++ b/content/recipes/recipe_different_processing_against_stream.html @@ -165,6 +165,12 @@ + + <li class="dropdownActive"><a href="/">edgent.apache.org</a></li> + + + + </ul> </li> @@ -280,7 +286,7 @@ window.location.href = uri; <ul id="mysidebar" class="nav"> <span class="siteTagline">Edgent</span> - <span class="versionTagline">Version 1.0.0</span> + <span class="versionTagline">Version 1.0.0-incubating</span> @@ -678,7 +684,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="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">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="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> @@ -792,7 +798,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="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">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="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> http://git-wip-us.apache.org/repos/asf/incubator-edgent-website/blob/399cc808/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 fb8f9d8..bc584de 100644 --- a/content/recipes/recipe_dynamic_analytic_control.html +++ b/content/recipes/recipe_dynamic_analytic_control.html @@ -165,6 +165,12 @@ + + <li class="dropdownActive"><a href="/">edgent.apache.org</a></li> + + + + </ul> </li> @@ -280,7 +286,7 @@ window.location.href = uri; <ul id="mysidebar" class="nav"> <span class="siteTagline">Edgent</span> - <span class="versionTagline">Version 1.0.0</span> + <span class="versionTagline">Version 1.0.0-incubating</span> http://git-wip-us.apache.org/repos/asf/incubator-edgent-website/blob/399cc808/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 ce773a2..c9423bc 100644 --- a/content/recipes/recipe_external_filter_range.html +++ b/content/recipes/recipe_external_filter_range.html @@ -165,6 +165,12 @@ + + <li class="dropdownActive"><a href="/">edgent.apache.org</a></li> + + + + </ul> </li> @@ -280,7 +286,7 @@ window.location.href = uri; <ul id="mysidebar" class="nav"> <span class="siteTagline">Edgent</span> - <span class="versionTagline">Version 1.0.0</span> + <span class="versionTagline">Version 1.0.0-incubating</span> @@ -641,7 +647,7 @@ $('#toc').on('click', 'a', function() { <a target="_blank" href="https://github.com/apache/incubator-edgent-website/blob/master/site/recipes/recipe_external_filter_range.md"; class="btn btn-default githubEditButton" role="button"><i class="fa fa-github fa-lg"></i> Edit me</a> - <p>The <a href="recipe_value_out_of_range.html">Detecting a sensor value out of range</a> recipe introduced the basics of filtering as well as the use of a <a href="http://edgent.incubator.apache.org/javadoc/latest/index.html?org/apache/edgent/analytics/sensors/Range.html";>Range</a>.</p> + <p>The <a href="recipe_value_out_of_range.html">Detecting a sensor value out of range</a> recipe introduced the basics of filtering as well as the use of a <a href="https://edgent.incubator.apache.org/javadoc/latest/index.html?org/apache/edgent/analytics/sensors/Range.html";>Range</a>.</p> <p>Oftentimes, a user wants to initialize a range specification from an external configuration file so the application code is more easily configured and reusable.</p> @@ -698,7 +704,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="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="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="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> @@ -715,9 +721,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="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">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="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="nf">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="n">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> http://git-wip-us.apache.org/repos/asf/incubator-edgent-website/blob/399cc808/content/recipes/recipe_hello_edgent.html ---------------------------------------------------------------------- diff --git a/content/recipes/recipe_hello_edgent.html b/content/recipes/recipe_hello_edgent.html index 1cf9720..9f2c0e6 100644 --- a/content/recipes/recipe_hello_edgent.html +++ b/content/recipes/recipe_hello_edgent.html @@ -165,6 +165,12 @@ + + <li class="dropdownActive"><a href="/">edgent.apache.org</a></li> + + + + </ul> </li> @@ -280,7 +286,7 @@ window.location.href = uri; <ul id="mysidebar" class="nav"> <span class="siteTagline">Edgent</span> - <span class="versionTagline">Version 1.0.0</span> + <span class="versionTagline">Version 1.0.0-incubating</span> @@ -642,7 +648,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="o">(</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="p">(</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> @@ -654,7 +660,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="o">(</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="p">(</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> @@ -668,7 +674,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="o">(</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="p">(</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> @@ -682,7 +688,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="o">(</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="p">(</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> http://git-wip-us.apache.org/repos/asf/incubator-edgent-website/blob/399cc808/content/recipes/recipe_parallel_analytics.html ---------------------------------------------------------------------- diff --git a/content/recipes/recipe_parallel_analytics.html b/content/recipes/recipe_parallel_analytics.html index 0f532d7..50be63c 100644 --- a/content/recipes/recipe_parallel_analytics.html +++ b/content/recipes/recipe_parallel_analytics.html @@ -165,6 +165,12 @@ + + <li class="dropdownActive"><a href="/">edgent.apache.org</a></li> + + + + </ul> </li> @@ -280,7 +286,7 @@ window.location.href = uri; <ul id="mysidebar" class="nav"> <span class="siteTagline">Edgent</span> - <span class="versionTagline">Version 1.0.0</span> + <span class="versionTagline">Version 1.0.0-incubating</span> @@ -688,7 +694,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="nf">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="n">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> @@ -741,7 +747,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="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">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="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> @@ -774,7 +780,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="nf">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="n">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> @@ -788,11 +794,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="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="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="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="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="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="o">}</span> <span class="o">}</span> http://git-wip-us.apache.org/repos/asf/incubator-edgent-website/blob/399cc808/content/recipes/recipe_source_function.html ---------------------------------------------------------------------- diff --git a/content/recipes/recipe_source_function.html b/content/recipes/recipe_source_function.html index 6f896a5..528d83a 100644 --- a/content/recipes/recipe_source_function.html +++ b/content/recipes/recipe_source_function.html @@ -165,6 +165,12 @@ + + <li class="dropdownActive"><a href="/">edgent.apache.org</a></li> + + + + </ul> </li> @@ -280,7 +286,7 @@ window.location.href = uri; <ul id="mysidebar" class="nav"> <span class="siteTagline">Edgent</span> - <span class="versionTagline">Version 1.0.0</span> + <span class="versionTagline">Version 1.0.0-incubating</span> @@ -648,7 +654,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="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> +<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> <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> @@ -662,7 +668,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="nf">InputStreamReader</span><span class="o">(</span><span class="n">is</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">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> @@ -675,13 +681,15 @@ $('#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="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> +<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> <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> <span class="kd">final</span> <span class="n">URL</span> <span class="n">url</span> <span class="o">=</span> <span class="k">new</span> <span class="n">URL</span><span class="o">(</span><span class="s">"http://finance.yahoo.com/d/quotes.csv?s=BAC+COG+FCX&f=snabl";</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">linesOfWebsite</span> <span class="o">=</span> <span class="n">top</span><span class="o">.</span><span class="na">source</span><span class="o">(</span><span class="n">queryWebsite</span><span class="o">(</span><span class="n">url</span><span class="o">));</span> + + <span class="n">dp</span><span class="o">.</span><span class="na">submit</span><span class="o">(</span><span class="n">top</span><span class="o">);</span> <span class="o">}</span> </code></pre></div> <p>Source methods such as <code>Topology.source()</code> and <code>Topology.strings()</code> return a <code>TStream</code>. If we print the <code>linesOfWebsite</code> stream to standard output and run the application, we can see that it correctly generates the data and feeds it into the Edgent runtime:</p> @@ -694,7 +702,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="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> +<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> <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>
