You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@edgent.apache.org by dl...@apache.org on 2016/12/22 22:25:17 UTC
[1/3] incubator-edgent-website git commit: from
898caa4662580930944508bd7233f1398830ff4f
Repository: incubator-edgent-website
Updated Branches:
refs/heads/asf-site 00f24bc6d -> 399cc8082
http://git-wip-us.apache.org/repos/asf/incubator-edgent-website/blob/399cc808/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 a07c060..ddabdcf 100644
--- a/content/recipes/recipe_value_out_of_range.html
+++ b/content/recipes/recipe_value_out_of_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>
@@ -670,7 +676,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="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>
@@ -689,7 +695,7 @@ $('#toc').on('click', 'a', function() {
</code></pre></div>
<h2 id="simple-filtering">Simple filtering</h2>
-<p>If the corn grower is interested in determining when the temperature is strictly out of the optimal range of 77�F and 91�F, a simple filter can be used. The <code>filter</code> method can be applied to <code>TStream</code> objects, where a filter predicate determines which tuples to keep for further processing. For its method declaration, refer to the <a href="http://edgent.incubator.apache.org/javadoc/latest/org/apache/edgent/topology/TStream.html#filter-org.apache.edgent.function.Predicate-">Javadoc</a>.</p>
+<p>If the corn grower is interested in determining when the temperature is strictly out of the optimal range of 77�F and 91�F, a simple filter can be used. The <code>filter</code> method can be applied to <code>TStream</code> objects, where a filter predicate determines which tuples to keep for further processing. For its method declaration, refer to the <a href="https://edgent.incubator.apache.org/javadoc/latest/org/apache/edgent/topology/TStream.html#filter-org.apache.edgent.function.Predicate-">Javadoc</a>.</p>
<p>In this case, we want to keep temperatures below the lower range value <em>or</em> above the upper range value. This is expressed in the filter predicate, which follows Java's syntax for <a href="https://docs.oracle.com/javase/tutorial/java/javaOO/lambdaexpressions.html#syntax">lambda expressions</a>. Then, we terminate the stream (using <code>sink</code>) by printing out the warning to standard out. Note that <code>\u00b0</code> is the Unicode encoding for the degree (�) symbol.</p>
<div class="highlight"><pre><code class="language-java" data-lang="java"><span class="n">TStream</span><span class="o"><</span><span class="n">Double</span><span class="o">></span> <span class="n">simpleFiltered</span> <span class="o">=</span> <span class="n">temp</span><span class="o">.</span><span class="na">filter</span><span class="o">(</span><span class="n">tuple</span> <span class="o">-></span>
@@ -704,7 +710,7 @@ $('#toc').on('click', 'a', function() {
<p>The <code>deadband</code> filter is a part of the <code>edgent.analytics</code> package focused on handling sensor data. Let's look more closely at the method declaration below.</p>
<div class="highlight"><pre><code class="language-java" data-lang="java"><span class="n">deadband</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">stream</span><span class="o">,</span> <span class="n">Function</span><span class="o"><</span><span class="n">T</span><span class="o">,</span><span class="n">V</span><span class="o">></span> <span class="n">value</span><span class="o">,</span> <span class="n">Predicate</span><span class="o"><</span><span class="n">V</span><span class="o">></span> <span class="n">inBand</span><span class="o">)</span>
</code></pre></div>
-<p>The first parameter is the stream to the filtered, which is <code>temp</code> in our scenario. The second parameter is the value to examine. Here, we use the <code>identity()</code> method to return a tuple on the stream. The last parameter is the predicate that defines the optimal range, that is, between 77�F and 91�F. it is important to note that this differs from the <code>TStream</code> version of <code>filter</code> in which one must explicitly specify the values that are out of range. The code snippet below demonstrates how the method call is pieced together. The <code>deadbandFiltered</code> stream contains temperature readings that follow the rules as described in the <a href="http://edgent.incubator.apache.org/javadoc/latest/org/apache/edgent/analytics/sensors/Filters.html#deadband-org.apache.edgent.topology.TStream-org.apache.edgent.function.Function-org.apache.edgent.function.Predicate-">Javadoc</a>:</p>
+<p>The first parameter is the stream to the filtered, which is <code>temp</code> in our scenario. The second parameter is the value to examine. Here, we use the <code>identity()</code> method to return a tuple on the stream. The last parameter is the predicate that defines the optimal range, that is, between 77�F and 91�F. it is important to note that this differs from the <code>TStream</code> version of <code>filter</code> in which one must explicitly specify the values that are out of range. The code snippet below demonstrates how the method call is pieced together. The <code>deadbandFiltered</code> stream contains temperature readings that follow the rules as described in the <a href="https://edgent.incubator.apache.org/javadoc/latest/org/apache/edgent/analytics/sensors/Filters.html#deadband-org.apache.edgent.topology.TStream-org.apache.edgent.function.Function-org.apache.edgent.function.Predicate-">Javadoc</a>:</p>
<ul>
<li>the value is outside of the optimal range (deadband)</li>
@@ -793,7 +799,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="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/title-checker.html
----------------------------------------------------------------------
diff --git a/content/title-checker.html b/content/title-checker.html
index 6f36952..c3aa553 100644
--- a/content/title-checker.html
+++ b/content/title-checker.html
@@ -2699,5 +2699,107 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+Problem: The top drop-down navigation item title "edgent.apache.org" does not match the page title "Edgent".
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
</body>
</html>
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/incubator-edgent-website/blob/399cc808/content/titlepage.html
----------------------------------------------------------------------
diff --git a/content/titlepage.html b/content/titlepage.html
index 0587304..d65cf4b 100644
--- a/content/titlepage.html
+++ b/content/titlepage.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/tocpage.html
----------------------------------------------------------------------
diff --git a/content/tocpage.html b/content/tocpage.html
index 017554b..8be80f0 100644
--- a/content/tocpage.html
+++ b/content/tocpage.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/urls_mydoc.txt
----------------------------------------------------------------------
diff --git a/content/urls_mydoc.txt b/content/urls_mydoc.txt
index 838d85a..17d1c7d 100644
--- a/content/urls_mydoc.txt
+++ b/content/urls_mydoc.txt
@@ -219,5 +219,12 @@ faq:
+/:
+ title: "edgent.apache.org"
+ url: "../"
+ link: "<a href='../'>edgent.apache.org</a>"
+
+
+
[2/3] incubator-edgent-website git commit: from
898caa4662580930944508bd7233f1398830ff4f
Posted by dl...@apache.org.
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>
[3/3] incubator-edgent-website git commit: from
898caa4662580930944508bd7233f1398830ff4f
Posted by dl...@apache.org.
from 898caa4662580930944508bd7233f1398830ff4f
Project: http://git-wip-us.apache.org/repos/asf/incubator-edgent-website/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-edgent-website/commit/399cc808
Tree: http://git-wip-us.apache.org/repos/asf/incubator-edgent-website/tree/399cc808
Diff: http://git-wip-us.apache.org/repos/asf/incubator-edgent-website/diff/399cc808
Branch: refs/heads/asf-site
Commit: 399cc8082f9a9edac07e101160a2e4accee68b8f
Parents: 00f24bc
Author: Dale LaBossiere <dl...@us.ibm.com>
Authored: Thu Dec 22 17:21:30 2016 -0500
Committer: Dale LaBossiere <dl...@us.ibm.com>
Committed: Thu Dec 22 17:21:30 2016 -0500
----------------------------------------------------------------------
content/404.html | 8 +-
content/Gemfile.lock | 209 -------------------
content/algolia_search.json | 6 +-
content/doap_Edgent.rdf | 4 +-
content/docs/committers.html | 8 +-
content/docs/common-edgent-operations.html | 10 +-
content/docs/community.html | 8 +-
content/docs/console.html | 16 +-
content/docs/downloads.html | 42 ++--
content/docs/edgent-getting-started.html | 16 +-
content/docs/edgent_index.html | 8 +-
content/docs/faq.html | 18 +-
content/docs/home.html | 8 +-
content/docs/overview.html | 8 +-
content/docs/quickstart.html | 12 +-
content/docs/samples.html | 10 +-
content/docs/search.html | 8 +-
content/docs/streaming-concepts.html | 20 +-
content/docs/tag_collaboration.html | 8 +-
content/docs/tag_content_types.html | 8 +-
content/docs/tag_formatting.html | 8 +-
content/docs/tag_getting_started.html | 8 +-
content/docs/tag_mobile.html | 8 +-
content/docs/tag_navigation.html | 8 +-
content/docs/tag_publishing.html | 8 +-
content/docs/tag_single_sourcing.html | 8 +-
content/docs/tag_special_layouts.html | 8 +-
content/index.html | 12 +-
.../recipe_adaptable_deadtime_filter.html | 16 +-
.../recipes/recipe_adaptable_filter_range.html | 16 +-
.../recipe_adaptable_polling_source.html | 18 +-
...pe_combining_streams_processing_results.html | 20 +-
.../recipes/recipe_concurrent_analytics.html | 22 +-
...ipe_different_processing_against_stream.html | 12 +-
.../recipe_dynamic_analytic_control.html | 8 +-
.../recipes/recipe_external_filter_range.html | 16 +-
content/recipes/recipe_hello_edgent.html | 16 +-
content/recipes/recipe_parallel_analytics.html | 18 +-
content/recipes/recipe_source_function.html | 18 +-
content/recipes/recipe_value_out_of_range.html | 16 +-
content/title-checker.html | 102 +++++++++
content/titlepage.html | 8 +-
content/tocpage.html | 8 +-
content/urls_mydoc.txt | 7 +
44 files changed, 480 insertions(+), 344 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-edgent-website/blob/399cc808/content/404.html
----------------------------------------------------------------------
diff --git a/content/404.html b/content/404.html
index b10abb3..1287c3e 100644
--- a/content/404.html
+++ b/content/404.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/Gemfile.lock
----------------------------------------------------------------------
diff --git a/content/Gemfile.lock b/content/Gemfile.lock
deleted file mode 100644
index d6a2b8b..0000000
--- a/content/Gemfile.lock
+++ /dev/null
@@ -1,209 +0,0 @@
-GEM
- remote: https://rubygems.org/
- specs:
- activesupport (4.2.7)
- i18n (~> 0.7)
- json (~> 1.7, >= 1.7.7)
- minitest (~> 5.1)
- thread_safe (~> 0.3, >= 0.3.4)
- tzinfo (~> 1.1)
- addressable (2.5.0)
- public_suffix (~> 2.0, >= 2.0.2)
- coffee-script (2.4.1)
- coffee-script-source
- execjs
- coffee-script-source (1.12.2)
- colorator (1.1.0)
- ethon (0.10.1)
- ffi (>= 1.3.0)
- execjs (2.7.0)
- faraday (0.10.0)
- multipart-post (>= 1.2, < 3)
- ffi (1.9.14)
- forwardable-extended (2.6.0)
- gemoji (2.1.0)
- github-pages (110)
- activesupport (= 4.2.7)
- github-pages-health-check (= 1.3.0)
- jekyll (= 3.3.1)
- jekyll-avatar (= 0.4.2)
- jekyll-coffeescript (= 1.0.1)
- jekyll-default-layout (= 0.1.4)
- jekyll-feed (= 0.8.0)
- jekyll-gist (= 1.4.0)
- jekyll-github-metadata (= 2.2.0)
- jekyll-mentions (= 1.2.0)
- jekyll-optional-front-matter (= 0.1.2)
- jekyll-paginate (= 1.1.0)
- jekyll-readme-index (= 0.0.3)
- jekyll-redirect-from (= 0.11.0)
- jekyll-relative-links (= 0.2.1)
- jekyll-sass-converter (= 1.3.0)
- jekyll-seo-tag (= 2.1.0)
- jekyll-sitemap (= 0.12.0)
- jekyll-swiss (= 0.4.0)
- jekyll-theme-architect (= 0.0.3)
- jekyll-theme-cayman (= 0.0.3)
- jekyll-theme-dinky (= 0.0.3)
- jekyll-theme-hacker (= 0.0.3)
- jekyll-theme-leap-day (= 0.0.3)
- jekyll-theme-merlot (= 0.0.3)
- jekyll-theme-midnight (= 0.0.3)
- jekyll-theme-minimal (= 0.0.3)
- jekyll-theme-modernist (= 0.0.3)
- jekyll-theme-primer (= 0.1.5)
- jekyll-theme-slate (= 0.0.3)
- jekyll-theme-tactile (= 0.0.3)
- jekyll-theme-time-machine (= 0.0.3)
- jekyll-titles-from-headings (= 0.1.2)
- jemoji (= 0.7.0)
- kramdown (= 1.11.1)
- liquid (= 3.0.6)
- listen (= 3.0.6)
- mercenary (~> 0.3)
- minima (= 2.0.0)
- rouge (= 1.11.1)
- terminal-table (~> 1.4)
- github-pages-health-check (1.3.0)
- addressable (~> 2.3)
- net-dns (~> 0.8)
- octokit (~> 4.0)
- public_suffix (~> 2.0)
- typhoeus (~> 0.7)
- html-pipeline (2.4.2)
- activesupport (>= 2)
- nokogiri (>= 1.4)
- i18n (0.7.0)
- jekyll (3.3.1)
- addressable (~> 2.4)
- colorator (~> 1.0)
- jekyll-sass-converter (~> 1.0)
- jekyll-watch (~> 1.1)
- kramdown (~> 1.3)
- liquid (~> 3.0)
- mercenary (~> 0.3.3)
- pathutil (~> 0.9)
- rouge (~> 1.7)
- safe_yaml (~> 1.0)
- jekyll-avatar (0.4.2)
- jekyll (~> 3.0)
- jekyll-coffeescript (1.0.1)
- coffee-script (~> 2.2)
- jekyll-default-layout (0.1.4)
- jekyll (~> 3.0)
- jekyll-feed (0.8.0)
- jekyll (~> 3.3)
- jekyll-gist (1.4.0)
- octokit (~> 4.2)
- jekyll-github-metadata (2.2.0)
- jekyll (~> 3.1)
- octokit (~> 4.0, != 4.4.0)
- jekyll-mentions (1.2.0)
- activesupport (~> 4.0)
- html-pipeline (~> 2.3)
- jekyll (~> 3.0)
- jekyll-optional-front-matter (0.1.2)
- jekyll (~> 3.0)
- jekyll-paginate (1.1.0)
- jekyll-readme-index (0.0.3)
- jekyll (~> 3.0)
- jekyll-redirect-from (0.11.0)
- jekyll (>= 2.0)
- jekyll-relative-links (0.2.1)
- jekyll (~> 3.3)
- jekyll-sass-converter (1.3.0)
- sass (~> 3.2)
- jekyll-seo-tag (2.1.0)
- jekyll (~> 3.3)
- jekyll-sitemap (0.12.0)
- jekyll (~> 3.3)
- jekyll-swiss (0.4.0)
- jekyll-theme-architect (0.0.3)
- jekyll (~> 3.3)
- jekyll-theme-cayman (0.0.3)
- jekyll (~> 3.3)
- jekyll-theme-dinky (0.0.3)
- jekyll (~> 3.3)
- jekyll-theme-hacker (0.0.3)
- jekyll (~> 3.3)
- jekyll-theme-leap-day (0.0.3)
- jekyll (~> 3.3)
- jekyll-theme-merlot (0.0.3)
- jekyll (~> 3.3)
- jekyll-theme-midnight (0.0.3)
- jekyll (~> 3.3)
- jekyll-theme-minimal (0.0.3)
- jekyll (~> 3.3)
- jekyll-theme-modernist (0.0.3)
- jekyll (~> 3.3)
- jekyll-theme-primer (0.1.5)
- jekyll (~> 3.3)
- jekyll-theme-slate (0.0.3)
- jekyll (~> 3.3)
- jekyll-theme-tactile (0.0.3)
- jekyll (~> 3.3)
- jekyll-theme-time-machine (0.0.3)
- jekyll (~> 3.3)
- jekyll-titles-from-headings (0.1.2)
- jekyll (~> 3.3)
- jekyll-watch (1.5.0)
- listen (~> 3.0, < 3.1)
- jemoji (0.7.0)
- activesupport (~> 4.0)
- gemoji (~> 2.0)
- html-pipeline (~> 2.2)
- jekyll (>= 3.0)
- json (1.8.3)
- kramdown (1.11.1)
- liquid (3.0.6)
- listen (3.0.6)
- rb-fsevent (>= 0.9.3)
- rb-inotify (>= 0.9.7)
- mercenary (0.3.6)
- mini_portile2 (2.1.0)
- minima (2.0.0)
- minitest (5.10.1)
- multipart-post (2.0.0)
- net-dns (0.8.0)
- nokogiri (1.6.8.1)
- mini_portile2 (~> 2.1.0)
- octokit (4.6.2)
- sawyer (~> 0.8.0, >= 0.5.3)
- pathutil (0.14.0)
- forwardable-extended (~> 2.6)
- posix-spawn (0.3.12)
- public_suffix (2.0.4)
- pygments.rb (1.0.0)
- posix-spawn (~> 0.3.6)
- yajl-ruby (~> 1.2)
- rb-fsevent (0.9.8)
- rb-inotify (0.9.7)
- ffi (>= 0.5.0)
- redcarpet (3.3.4)
- rouge (1.11.1)
- safe_yaml (1.0.4)
- sass (3.4.22)
- sawyer (0.8.1)
- addressable (>= 2.3.5, < 2.6)
- faraday (~> 0.8, < 1.0)
- terminal-table (1.7.3)
- unicode-display_width (~> 1.1.1)
- thread_safe (0.3.5)
- typhoeus (0.8.0)
- ethon (>= 0.8.0)
- tzinfo (1.2.2)
- thread_safe (~> 0.1)
- unicode-display_width (1.1.2)
- yajl-ruby (1.3.0)
-
-PLATFORMS
- ruby
-
-DEPENDENCIES
- github-pages
- jekyll
- pygments.rb
- redcarpet
-
-BUNDLED WITH
- 1.13.6
http://git-wip-us.apache.org/repos/asf/incubator-edgent-website/blob/399cc808/content/algolia_search.json
----------------------------------------------------------------------
diff --git a/content/algolia_search.json b/content/algolia_search.json
index 9b214a7..0578878 100644
--- a/content/algolia_search.json
+++ b/content/algolia_search.json
@@ -65,7 +65,7 @@
"keywords": "",
"url": "../docs/downloads",
"summary": "",
-"body": "Official Apache Edgent releases are available for download from the ASF distribution site. A release consists of a source code bundle and a convenience binary bundle. The Edgent ASF distribution site is [here]({{ site.data.downloads.edgent_dist_main_location }}). Information about verifying the integrity of the release bundles can also be found there.The Edgent source is also available from the Edgent ASF [git repository]({{ site.data.project.source_repository }}).If you just want to use Edgent, it is easiest to download and unpack a binary bundle. The bundle includes the release's javadoc. The javadoc is also accessible online. For more information, please refer to the [Getting started guide](edgent-getting-started)A source bundle contains a README describing how to build the sources.If you want access the latest unreleased Edgent source or to contribute to Edgent runtime development, using the [GitHub repository]({{ site.data.project.source_repository_mirror }}) is recom
mended. You can also select a particular release version by release tag (e.g., 1.0.0-incubating). See README.md and DEVELOPMENT.md in the repository for more information.See [here](community.html) for more information about contributing to Edgent development.## Apache Edgent (incubating) release history| Version | Date | Source | Release Notes | Docs | GPG | MD5 | SHA ||:-----------------:|:--------------:|:------:|:-------------:|:----:|:---:|:---:|:-----:|| 1.0.0-incubating | 2016-12-15 | [Download]({{ site.data.downloads.edgent_1-0-0_src_location }}) | [1.0.0 Release]({{ site.data.downloads.edgent_1-0-0_release_note }}) | [JavaDoc]({{ site.data.downloads.edgent_1-0-0_doc_location }}) | [ASC]({{ site.data.downloads.edgent_1-0-0_asc_location }}) | [MD5]({{ site.data.downloads.edgent_1-0-0_md5_location }}) | [SHA]({{ site.data.downloads.edgent_1-0-0_sha_location }}) |Download the [KEYS file]({{ site.data.downloads.edgent_keys_file_location }}) to verify
the Edgent artifact"
+"body": "Official Apache Edgent releases are available for download from the ASF distribution site. A release consists of a source code bundle and a convenience binary bundle. See the table below for a release's download links.If you just want to use Edgent, it is easiest to download and unpack a binary bundle. The bundle includes the release's javadoc. The javadoc is also accessible online. For more information, please refer to the [Getting started guide](edgent-getting-started)A source bundle contains a README describing how to build the sources.If you want to access the latest unreleased Edgent source or to contribute to the Edgent runtime development, use the [GitHub repository]({{ site.data.project.source_repository_mirror }}). You can also select a particular release version by release tag (e.g., 1.0.0-incubating). See README.md and DEVELOPMENT.md in the repository for more information.See [community](community.html) for more information about contributing to Edgent developme
nt.## Apache Edgent ReleasesInformation about verifying the integrity of a bundle can be found at the bottom of the bundle's download page.Download the [KEYS]({{ site.data.downloads.edgent_keys_file_location }}) file for verifying a bundle's PGP signature.| Version | Date | Bundles | Release Notes | Docs | PGP | MD5 | SHA ||:-----------------:|:--------------:|:-------:|:-------------:|:----:|:---:|:---:|:-----:|| 1.0.0-incubating | 2016-12-15 | [Source]({{ site.data.downloads.edgent_1-0-0_dist_location }}) | [1.0.0 Release]({{ site.data.downloads.edgent_1-0-0_release_note }}) | [JavaDoc]({{ site.data.downloads.edgent_1-0-0_doc_location }}) | [ASC]({{ site.data.downloads.edgent_1-0-0_asc_location }}) | [MD5]({{ site.data.downloads.edgent_1-0-0_md5_location }}) | [SHA]({{ site.data.downloads.edgent_1-0-0_sha_location }}) || | | [Binary]({{ site.data.downloads.edgent_1-0-0_bin_dist_location }}) | | | [ASC]({{ site.data.dow
nloads.edgent_1-0-0_bin_asc_location }}) | [MD5]({{ site.data.downloads.edgent_1-0-0_bin_md5_location }}) | [SHA]({{ site.data.downloads.edgent_1-0-0_bin_sha_location }}) |"
},
@@ -104,7 +104,7 @@
"keywords": "",
"url": "../docs/faq",
"summary": "",
-"body": "## What is Apache Edgent?Edgent provides APIs and a lightweight runtime to analyze streaming data at the edge.## What do you mean by the edge?The edge includes devices, gateways, equipment, vehicles, systems, appliances and sensors of all kinds as part of the Internet of Things.## How is Apache Edgent used?Edgent can be used at the edge of the Internet of Things, for example, to analyze data on devices, engines, connected cars, etc. Edgent could be on the device itself, or a gateway device collecting data from local devices. You can write an edge application on Edgent and connect it to a Cloud service, such as the IBM Watson IoT Platform. It can also be used for enterprise data collection and analysis; for example log collectors, application data, and data center analytics.## How are applications developed?Applications are developed using a functional flow API to define operations on data streams that are executed as a graph of \"oplets\" in a lightweight embeddable runtime
. The SDK provides capabilities like windowing, aggregation and connectors with an extensible model for the community to expand its capabilities.## What APIs does Apache Edgent support?Currently, Edgent supports APIs for Java and Android. Support for additional languages, such as Python, is likely as more developers get involved. Please consider joining the Edgent open source development community to accelerate the contributions of additional APIs.## What type of analytics can be done with Apache Edgent?Edgent provides windowing, aggregation and simple filtering. It uses Apache Common Math to provide simple analytics aimed at device sensors. Edgent is also extensible, so you can call existing libraries from within your Edgent application. In the future, Edgent will include more analytics, either exposing more functionality from Apache Common Math, other libraries or hand-coded analytics.## What connectors does Apache Edgent support?Edgent supports connectors for MQTT, HTTP, JDBC, Fi
le, Apache Kafka and IBM Watson IoT Platform. Edgent is extensible; you can add the connector of your choice.## What centralized streaming analytic systems does Apache Edgent support?Edgent supports open source technology (such as Apache Spark, Apache Storm, Flink and samza), IBM Streams (on-premises or IBM Streaming Analytics on Bluemix), or any custom application of your choice.## Why do I need Apache Edgent on the edge, rather than my streaming analytic system?Edgent is designed for the edge, rather than a more centralized system. It has a small footprint, suitable for running on devices. Edgent provides simple analytics, allowing a device to analyze data locally and to only send to the centralized system if there is a need, reducing communication costs.## Why do I need Apache Edgent, rather than coding the complete application myself?Edgent is a tool for edge analytics that allows you to be more productive. Edgent provides a consistent data model (streams and windows) and provid
es useful functionality, such as aggregations, joins, etc. Using Edgent lets you to take advantage of this functionality, allowing you to focus on your application needs.## Where can I download Apache Edgent to try it out?You can download Apache Edgent from [here]({{ site.data.project.download }}).## How do I get started?Getting started is simple. Once you have downloaded Edgent, everything you need to know to get up and running, you will find [here](edgent-getting-started). We suggest you also run the [Edgent sample programs](samples) to familiarize yourselves with the code base.## How can I get involved?We would love to have your help! Visit [Get Involved](community) to learn more about how to get involved.## How can I contribute code?Just submit a [pull request]({{ site.data.project.source_repository_mirror }}/pulls) and wait for a committer to review. For more information, visit our [committer page](committers) and read [DEVELOPMENT.md]({{ site.data.project.source_repository_mir
ror }}/blob/master/DEVELOPMENT.md) at the top of the code tree.## Can I become a committer?Read about Edgent committers and how to become a committer [here](committers).## Where can I get the code?The source code is available [here]({{ site.data.project.source_repository_mirror }}).## Can I take a copy of the code and fork it for my own use?Yes. Edgent is available under the Apache 2.0 license which allows you to fork the code. We hope you will contribute your changes back to the Edgent community.## How do I suggest new features?Click [Issues](https://issues.apache.org/jira/browse/{{ site.data.project.jira }}) to submit requests for new features. You may browse or query the Issues database to see what other members of the Edgent community have already requested.## How do I submit bug reports?Click [Issues](https://issues.apache.org/jira/browse/{{ site.data.project.jira }}) to submit a bug report.## How do I ask questions about Apache Edgent?Use the [dev list](mailto:{{ site.data.pro
ject.dev_list }}) to submit questions to the Edgent community.## Why is Apache Edgent open source?With the growth of the Internet of Things there is a need to execute analytics at the edge. Edgent was developed to address requirements for analytics at the edge for IoT use cases that were not addressed by central analytic solutions. These capabilities will be useful to many organizations and that the diverse nature of edge devices and use cases is best addressed by an open community. Our goal is to develop a vibrant community of developers and users to expand the capabilities and real-world use of Edgent by companies and individuals to enable edge analytics and further innovation for the IoT space.## I see references to \"Quarks.\" How does it relate to Apache Edgent?Up until July 2016, Edgent was known as Quarks. Quarks was renamed due to the name not being unique enough. The suitable name search for Edgent is currently in progress at The Apache Software Foundation."
+"body": "## What is Apache Edgent?Edgent provides APIs and a lightweight runtime to analyze streaming data at the edge.## What do you mean by the edge?The edge includes devices, gateways, equipment, vehicles, systems, appliances and sensors of all kinds as part of the Internet of Things.## How is Apache Edgent used?Edgent can be used at the edge of the Internet of Things, for example, to analyze data on devices, engines, connected cars, etc. Edgent could be on the device itself, or a gateway device collecting data from local devices. You can write an edge application on Edgent and connect it to a Cloud service, such as the IBM Watson IoT Platform. It can also be used for enterprise data collection and analysis; for example log collectors, application data, and data center analytics.## How are applications developed?Applications are developed using a functional flow API to define operations on data streams that are executed as a graph of \"oplets\" in a lightweight embeddable runtime
. The SDK provides capabilities like windowing, aggregation and connectors with an extensible model for the community to expand its capabilities.## What APIs does Apache Edgent support?Currently, Edgent supports APIs for Java and Android. Support for additional languages, such as Python, is likely as more developers get involved. Please consider joining the Edgent open source development community to accelerate the contributions of additional APIs.## What type of analytics can be done with Apache Edgent?Edgent provides windowing, aggregation and simple filtering. It uses Apache Common Math to provide simple analytics aimed at device sensors. Edgent is also extensible, so you can call existing libraries from within your Edgent application. In the future, Edgent will include more analytics, either exposing more functionality from Apache Common Math, other libraries or hand-coded analytics.## What connectors does Apache Edgent support?Edgent supports connectors for MQTT, HTTP, JDBC, Fi
le, Apache Kafka and IBM Watson IoT Platform. Edgent is extensible; you can add the connector of your choice.## What centralized streaming analytic systems does Apache Edgent support?Edgent supports open source technology (such as Apache Spark, Apache Storm, Flink and samza), IBM Streams (on-premises or IBM Streaming Analytics on Bluemix), or any custom application of your choice.## Why do I need Apache Edgent on the edge, rather than my streaming analytic system?Edgent is designed for the edge, rather than a more centralized system. It has a small footprint, suitable for running on devices. Edgent provides simple analytics, allowing a device to analyze data locally and to only send to the centralized system if there is a need, reducing communication costs.## Why do I need Apache Edgent, rather than coding the complete application myself?Edgent is a tool for edge analytics that allows you to be more productive. Edgent provides a consistent data model (streams and windows) and provid
es useful functionality, such as aggregations, joins, etc. Using Edgent lets you to take advantage of this functionality, allowing you to focus on your application needs.## Where can I download Apache Edgent?Releases include source code and convenience binary bundles. The source code is also available on GitHub. The [downloads]({{ site.data.project.download }}) page has all of the details.## How do I get started?Getting started is simple. Once you have downloaded Edgent, everything you need to know to get up and running, you will find [here](edgent-getting-started). We suggest you also run the [Edgent sample programs](samples) to familiarize yourselves with the code base.## How can I get involved?We would love to have your help! Visit [Get Involved](community) to learn more about how to get involved.## How can I contribute code?Just submit a [pull request]({{ site.data.project.source_repository_mirror }}/pulls) and wait for a committer to review. For more information, visit our [c
ommitter page](committers) and read [DEVELOPMENT.md]({{ site.data.project.source_repository_mirror }}/blob/master/DEVELOPMENT.md) at the top of the code tree.## Can I become a committer?Read about Edgent committers and how to become a committer [here](committers).## Can I take a copy of the code and fork it for my own use?Yes. Edgent is available under the Apache 2.0 license which allows you to fork the code. We hope you will contribute your changes back to the Edgent community.## How do I suggest new features?Click [Issues](https://issues.apache.org/jira/browse/{{ site.data.project.jira }}) to submit requests for new features. You may browse or query the Issues database to see what other members of the Edgent community have already requested.## How do I submit bug reports?Click [Issues](https://issues.apache.org/jira/browse/{{ site.data.project.jira }}) to submit a bug report.## How do I ask questions about Apache Edgent?Use the [dev list](mailto:{{ site.data.project.dev_list }}) t
o submit questions to the Edgent community.## Why is Apache Edgent open source?With the growth of the Internet of Things there is a need to execute analytics at the edge. Edgent was developed to address requirements for analytics at the edge for IoT use cases that were not addressed by central analytic solutions. These capabilities will be useful to many organizations and that the diverse nature of edge devices and use cases is best addressed by an open community. Our goal is to develop a vibrant community of developers and users to expand the capabilities and real-world use of Edgent by companies and individuals to enable edge analytics and further innovation for the IoT space.## I see references to \"Quarks.\" How does it relate to Apache Edgent?Up until July 2016, Edgent was known as Quarks. Quarks was renamed due to the name not being unique enough."
},
@@ -302,7 +302,7 @@
"keywords": "",
"url": "../recipes/recipe_source_function",
"summary": "",
-"body": "In the previous [Hello Edgent!](recipe_hello_edgent) example, we create a data source which generates two Java `String`s and prints them to output. Yet Edgent sources support the ability generate any data type as a source, not just Java types such as `String`s and `Double`s. Moreover, because the user supplies the code which generates the data, the user has complete flexibility for *how* the data is generated. This recipe demonstrates how a user could write such a custom data source.## Custom source: reading the lines of a web page{{site.data.alerts.note}} 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. {{site.data.alerts.end}}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 dat
a of Bank of America, Cabot Oil & Gas, and Freeport-McMoRan Inc.:``` javapublic static void main(String[] args) throws Exception { DirectProvider dp = new DirectProvider(); Topology top = dp.newTopology(); final URL url = new URL(\"http://finance.yahoo.com/d/quotes.csv?s=BAC+COG+FCX&f=snabl\");}```Given the correctly formatted URL to request the data, we can use the *`Topology.source()`* method to generate each line of the page as a data item on the stream. `Topology.source()` takes a Java `Supplier` that returns an `Iterable`. The supplier is invoked once, and the items returned from the Iterable are used as the stream's data items. For example, the following `queryWebsite` method returns a supplier which queries a URL and returns an `Iterable` of its contents:``` javaprivate static Supplier > queryWebsite(URL url) throws Exception{ return () -> { List lines = new LinkedList(); try { InputStream is = url.openStream(); BufferedReader b
r = new BufferedReader( new InputStreamReader(is)); for(String s = br.readLine(); s != null; s = br.readLine()) lines.add(s); } catch (Exception e) { e.printStackTrace(); } return lines; };}```When invoking `Topology.source()`, we can use `queryWebsite` to return the required supplier, passing in the URL.```javapublic static void main(String[] args) throws Exception { DirectProvider dp = new DirectProvider(); Topology top = dp.newTopology(); final URL url = new URL(\"http://finance.yahoo.com/d/quotes.csv?s=BAC+COG+FCX&f=snabl\"); TStream linesOfWebsite = top.source(queryWebsite(url));}```Source methods such as `Topology.source()` and `Topology.strings()` return a `TStream`. If we print the `linesOfWebsite` stream to standard output and run the application, we can see that it correctly generates the data and feeds it into the Edgent runtime:**Output**:```java\"BAC\",\"Bank of America Corporati
on Com\",13.150,13.140,\"12:00pm - 13.145\"\"COG\",\"Cabot Oil & Gas Corporation Com\",21.6800,21.6700,\"12:00pm - 21.6775\"\"FCX\",\"Freeport-McMoRan, Inc. Common S\",8.8200,8.8100,\"12:00pm - 8.8035\"```## Polling source: reading data periodicallyA 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, `Topology` exposes the `poll()` 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:```javapublic static void main(String[] args) throws Exception { DirectProvider dp = new DirectProvider(); Topology top = dp.newTopology(); final URL url = new URL(\"http://finance.yahoo.com/d/quotes.csv?s=BAC+COG+FCX&f=snabl\"); TStream> source = top.poll(queryWebsite(url), 2, TimeUni
t.SECONDS); source.print(); dp.submit(top);}```**Output**:It's important to note that calls to `DirectProvider.submit()` are non-blocking; the main thread will exit, and the threads executing the topology will continue to run. (Also, to see changing stock prices, the above example needs to be run during open trading hours. Otherwise, it will simply return the same results every time the website is polled)."
+"body": "In the previous [Hello Edgent!](recipe_hello_edgent) example, we create a data source which generates two Java `String`s and prints them to output. Yet Edgent sources support the ability generate any data type as a source, not just Java types such as `String`s and `Double`s. Moreover, because the user supplies the code which generates the data, the user has complete flexibility for *how* the data is generated. This recipe demonstrates how a user could write such a custom data source.## Custom source: reading the lines of a web page{{site.data.alerts.note}} 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. {{site.data.alerts.end}}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 dat
a of Bank of America, Cabot Oil & Gas, and Freeport-McMoRan Inc.:``` javapublic static void main(String[] args) throws Exception { DirectProvider dp = new DirectProvider(); Topology top = dp.newTopology(); final URL url = new URL(\"http://finance.yahoo.com/d/quotes.csv?s=BAC+COG+FCX&f=snabl\");}```Given the correctly formatted URL to request the data, we can use the *`Topology.source()`* method to generate each line of the page as a data item on the stream. `Topology.source()` takes a Java `Supplier` that returns an `Iterable`. The supplier is invoked once, and the items returned from the Iterable are used as the stream's data items. For example, the following `queryWebsite` method returns a supplier which queries a URL and returns an `Iterable` of its contents:``` javaprivate static Supplier > queryWebsite(URL url) throws Exception{ return () -> { List lines = new LinkedList(); try { InputStream is = url.openStream(); BufferedReader b
r = new BufferedReader( new InputStreamReader(is)); for(String s = br.readLine(); s != null; s = br.readLine()) lines.add(s); } catch (Exception e) { e.printStackTrace(); } return lines; };}```When invoking `Topology.source()`, we can use `queryWebsite` to return the required supplier, passing in the URL.```javapublic static void main(String[] args) throws Exception { DirectProvider dp = new DirectProvider(); Topology top = dp.newTopology(); final URL url = new URL(\"http://finance.yahoo.com/d/quotes.csv?s=BAC+COG+FCX&f=snabl\"); TStream linesOfWebsite = top.source(queryWebsite(url)); dp.submit(top);}```Source methods such as `Topology.source()` and `Topology.strings()` return a `TStream`. If we print the `linesOfWebsite` stream to standard output and run the application, we can see that it correctly generates the data and feeds it into the Edgent runtime:**Output**:```java\"BAC\",\"Bank o
f America Corporation Com\",13.150,13.140,\"12:00pm - 13.145\"\"COG\",\"Cabot Oil & Gas Corporation Com\",21.6800,21.6700,\"12:00pm - 21.6775\"\"FCX\",\"Freeport-McMoRan, Inc. Common S\",8.8200,8.8100,\"12:00pm - 8.8035\"```## Polling source: reading data periodicallyA 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, `Topology` exposes the `poll()` 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:```javapublic static void main(String[] args) throws Exception { DirectProvider dp = new DirectProvider(); Topology top = dp.newTopology(); final URL url = new URL(\"http://finance.yahoo.com/d/quotes.csv?s=BAC+COG+FCX&f=snabl\"); TStream> source = top.poll(queryWebsi
te(url), 2, TimeUnit.SECONDS); source.print(); dp.submit(top);}```**Output**:It's important to note that calls to `DirectProvider.submit()` are non-blocking; the main thread will exit, and the threads executing the topology will continue to run. (Also, to see changing stock prices, the above example needs to be run during open trading hours. Otherwise, it will simply return the same results every time the website is polled)."
},
http://git-wip-us.apache.org/repos/asf/incubator-edgent-website/blob/399cc808/content/doap_Edgent.rdf
----------------------------------------------------------------------
diff --git a/content/doap_Edgent.rdf b/content/doap_Edgent.rdf
index c7f833b..09d31c8 100644
--- a/content/doap_Edgent.rdf
+++ b/content/doap_Edgent.rdf
@@ -27,7 +27,7 @@
<name>Apache Edgent</name>
<homepage rdf:resource="http://edgent.incubator.apache.org/" />
<asfext:pmc rdf:resource="http://incubator.apache.org" />
- <shortdesc>Edgent is a stream processing programming model and lightweight runtime to execute analytics at devices on the edge or at the gateway.</shortdesc>
+ <shortdesc>Apache Edgent is a stream processing programming model and lightweight micro-kernel style runtime to execute analytics at devices on the edge or at the gateway.</shortdesc>
<description>Apache Edgent is a programming model and micro-kernel style runtime that can be embedded in gateways and small footprint edge devices enabling local, real-time, analytics on the continuous streams of data coming from equipment, vehicles, systems, appliances, devices and sensors of all kinds (for example, Raspberry Pis or smart phones). Working in conjunction with centralized analytic systems, Apache Edgent provides efficient and timely analytics across the whole IoT ecosystem: from the center to the edge.</description>
<bug-database rdf:resource="https://issues.apache.org/jira/browse/EDGENT" />
<mailing-list rdf:resource="http://edgent.incubator.apache.org/docs/community#mailing-list" />
@@ -50,4 +50,4 @@
</foaf:Person>
</maintainer>
</Project>
-</rdf:RDF>
\ No newline at end of file
+</rdf:RDF>
http://git-wip-us.apache.org/repos/asf/incubator-edgent-website/blob/399cc808/content/docs/committers.html
----------------------------------------------------------------------
diff --git a/content/docs/committers.html b/content/docs/committers.html
index b9495e7..065a8b5 100644
--- a/content/docs/committers.html
+++ b/content/docs/committers.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/docs/common-edgent-operations.html
----------------------------------------------------------------------
diff --git a/content/docs/common-edgent-operations.html b/content/docs/common-edgent-operations.html
index 2345287..8d20808 100644
--- a/content/docs/common-edgent-operations.html
+++ b/content/docs/common-edgent-operations.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>
@@ -680,7 +686,7 @@ $('#toc').on('click', 'a', function() {
<span class="n">TStream</span><span class="o"><</span><span class="n">Integer</span><span class="o">></span> <span class="n">counts</span> <span class="o">=</span> <span class="n">streamOfStrings</span><span class="o">.</span><span class="na">map</span><span class="o">(</span><span class="k">new</span> <span class="n">Function</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="o">{</span>
<span class="kt">int</span> <span class="n">count</span> <span class="o">=</span> <span class="mi">0</span><span class="o">;</span>
<span class="nd">@Override</span>
- <span class="kd">public</span> <span class="n">Integer</span> <span class="nf">apply</span><span class="o">(</span><span class="n">String</span> <span class="n">arg0</span><span class="o">)</span> <span class="o">{</span>
+ <span class="kd">public</span> <span class="n">Integer</span> <span class="n">apply</span><span class="o">(</span><span class="n">String</span> <span class="n">arg0</span><span class="o">)</span> <span class="o">{</span>
<span class="n">count</span> <span class="o">=</span> <span class="n">count</span> <span class="o">+</span> <span class="mi">1</span><span class="o">;</span>
<span class="k">return</span> <span class="n">count</span><span class="o">;</span>
<span class="o">}</span>
http://git-wip-us.apache.org/repos/asf/incubator-edgent-website/blob/399cc808/content/docs/community.html
----------------------------------------------------------------------
diff --git a/content/docs/community.html b/content/docs/community.html
index d56e1b2..c5a521a 100644
--- a/content/docs/community.html
+++ b/content/docs/community.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/docs/console.html
----------------------------------------------------------------------
diff --git a/content/docs/console.html b/content/docs/console.html
index 4633f36..d8d3808 100644
--- a/content/docs/console.html
+++ b/content/docs/console.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>
@@ -658,7 +664,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">TempSensorApplication</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">TempSensor</span> <span class="n">sensor</span> <span class="o">=</span> <span class="k">new</span> <span class="n">TempSensor</span><span class="o">();</span>
<span class="n">DevelopmentProvider</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">Topology</span> <span class="n">topology</span> <span class="o">=</span> <span class="n">dp</span><span class="o">.</span><span class="na">newTopology</span><span class="o">();</span>
@@ -793,7 +799,7 @@ Well3 alert, ecoli value is 1
<li>Each well that is to be measured is added to the topology. The topology polls each sensor (temp, ecoli, etc.) for each well as a unit. A <code>TStream<Integer></code> is returned from polling the toplogy and represents a sensor reading. Each sensor reading for the well has a tag added to it with the reading type i.e, "temp", and the well id. Once all of the sensor readings are obtained and the tags added, each sensor reading is 'unioned' into a single <code>TStream<JsonObject></code>. Look at the <code>waterDetector</code> method for details on this.</li>
<li>Now, each well has a single stream with each of the sensors readings as a property with a name and value in the <code>TStream<JsonObject></code>. Next the <code>alertFilter</code> method is called on the <code>TStream<JsonObject></code> representing each well. This method checks the values for each well's sensors to determine if they are 'out of range' for healthy values. The <code>filter</code> oplet is used to do this. If any of the sensor's readings are out of the acceptable range the tuple is passed along. Those that are within an acceptable range are discarded.</li>
<li><p>Next the applications' <code>splitAlert</code> method is called on each well's stream that contains the union of all the sensor readings that are out of range. The <code>splitAlert</code> method uses the <code>split</code> oplet to split the incoming stream into 5 different streams. Only those tuples that are out of range for each stream, which represents each sensor type, will be returned. The object returned from <code>splitAlert</code> is a list of <code>TStream<JsonObject></code> objects. The <code>splitAlert</code> method is shown below:</p>
-<div class="highlight"><pre><code class="language-java" data-lang="java"><span class="kd">public</span> <span class="kd">static</span> <span class="n">List</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="nf">splitAlert</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">alertStream</span><span class="o">,</span> <span class="kt">int</span> <span class="n">wellId</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="n">List</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">splitAlert</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">alertStream</span><span class="o">,</span> <span class="kt">int</span> <span class="n">wellId</span><span class="o">)</span> <span class="o">{</span>
<span class="n">List</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">allStreams</span> <span class="o">=</span> <span class="n">alertStream</span><span class="o">.</span><span class="na">split</span><span class="o">(</span><span class="mi">5</span><span class="o">,</span> <span class="n">tuple</span> <span class="o">-></span> <span class="o">{</span>
<span class="k">if</span> <span class="o">(</span><span class="n">tuple</span><span class="o">.</span><span class="na">get</span><span class="o">(</span><span class="s">"temp"</span><span class="o">)</span> <span class="o">!=</span> <span class="kc">null</span><span class="o">)</span> <span class="o">{</span>
<span class="n">JsonObject</span> <span class="n">tempObj</span> <span class="o">=</span> <span class="k">new</span> <span class="n">JsonObject</span><span class="o">();</span>
@@ -958,7 +964,7 @@ Counter Op:TupleCounter.edgent.oplet.JOB_0.OP_98 has a tuple count of zero!
<p><img src='images/console_hover_over_link.jpg'/></p>
<p>The section of the code that adds the tags 'temperature' and 'well1' is in the <code>waterDetector</code> method of the <code>ConsoleWaterDetector</code> class.</p>
-<div class="highlight"><pre><code class="language-java" data-lang="java"><span class="kd">public</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">waterDetector</span><span class="o">(</span><span class="n">Topology</span> <span class="n">topology</span><span class="o">,</span> <span class="kt">int</span> <span class="n">wellId</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="n">TStream</span><span class="o"><</span><span class="n">JsonObject</span><span class="o">></span> <span class="n">waterDetector</span><span class="o">(</span><span class="n">Topology</span> <span class="n">topology</span><span class="o">,</span> <span class="kt">int</span> <span class="n">wellId</span><span class="o">)</span> <span class="o">{</span>
<span class="n">Random</span> <span class="n">rNum</span> <span class="o">=</span> <span class="k">new</span> <span class="n">Random</span><span class="o">();</span>
<span class="n">TStream</span><span class="o"><</span><span class="n">Integer</span><span class="o">></span> <span class="n">temp</span> <span class="o">=</span> <span class="n">topology</span><span class="o">.</span><span class="na">poll</span><span class="o">(()</span> <span class="o">-></span> <span class="n">rNum</span><span class="o">.</span><span class="na">nextInt</span><span class="o">(</span><span class="n">TEMP_RANDOM_HIGH</span> <span class="o">-</span> <span class="n">TEMP_RANDOM_LOW</span><span class="o">)</span> <span class="o">+</span> <span class="n">TEMP_RANDOM_LOW</span><span class="o">,</span> <span class="mi">1</span><span class="o">,</span> <span class="n">TimeUnit</span><span class="o">.</span><span class="na">SECONDS</span><span class="o">);</span>
<span class="n">TStream</span><span class="o"><</span><span class="n">Integer</span><span class="o">></span> <span class="n">acidity</span> <span class="o">=</span> <span class="n">topology</span><span class="o">.</span><span class="na">poll</span><span class="o">(()</span> <span class="o">-></span> <span class="n">rNum</span><span class="o">.</span><span class="na">nextInt</span><span class="o">(</span><span class="n">ACIDITY_RANDOM_HIGH</span> <span class="o">-</span> <span class="n">ACIDITY_RANDOM_LOW</span><span class="o">)</span> <span class="o">+</span> <span class="n">ACIDITY_RANDOM_LOW</span><span class="o">,</span> <span class="mi">1</span><span class="o">,</span> <span class="n">TimeUnit</span><span class="o">.</span><span class="na">SECONDS</span><span class="o">);</span>
@@ -1021,7 +1027,7 @@ Counter Op:TupleCounter.edgent.oplet.JOB_0.OP_98 has a tuple count of zero!
<h2 id="counters">Counters</h2>
-<p>In the <code>ConsoleWaterDetector</code> application we used a <code>DevelopmentProvider</code>. Therefore, counters were added to most streams (edges) with the following exceptions (from the <a href="http://edgent.incubator.apache.org/javadoc/latest/org/apache/edgent/metrics/Metrics.html#counter-org.apache.edgent.topology.TStream-">Javadoc</a> for <code>edgent.metrics.Metrics</code>):</p>
+<p>In the <code>ConsoleWaterDetector</code> application we used a <code>DevelopmentProvider</code>. Therefore, counters were added to most streams (edges) with the following exceptions (from the <a href="https://edgent.incubator.apache.org/javadoc/latest/org/apache/edgent/metrics/Metrics.html#counter-org.apache.edgent.topology.TStream-">Javadoc</a> for <code>edgent.metrics.Metrics</code>):</p>
<p><em>Oplets are only inserted upstream from a FanOut oplet.</em></p>
http://git-wip-us.apache.org/repos/asf/incubator-edgent-website/blob/399cc808/content/docs/downloads.html
----------------------------------------------------------------------
diff --git a/content/docs/downloads.html b/content/docs/downloads.html
index 3ece134..0e5e995 100644
--- a/content/docs/downloads.html
+++ b/content/docs/downloads.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,28 +647,30 @@ $('#toc').on('click', 'a', function() {
<a target="_blank" href="https://github.com/apache/incubator-edgent-website/blob/master/site/docs/downloads.md" class="btn btn-default githubEditButton" role="button"><i class="fa fa-github fa-lg"></i> Edit me</a>
- <p>Official Apache Edgent releases are available for download from the ASF distribution site. A release consists of a source code bundle and a convenience binary bundle. The Edgent ASF distribution site is <a href="http://www.apache.org/dyn/closer.cgi/incubator/edgent">here</a>. Information about verifying the integrity of the release bundles can also be found there.</p>
-
-<p>The Edgent source is also available from the Edgent ASF <a href="https://git-wip-us.apache.org/repos/asf/incubator-edgent.git">git repository</a>.</p>
+ <p>Official Apache Edgent releases are available for download from the ASF distribution site. A release consists of a source code bundle and a convenience binary bundle. See the table below for a release's download links.</p>
<p>If you just want to use Edgent, it is easiest to download and unpack a binary bundle. The bundle includes the release's javadoc. The javadoc is also accessible online. For more information, please refer to the <a href="edgent-getting-started">Getting started guide</a></p>
<p>A source bundle contains a README describing how to build the sources.</p>
-<p>If you want access the latest unreleased Edgent source or to contribute to Edgent runtime development, using the <a href="https://github.com/apache/incubator-edgent">GitHub repository</a> is recommended. You can also select a particular release version by release tag (e.g., 1.0.0-incubating). See README.md and DEVELOPMENT.md in the repository for more information.</p>
+<p>If you want to access the latest unreleased Edgent source or to contribute to the Edgent runtime development, use the <a href="https://github.com/apache/incubator-edgent">GitHub repository</a>. You can also select a particular release version by release tag (e.g., 1.0.0-incubating). See README.md and DEVELOPMENT.md in the repository for more information.</p>
-<p>See <a href="community.html">here</a> for more information about contributing to Edgent development.</p>
+<p>See <a href="community.html">community</a> for more information about contributing to Edgent development.</p>
-<h2 id="apache-edgent-incubating-release-history">Apache Edgent (incubating) release history</h2>
+<h2 id="apache-edgent-releases">Apache Edgent Releases</h2>
+
+<p>Information about verifying the integrity of a bundle can be found at the bottom of the bundle's download page.</p>
+
+<p>Download the <a href="https://www.apache.org/dist/incubator/edgent/KEYS">KEYS</a> file for verifying a bundle's PGP signature.</p>
<table><thead>
<tr>
<th style="text-align: center">Version</th>
<th style="text-align: center">Date</th>
-<th style="text-align: center">Source</th>
+<th style="text-align: center">Bundles</th>
<th style="text-align: center">Release Notes</th>
<th style="text-align: center">Docs</th>
-<th style="text-align: center">GPG</th>
+<th style="text-align: center">PGP</th>
<th style="text-align: center">MD5</th>
<th style="text-align: center">SHA</th>
</tr>
@@ -670,17 +678,25 @@ $('#toc').on('click', 'a', function() {
<tr>
<td style="text-align: center">1.0.0-incubating</td>
<td style="text-align: center">2016-12-15</td>
-<td style="text-align: center"><a href="http://www.apache.org/dyn/closer.cgi/incubator/edgent/1.0.0-incubating">Download</a></td>
+<td style="text-align: center"><a href="https://www.apache.org/dyn/closer.cgi/incubator/edgent/1.0.0-incubating">Source</a></td>
<td style="text-align: center"><a href="https://github.com/apache/incubator-edgent/blob/1.0.0-incubating/RELEASE_NOTES">1.0.0 Release</a></td>
-<td style="text-align: center"><a href="http://edgent.incubator.apache.org/javadoc/r1.0.0/index.html">JavaDoc</a></td>
+<td style="text-align: center"><a href="https://edgent.incubator.apache.org/javadoc/r1.0.0/index.html">JavaDoc</a></td>
<td style="text-align: center"><a href="https://www.apache.org/dist/incubator/edgent/1.0.0-incubating/apache-edgent-1.0.0-incubating-src.tgz.asc">ASC</a></td>
<td style="text-align: center"><a href="https://www.apache.org/dist/incubator/edgent/1.0.0-incubating/apache-edgent-1.0.0-incubating-src.tgz.md5">MD5</a></td>
<td style="text-align: center"><a href="https://www.apache.org/dist/incubator/edgent/1.0.0-incubating/apache-edgent-1.0.0-incubating-src.tgz.sha">SHA</a></td>
</tr>
+<tr>
+<td style="text-align: center"></td>
+<td style="text-align: center"></td>
+<td style="text-align: center"><a href="https://www.apache.org/dyn/closer.cgi/incubator/edgent/1.0.0-incubating/binaries">Binary</a></td>
+<td style="text-align: center"></td>
+<td style="text-align: center"></td>
+<td style="text-align: center"><a href="https://www.apache.org/dist/incubator/edgent/1.0.0-incubating/binaries/apache-edgent-1.0.0-incubating-bin.tgz.asc">ASC</a></td>
+<td style="text-align: center"><a href="https://www.apache.org/dist/incubator/edgent/1.0.0-incubating/binaries/apache-edgent-1.0.0-incubating-bin.tgz.md5">MD5</a></td>
+<td style="text-align: center"><a href="https://www.apache.org/dist/incubator/edgent/1.0.0-incubating/binaries/apache-edgent-1.0.0-incubating-bin.tgz.sha">SHA</a></td>
+</tr>
</tbody></table>
-<p>Download the <a href="https://www.apache.org/dist/incubator/edgent/KEYS">KEYS file</a> to verify the Edgent artifact</p>
-
<div class="tags">
http://git-wip-us.apache.org/repos/asf/incubator-edgent-website/blob/399cc808/content/docs/edgent-getting-started.html
----------------------------------------------------------------------
diff --git a/content/docs/edgent-getting-started.html b/content/docs/edgent-getting-started.html
index 9b8fa1a..95ce634 100644
--- a/content/docs/edgent-getting-started.html
+++ b/content/docs/edgent-getting-started.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>
@@ -710,7 +716,7 @@ $('#toc').on('click', 'a', function() {
<span class="o">}</span>
<span class="nd">@Override</span>
- <span class="kd">public</span> <span class="n">Double</span> <span class="nf">get</span><span class="o">()</span> <span class="o">{</span>
+ <span class="kd">public</span> <span class="n">Double</span> <span class="n">get</span><span class="o">()</span> <span class="o">{</span>
<span class="c1">// Change the current temperature some random amount</span>
<span class="kt">double</span> <span class="n">newTemp</span> <span class="o">=</span> <span class="n">rand</span><span class="o">.</span><span class="na">nextGaussian</span><span class="o">()</span> <span class="o">+</span> <span class="n">currentTemp</span><span class="o">;</span>
<span class="n">currentTemp</span> <span class="o">=</span> <span class="n">newTemp</span><span class="o">;</span>
@@ -728,7 +734,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">TempSensorApplication</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">TempSensor</span> <span class="n">sensor</span> <span class="o">=</span> <span class="k">new</span> <span class="n">TempSensor</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">topology</span> <span class="o">=</span> <span class="n">dp</span><span class="o">.</span><span class="na">newTopology</span><span class="o">();</span>
@@ -744,14 +750,14 @@ $('#toc').on('click', 'a', function() {
<h3 id="specifying-a-provider">Specifying a provider</h3>
-<p>Your first step when you write an Edgent application is to create a <a href="http://edgent.incubator.apache.org/javadoc/latest/index.html?org/apache/edgent/providers/direct/DirectProvider.html"><code>DirectProvider</code></a>:</p>
+<p>Your first step when you write an Edgent application is to create a <a href="https://edgent.incubator.apache.org/javadoc/latest/index.html?org/apache/edgent/providers/direct/DirectProvider.html"><code>DirectProvider</code></a>:</p>
<div class="highlight"><pre><code class="language-java" data-lang="java"><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>
</code></pre></div>
<p>A <code>Provider</code> is an object that contains information on how and where your Edgent application will run. A <code>DirectProvider</code> is a type of Provider that runs your application directly within the current virtual machine when its <code>submit()</code> method is called.</p>
<h3 id="creating-a-topology">Creating a topology</h3>
-<p>Additionally a Provider is used to create a <a href="http://edgent.incubator.apache.org/javadoc/latest/index.html?org/apache/edgent/topology/Topology.html"><code>Topology</code></a> instance:</p>
+<p>Additionally a Provider is used to create a <a href="https://edgent.incubator.apache.org/javadoc/latest/index.html?org/apache/edgent/topology/Topology.html"><code>Topology</code></a> instance:</p>
<div class="highlight"><pre><code class="language-java" data-lang="java"><span class="n">Topology</span> <span class="n">topology</span> <span class="o">=</span> <span class="n">dp</span><span class="o">.</span><span class="na">newTopology</span><span class="o">();</span>
</code></pre></div>
<p>In Edgent, <code>Topology</code> is a container that describes the structure of your application:</p>
http://git-wip-us.apache.org/repos/asf/incubator-edgent-website/blob/399cc808/content/docs/edgent_index.html
----------------------------------------------------------------------
diff --git a/content/docs/edgent_index.html b/content/docs/edgent_index.html
index 65b078d..a2edf33 100644
--- a/content/docs/edgent_index.html
+++ b/content/docs/edgent_index.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/docs/faq.html
----------------------------------------------------------------------
diff --git a/content/docs/faq.html b/content/docs/faq.html
index 0bdb9e7..5f37cea 100644
--- a/content/docs/faq.html
+++ b/content/docs/faq.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>
@@ -681,9 +687,9 @@ $('#toc').on('click', 'a', function() {
<p>Edgent is a tool for edge analytics that allows you to be more productive. Edgent provides a consistent data model (streams and windows) and provides useful functionality, such as aggregations, joins, etc. Using Edgent lets you to take advantage of this functionality, allowing you to focus on your application needs.</p>
-<h2 id="where-can-i-download-apache-edgent-to-try-it-out">Where can I download Apache Edgent to try it out?</h2>
+<h2 id="where-can-i-download-apache-edgent">Where can I download Apache Edgent?</h2>
-<p>You can download Apache Edgent from <a href="downloads">here</a>.</p>
+<p>Releases include source code and convenience binary bundles. The source code is also available on GitHub. The <a href="downloads">downloads</a> page has all of the details.</p>
<h2 id="how-do-i-get-started">How do I get started?</h2>
@@ -701,10 +707,6 @@ $('#toc').on('click', 'a', function() {
<p>Read about Edgent committers and how to become a committer <a href="committers">here</a>.</p>
-<h2 id="where-can-i-get-the-code">Where can I get the code?</h2>
-
-<p>The source code is available <a href="https://github.com/apache/incubator-edgent">here</a>.</p>
-
<h2 id="can-i-take-a-copy-of-the-code-and-fork-it-for-my-own-use">Can I take a copy of the code and fork it for my own use?</h2>
<p>Yes. Edgent is available under the Apache 2.0 license which allows you to fork the code. We hope you will contribute your changes back to the Edgent community.</p>
@@ -727,7 +729,7 @@ $('#toc').on('click', 'a', function() {
<h2 id="i-see-references-to-quot-quarks-quot-how-does-it-relate-to-apache-edgent">I see references to "Quarks." How does it relate to Apache Edgent?</h2>
-<p>Up until July 2016, Edgent was known as Quarks. Quarks was renamed due to the name not being unique enough. The suitable name search for Edgent is currently in progress at The Apache Software Foundation.</p>
+<p>Up until July 2016, Edgent was known as Quarks. Quarks was renamed due to the name not being unique enough.</p>
<div class="tags">
http://git-wip-us.apache.org/repos/asf/incubator-edgent-website/blob/399cc808/content/docs/home.html
----------------------------------------------------------------------
diff --git a/content/docs/home.html b/content/docs/home.html
index f9ade77..4035759 100644
--- a/content/docs/home.html
+++ b/content/docs/home.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/docs/overview.html
----------------------------------------------------------------------
diff --git a/content/docs/overview.html b/content/docs/overview.html
index 088bc61..eb15604 100644
--- a/content/docs/overview.html
+++ b/content/docs/overview.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/docs/quickstart.html
----------------------------------------------------------------------
diff --git a/content/docs/quickstart.html b/content/docs/quickstart.html
index 82f8c9c..0ad8b2a 100644
--- a/content/docs/quickstart.html
+++ b/content/docs/quickstart.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>
@@ -646,9 +652,9 @@ $('#toc').on('click', 'a', function() {
<p>IoT devices running Edgent applications typically connect to back-end analytic systems through a message hub. Message hubs are used to isolate the back-end system from having to handle connections from thousands to millions of devices.</p>
<p>An example of such a message hub designed for the Internet of Things is <a href="https://internetofthings.ibmcloud.com/">IBM Watson IoT Platform</a>. This cloud service runs on IBM's Bluemix cloud platform
-and Edgent provides a <a href="http://edgent.incubator.apache.org/javadoc/latest/index.html?org/apache/edgent/connectors/iotp/IotpDevice.html">connector</a>.</p>
+and Edgent provides a <a href="https://edgent.incubator.apache.org/javadoc/latest/index.html?org/apache/edgent/connectors/iotp/IotpDevice.html">connector</a>.</p>
-<p>You can test out the service without any registration by using its Quickstart service and the Edgent sample application: <a href="https://github.com/apache/incubator-edgent/blob/master/samples/connectors/src/main/java/org/apache/edgent/samples/connectors/iotp/IotpQuickstart.java">code</a>, <a href="http://edgent.incubator.apache.org/javadoc/latest/index.html?org/apache/edgent/samples/connectors/iotp/IotpQuickstart.html">Javadoc</a>.</p>
+<p>You can test out the service without any registration by using its Quickstart service and the Edgent sample application: <a href="https://github.com/apache/incubator-edgent/blob/master/samples/connectors/src/main/java/org/apache/edgent/samples/connectors/iotp/IotpQuickstart.java">code</a>, <a href="https://edgent.incubator.apache.org/javadoc/latest/index.html?org/apache/edgent/samples/connectors/iotp/IotpQuickstart.html">Javadoc</a>.</p>
<p>You can execute the class directly from Eclipse, or using the script: <a href="https://github.com/apache/incubator-edgent/blob/master/scripts/connectors/iotp/runiotpquickstart.sh"><code>edgent/java8/scripts/connectors/iotp/runiotpquickstart.sh</code></a></p>
http://git-wip-us.apache.org/repos/asf/incubator-edgent-website/blob/399cc808/content/docs/samples.html
----------------------------------------------------------------------
diff --git a/content/docs/samples.html b/content/docs/samples.html
index e21e360..fdbe170 100644
--- a/content/docs/samples.html
+++ b/content/docs/samples.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>
@@ -704,7 +710,7 @@ $('#toc').on('click', 'a', function() {
</ul></li>
</ul>
-<p>Additional samples are documented in the <a href="http://edgent.incubator.apache.org/javadoc/latest/overview-summary.html#overview.description">Edgent Overview</a> section of the Javadoc.</p>
+<p>Additional samples are documented in the <a href="https://edgent.incubator.apache.org/javadoc/latest/overview-summary.html#overview.description">Edgent Overview</a> section of the Javadoc.</p>
<div class="tags">
http://git-wip-us.apache.org/repos/asf/incubator-edgent-website/blob/399cc808/content/docs/search.html
----------------------------------------------------------------------
diff --git a/content/docs/search.html b/content/docs/search.html
index 9646caf..06decdd 100644
--- a/content/docs/search.html
+++ b/content/docs/search.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/docs/streaming-concepts.html
----------------------------------------------------------------------
diff --git a/content/docs/streaming-concepts.html b/content/docs/streaming-concepts.html
index 4c09814..4a5e83f 100644
--- a/content/docs/streaming-concepts.html
+++ b/content/docs/streaming-concepts.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>
@@ -644,12 +650,12 @@ $('#toc').on('click', 'a', function() {
<p>An Edgent application is most useful when processing some sort of data. This page is intended to help you understand stream processing concepts by visually demonstrating some of the operations that can be invoked on a stream, along with code snippets. For example,</p>
<ul>
-<li><a href="http://edgent.incubator.apache.org/javadoc/latest/org/apache/edgent/topology/TStream.html#filter-org.apache.edgent.function.Predicate-">filter</a></li>
-<li><a href="http://edgent.incubator.apache.org/javadoc/latest/org/apache/edgent/topology/TStream.html#split-int-org.apache.edgent.function.ToIntFunction-">split</a></li>
-<li><a href="http://edgent.incubator.apache.org/javadoc/latest/org/apache/edgent/topology/TStream.html#union-org.apache.edgent.topology.TStream-">union</a></li>
-<li><a href="http://edgent.incubator.apache.org/javadoc/latest/org/apache/edgent/topology/TStream.html#last-long-java.util.concurrent.TimeUnit-org.apache.edgent.function.Function-">partitioned window</a></li>
-<li><a href="http://edgent.incubator.apache.org/javadoc/latest/org/apache/edgent/topology/TWindow.html#aggregate-org.apache.edgent.function.BiFunction-">continuous aggregation</a></li>
-<li><a href="http://edgent.incubator.apache.org/javadoc/latest/org/apache/edgent/topology/TWindow.html#batch-org.apache.edgent.function.BiFunction-">batch</a></li>
+<li><a href="https://edgent.incubator.apache.org/javadoc/latest/org/apache/edgent/topology/TStream.html#filter-org.apache.edgent.function.Predicate-">filter</a></li>
+<li><a href="https://edgent.incubator.apache.org/javadoc/latest/org/apache/edgent/topology/TStream.html#split-int-org.apache.edgent.function.ToIntFunction-">split</a></li>
+<li><a href="https://edgent.incubator.apache.org/javadoc/latest/org/apache/edgent/topology/TStream.html#union-org.apache.edgent.topology.TStream-">union</a></li>
+<li><a href="https://edgent.incubator.apache.org/javadoc/latest/org/apache/edgent/topology/TStream.html#last-long-java.util.concurrent.TimeUnit-org.apache.edgent.function.Function-">partitioned window</a></li>
+<li><a href="https://edgent.incubator.apache.org/javadoc/latest/org/apache/edgent/topology/TWindow.html#aggregate-org.apache.edgent.function.BiFunction-">continuous aggregation</a></li>
+<li><a href="https://edgent.incubator.apache.org/javadoc/latest/org/apache/edgent/topology/TWindow.html#batch-org.apache.edgent.function.BiFunction-">batch</a></li>
</ul>
<h2 id="filter">Filter</h2>
http://git-wip-us.apache.org/repos/asf/incubator-edgent-website/blob/399cc808/content/docs/tag_collaboration.html
----------------------------------------------------------------------
diff --git a/content/docs/tag_collaboration.html b/content/docs/tag_collaboration.html
index 6e46699..1c1fe8a 100644
--- a/content/docs/tag_collaboration.html
+++ b/content/docs/tag_collaboration.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/docs/tag_content_types.html
----------------------------------------------------------------------
diff --git a/content/docs/tag_content_types.html b/content/docs/tag_content_types.html
index f41aa8a..a4e7b70 100644
--- a/content/docs/tag_content_types.html
+++ b/content/docs/tag_content_types.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/docs/tag_formatting.html
----------------------------------------------------------------------
diff --git a/content/docs/tag_formatting.html b/content/docs/tag_formatting.html
index e570d9f..9b30312 100644
--- a/content/docs/tag_formatting.html
+++ b/content/docs/tag_formatting.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/docs/tag_getting_started.html
----------------------------------------------------------------------
diff --git a/content/docs/tag_getting_started.html b/content/docs/tag_getting_started.html
index d2afee0..0387c31 100644
--- a/content/docs/tag_getting_started.html
+++ b/content/docs/tag_getting_started.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/docs/tag_mobile.html
----------------------------------------------------------------------
diff --git a/content/docs/tag_mobile.html b/content/docs/tag_mobile.html
index 130b33b..3659cd1 100644
--- a/content/docs/tag_mobile.html
+++ b/content/docs/tag_mobile.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/docs/tag_navigation.html
----------------------------------------------------------------------
diff --git a/content/docs/tag_navigation.html b/content/docs/tag_navigation.html
index 231bb7a..513814e 100644
--- a/content/docs/tag_navigation.html
+++ b/content/docs/tag_navigation.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/docs/tag_publishing.html
----------------------------------------------------------------------
diff --git a/content/docs/tag_publishing.html b/content/docs/tag_publishing.html
index c595c0c..46406b2 100644
--- a/content/docs/tag_publishing.html
+++ b/content/docs/tag_publishing.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/docs/tag_single_sourcing.html
----------------------------------------------------------------------
diff --git a/content/docs/tag_single_sourcing.html b/content/docs/tag_single_sourcing.html
index 206767a..267022b 100644
--- a/content/docs/tag_single_sourcing.html
+++ b/content/docs/tag_single_sourcing.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>