This is an automated email from the ASF dual-hosted git repository.
jfeinauer pushed a commit to branch asf-site
in repository https://gitbox.apache.org/repos/asf/incubator-edgent-website.git
The following commit(s) were added to refs/heads/asf-site by this push:
new c0768cd from c7b0ce579681a5e6fba73cf8ed3699367e4fb130
c0768cd is described below
commit c0768cdb6e9c45d8084cc9a382eae688235f2251
Author: Julian Feinauer <j.feina...@pragmaticminds.de>
AuthorDate: Wed Apr 3 18:17:35 2019 +0200
from c7b0ce579681a5e6fba73cf8ed3699367e4fb130
---
content/404.html | 2 +-
content/Gemfile.lock | 255 +++++++++++++++++++++
content/docs/application-development.html | 6 +-
content/docs/committers.html | 2 +-
content/docs/common-edgent-operations.html | 6 +-
content/docs/community.html | 2 +-
content/docs/console.html | 8 +-
content/docs/downloads.html | 2 +-
content/docs/edgent-getting-started-samples.html | 2 +-
content/docs/edgent-getting-started.html | 10 +-
content/docs/edgent_index.html | 2 +-
content/docs/faq.html | 4 +-
content/docs/home.html | 2 +-
content/docs/old-edgent-getting-started.html | 6 +-
content/docs/old-samples.html | 2 +-
content/docs/overview.html | 2 +-
content/docs/power-of-edgent.html | 12 +-
content/docs/quickstart.html | 2 +-
content/docs/search.html | 2 +-
content/docs/streaming-concepts.html | 2 +-
content/docs/tag_collaboration.html | 2 +-
content/docs/tag_content_types.html | 2 +-
content/docs/tag_formatting.html | 2 +-
content/docs/tag_getting_started.html | 2 +-
content/docs/tag_mobile.html | 2 +-
content/docs/tag_navigation.html | 2 +-
content/docs/tag_publishing.html | 2 +-
content/docs/tag_single_sourcing.html | 2 +-
content/docs/tag_special_layouts.html | 2 +-
content/index.html | 11 +
.../recipes/recipe_adaptable_deadtime_filter.html | 16 +-
content/recipes/recipe_adaptable_filter_range.html | 8 +-
.../recipes/recipe_adaptable_polling_source.html | 14 +-
...ecipe_combining_streams_processing_results.html | 10 +-
content/recipes/recipe_concurrent_analytics.html | 16 +-
...recipe_different_processing_against_stream.html | 6 +-
.../recipes/recipe_dynamic_analytic_control.html | 2 +-
content/recipes/recipe_external_filter_range.html | 8 +-
content/recipes/recipe_hello_edgent.html | 10 +-
content/recipes/recipe_parallel_analytics.html | 12 +-
content/recipes/recipe_source_function.html | 10 +-
content/recipes/recipe_value_out_of_range.html | 6 +-
content/recipes/recipe_writing_a_connector.html | 2 +-
content/titlepage.html | 4 +-
content/tocpage.html | 2 +-
45 files changed, 376 insertions(+), 110 deletions(-)
diff --git a/content/404.html b/content/404.html
index 330ae6e..2f95c3b 100644
--- a/content/404.html
+++ b/content/404.html
@@ -725,7 +725,7 @@ $('#toc').on('click', 'a', function() {
<div class="col-lg-12 footer">
Site last
- generated: Dec 18, 2017 <br/>
+ generated: Apr 3, 2019 <br/>
</div>
</div>
diff --git a/content/Gemfile.lock b/content/Gemfile.lock
new file mode 100644
index 0000000..a121a4b
--- /dev/null
+++ b/content/Gemfile.lock
@@ -0,0 +1,255 @@
+GEM
+ remote: https://rubygems.org/
+ specs:
+ activesupport (4.2.10)
+ i18n (~> 0.7)
+ minitest (~> 5.1)
+ thread_safe (~> 0.3, >= 0.3.4)
+ tzinfo (~> 1.1)
+ addressable (2.5.2)
+ public_suffix (>= 2.0.2, < 4.0)
+ coffee-script (2.4.1)
+ coffee-script-source
+ execjs
+ coffee-script-source (1.11.1)
+ colorator (1.1.0)
+ commonmarker (0.17.13)
+ ruby-enum (~> 0.5)
+ concurrent-ruby (1.1.5)
+ dnsruby (1.61.2)
+ addressable (~> 2.5)
+ em-websocket (0.5.1)
+ eventmachine (>= 0.12.9)
+ http_parser.rb (~> 0.6.0)
+ ethon (0.12.0)
+ ffi (>= 1.3.0)
+ eventmachine (1.2.7)
+ execjs (2.7.0)
+ faraday (0.15.4)
+ multipart-post (>= 1.2, < 3)
+ ffi (1.10.0)
+ forwardable-extended (2.6.0)
+ gemoji (3.0.0)
+ github-pages (197)
+ activesupport (= 4.2.10)
+ github-pages-health-check (= 1.16.1)
+ jekyll (= 3.7.4)
+ jekyll-avatar (= 0.6.0)
+ jekyll-coffeescript (= 1.1.1)
+ jekyll-commonmark-ghpages (= 0.1.5)
+ jekyll-default-layout (= 0.1.4)
+ jekyll-feed (= 0.11.0)
+ jekyll-gist (= 1.5.0)
+ jekyll-github-metadata (= 2.12.1)
+ jekyll-mentions (= 1.4.1)
+ jekyll-optional-front-matter (= 0.3.0)
+ jekyll-paginate (= 1.1.0)
+ jekyll-readme-index (= 0.2.0)
+ jekyll-redirect-from (= 0.14.0)
+ jekyll-relative-links (= 0.6.0)
+ jekyll-remote-theme (= 0.3.1)
+ jekyll-sass-converter (= 1.5.2)
+ jekyll-seo-tag (= 2.5.0)
+ jekyll-sitemap (= 1.2.0)
+ jekyll-swiss (= 0.4.0)
+ jekyll-theme-architect (= 0.1.1)
+ jekyll-theme-cayman (= 0.1.1)
+ jekyll-theme-dinky (= 0.1.1)
+ jekyll-theme-hacker (= 0.1.1)
+ jekyll-theme-leap-day (= 0.1.1)
+ jekyll-theme-merlot (= 0.1.1)
+ jekyll-theme-midnight (= 0.1.1)
+ jekyll-theme-minimal (= 0.1.1)
+ jekyll-theme-modernist (= 0.1.1)
+ jekyll-theme-primer (= 0.5.3)
+ jekyll-theme-slate (= 0.1.1)
+ jekyll-theme-tactile (= 0.1.1)
+ jekyll-theme-time-machine (= 0.1.1)
+ jekyll-titles-from-headings (= 0.5.1)
+ jemoji (= 0.10.2)
+ kramdown (= 1.17.0)
+ liquid (= 4.0.0)
+ listen (= 3.1.5)
+ mercenary (~> 0.3)
+ minima (= 2.5.0)
+ nokogiri (>= 1.8.5, < 2.0)
+ rouge (= 2.2.1)
+ terminal-table (~> 1.4)
+ github-pages-health-check (1.16.1)
+ addressable (~> 2.3)
+ dnsruby (~> 1.60)
+ octokit (~> 4.0)
+ public_suffix (~> 3.0)
+ typhoeus (~> 1.3)
+ html-pipeline (2.10.0)
+ activesupport (>= 2)
+ nokogiri (>= 1.4)
+ http_parser.rb (0.6.0)
+ i18n (0.9.5)
+ concurrent-ruby (~> 1.0)
+ jekyll (3.7.4)
+ addressable (~> 2.4)
+ colorator (~> 1.0)
+ em-websocket (~> 0.5)
+ i18n (~> 0.7)
+ jekyll-sass-converter (~> 1.0)
+ jekyll-watch (~> 2.0)
+ kramdown (~> 1.14)
+ liquid (~> 4.0)
+ mercenary (~> 0.3.3)
+ pathutil (~> 0.9)
+ rouge (>= 1.7, < 4)
+ safe_yaml (~> 1.0)
+ jekyll-avatar (0.6.0)
+ jekyll (~> 3.0)
+ jekyll-coffeescript (1.1.1)
+ coffee-script (~> 2.2)
+ coffee-script-source (~> 1.11.1)
+ jekyll-commonmark (1.3.1)
+ commonmarker (~> 0.14)
+ jekyll (>= 3.7, < 5.0)
+ jekyll-commonmark-ghpages (0.1.5)
+ commonmarker (~> 0.17.6)
+ jekyll-commonmark (~> 1)
+ rouge (~> 2)
+ jekyll-default-layout (0.1.4)
+ jekyll (~> 3.0)
+ jekyll-feed (0.11.0)
+ jekyll (~> 3.3)
+ jekyll-gist (1.5.0)
+ octokit (~> 4.2)
+ jekyll-github-metadata (2.12.1)
+ jekyll (~> 3.4)
+ octokit (~> 4.0, != 4.4.0)
+ jekyll-mentions (1.4.1)
+ html-pipeline (~> 2.3)
+ jekyll (~> 3.0)
+ jekyll-optional-front-matter (0.3.0)
+ jekyll (~> 3.0)
+ jekyll-paginate (1.1.0)
+ jekyll-readme-index (0.2.0)
+ jekyll (~> 3.0)
+ jekyll-redirect-from (0.14.0)
+ jekyll (~> 3.3)
+ jekyll-relative-links (0.6.0)
+ jekyll (~> 3.3)
+ jekyll-remote-theme (0.3.1)
+ jekyll (~> 3.5)
+ rubyzip (>= 1.2.1, < 3.0)
+ jekyll-sass-converter (1.5.2)
+ sass (~> 3.4)
+ jekyll-seo-tag (2.5.0)
+ jekyll (~> 3.3)
+ jekyll-sitemap (1.2.0)
+ jekyll (~> 3.3)
+ jekyll-swiss (0.4.0)
+ jekyll-theme-architect (0.1.1)
+ jekyll (~> 3.5)
+ jekyll-seo-tag (~> 2.0)
+ jekyll-theme-cayman (0.1.1)
+ jekyll (~> 3.5)
+ jekyll-seo-tag (~> 2.0)
+ jekyll-theme-dinky (0.1.1)
+ jekyll (~> 3.5)
+ jekyll-seo-tag (~> 2.0)
+ jekyll-theme-hacker (0.1.1)
+ jekyll (~> 3.5)
+ jekyll-seo-tag (~> 2.0)
+ jekyll-theme-leap-day (0.1.1)
+ jekyll (~> 3.5)
+ jekyll-seo-tag (~> 2.0)
+ jekyll-theme-merlot (0.1.1)
+ jekyll (~> 3.5)
+ jekyll-seo-tag (~> 2.0)
+ jekyll-theme-midnight (0.1.1)
+ jekyll (~> 3.5)
+ jekyll-seo-tag (~> 2.0)
+ jekyll-theme-minimal (0.1.1)
+ jekyll (~> 3.5)
+ jekyll-seo-tag (~> 2.0)
+ jekyll-theme-modernist (0.1.1)
+ jekyll (~> 3.5)
+ jekyll-seo-tag (~> 2.0)
+ jekyll-theme-primer (0.5.3)
+ jekyll (~> 3.5)
+ jekyll-github-metadata (~> 2.9)
+ jekyll-seo-tag (~> 2.0)
+ jekyll-theme-slate (0.1.1)
+ jekyll (~> 3.5)
+ jekyll-seo-tag (~> 2.0)
+ jekyll-theme-tactile (0.1.1)
+ jekyll (~> 3.5)
+ jekyll-seo-tag (~> 2.0)
+ jekyll-theme-time-machine (0.1.1)
+ jekyll (~> 3.5)
+ jekyll-seo-tag (~> 2.0)
+ jekyll-titles-from-headings (0.5.1)
+ jekyll (~> 3.3)
+ jekyll-watch (2.2.1)
+ listen (~> 3.0)
+ jemoji (0.10.2)
+ gemoji (~> 3.0)
+ html-pipeline (~> 2.2)
+ jekyll (~> 3.0)
+ kramdown (1.17.0)
+ liquid (4.0.0)
+ listen (3.1.5)
+ rb-fsevent (~> 0.9, >= 0.9.4)
+ rb-inotify (~> 0.9, >= 0.9.7)
+ ruby_dep (~> 1.2)
+ mercenary (0.3.6)
+ mini_portile2 (2.4.0)
+ minima (2.5.0)
+ jekyll (~> 3.5)
+ jekyll-feed (~> 0.9)
+ jekyll-seo-tag (~> 2.1)
+ minitest (5.8.5)
+ multi_json (1.13.1)
+ multipart-post (2.0.0)
+ nokogiri (1.10.2)
+ mini_portile2 (~> 2.4.0)
+ octokit (4.14.0)
+ sawyer (~> 0.8.0, >= 0.5.3)
+ pathutil (0.16.2)
+ forwardable-extended (~> 2.6)
+ public_suffix (3.0.3)
+ pygments.rb (1.2.1)
+ multi_json (>= 1.0.0)
+ rb-fsevent (0.10.3)
+ rb-inotify (0.10.0)
+ ffi (~> 1.0)
+ redcarpet (3.4.0)
+ rouge (2.2.1)
+ ruby-enum (0.7.2)
+ i18n
+ ruby_dep (1.5.0)
+ rubyzip (1.2.2)
+ safe_yaml (1.0.5)
+ sass (3.7.3)
+ sass-listen (~> 4.0.0)
+ sass-listen (4.0.0)
+ rb-fsevent (~> 0.9, >= 0.9.4)
+ rb-inotify (~> 0.9, >= 0.9.7)
+ sawyer (0.8.1)
+ addressable (>= 2.3.5, < 2.6)
+ faraday (~> 0.8, < 1.0)
+ terminal-table (1.8.0)
+ unicode-display_width (~> 1.1, >= 1.1.1)
+ thread_safe (0.3.6)
+ typhoeus (1.3.1)
+ ethon (>= 0.9.0)
+ tzinfo (1.2.5)
+ thread_safe (~> 0.1)
+ unicode-display_width (1.5.0)
+
+PLATFORMS
+ ruby
+
+DEPENDENCIES
+ github-pages
+ jekyll
+ pygments.rb
+ redcarpet
+
+BUNDLED WITH
+ 2.0.1
diff --git a/content/docs/application-development.html
b/content/docs/application-development.html
index a5ea3ec..68a7bda 100644
--- a/content/docs/application-development.html
+++ b/content/docs/application-development.html
@@ -845,7 +845,7 @@ and runs the application.</p>
<p>E.g.,</p>
<div class="highlight"><pre><code class="language-sh" data-lang="sh"><span
class="nb">cd </span>MyApp <span class="c"># the application's project
directory</span>
-package-app.sh --mainClass com.mycompany.app.MyApp --appjar
target/my-app-1.0-SNAPSHOT.jar
+package-app.sh <span class="nt">--mainClass</span> com.mycompany.app.MyApp
<span class="nt">--appjar</span> target/my-app-1.0-SNAPSHOT.jar
<span class="c">##### get the app specific dependencies...</span>
...
<span class="c">##### create target/app-run.sh...</span>
@@ -857,7 +857,7 @@ package-app.sh --mainClass com.mycompany.app.MyApp --appjar
target/my-app-1.0-SN
<span class="c">##### (cd app-pkg; ./app-run.sh)"</span>
</code></pre></div>
<p>For more usage information:</p>
-<div class="highlight"><pre><code class="language-sh"
data-lang="sh">./package-app.sh -h
+<div class="highlight"><pre><code class="language-sh"
data-lang="sh">./package-app.sh <span class="nt">-h</span>
</code></pre></div>
<div class="tags">
@@ -890,7 +890,7 @@ package-app.sh --mainClass com.mycompany.app.MyApp --appjar
target/my-app-1.0-SN
<div class="col-lg-12 footer">
Site last
- generated: Dec 18, 2017 <br/>
+ generated: Apr 3, 2019 <br/>
</div>
</div>
diff --git a/content/docs/committers.html b/content/docs/committers.html
index b97da8b..75da6b4 100644
--- a/content/docs/committers.html
+++ b/content/docs/committers.html
@@ -739,7 +739,7 @@ $('#toc').on('click', 'a', function() {
<div class="col-lg-12 footer">
Site last
- generated: Dec 18, 2017 <br/>
+ generated: Apr 3, 2019 <br/>
</div>
</div>
diff --git a/content/docs/common-edgent-operations.html
b/content/docs/common-edgent-operations.html
index 8eed047..2d799ea 100644
--- a/content/docs/common-edgent-operations.html
+++ b/content/docs/common-edgent-operations.html
@@ -698,7 +698,7 @@ $('#toc').on('click', 'a', function() {
<p><code>TStream.map()</code> is arguably the most used method in the Edgent
API. Its two main purposes are to perform stateful or stateless operations on a
stream's tuples, and to produce a <code>TStream</code> with tuples of a
different type from that of the calling stream.</p>
-<h3 id="changing-a-tstream-39-s-tuple-type">Changing a TStream's tuple
type</h3>
+<h3 id="changing-a-tstreams-tuple-type">Changing a TStream's tuple
type</h3>
<p>In addition to filtering tuples, <code>TStream</code>s support operations
that <em>transform</em> tuples from one Java type to another by invoking the
<code>TStream.map()</code> method.</p>
@@ -731,7 +731,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 clas [...]
<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="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="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="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>
@@ -770,7 +770,7 @@ $('#toc').on('click', 'a', function() {
<div class="col-lg-12 footer">
Site last
- generated: Dec 18, 2017 <br/>
+ generated: Apr 3, 2019 <br/>
</div>
</div>
diff --git a/content/docs/community.html b/content/docs/community.html
index 72414af..7bd4ad9 100644
--- a/content/docs/community.html
+++ b/content/docs/community.html
@@ -791,7 +791,7 @@ $('#toc').on('click', 'a', function() {
<div class="col-lg-12 footer">
Site last
- generated: Dec 18, 2017 <br/>
+ generated: Apr 3, 2019 <br/>
</div>
</div>
diff --git a/content/docs/console.html b/content/docs/console.html
index 5d88eca..18d729d 100644
--- a/content/docs/console.html
+++ b/content/docs/console.html
@@ -709,7 +709,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="n">main</span><span class="o">(</span><span
class="n">String</span><span class="o">[]</span> <span
class="n">args</span><span class="o">)</span> <span class="kd">throws</span>
<span class="n">Exception</span> <span class="o">{</span>
+ <span class="kd">public</span> <span class="kd">static</span> <span
class="kt">void</span> <span class="nf">main</span><span
class="o">(</span><span class="n">String</span><span class="o">[]</span> <span
class="n">args</span><span class="o">)</span> <span class="kd">throws</span>
<span class="n">Exception</span> <span class="o">{</span>
<span class="n">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>
@@ -844,7 +844,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>TS [...]
<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 [...]
<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<Json [...]
-<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 [...]
+<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 [...]
<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>
@@ -1009,7 +1009,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="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 cla [...]
+<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 cl [...]
<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 clas [...]
<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> <spa [...]
@@ -1196,7 +1196,7 @@ Metrics.rateMeter(individualAlerts3.get(0));
<div class="col-lg-12 footer">
Site last
- generated: Dec 18, 2017 <br/>
+ generated: Apr 3, 2019 <br/>
</div>
</div>
diff --git a/content/docs/downloads.html b/content/docs/downloads.html
index f7664f9..80b966a 100644
--- a/content/docs/downloads.html
+++ b/content/docs/downloads.html
@@ -852,7 +852,7 @@ $('#toc').on('click', 'a', function() {
<div class="col-lg-12 footer">
Site last
- generated: Dec 18, 2017 <br/>
+ generated: Apr 3, 2019 <br/>
</div>
</div>
diff --git a/content/docs/edgent-getting-started-samples.html
b/content/docs/edgent-getting-started-samples.html
index 14408a0..1e69a94 100644
--- a/content/docs/edgent-getting-started-samples.html
+++ b/content/docs/edgent-getting-started-samples.html
@@ -778,7 +778,7 @@ See the <a href="edgent-getting-started">Getting Started
Guide</a> for a tutoria
<div class="col-lg-12 footer">
Site last
- generated: Dec 18, 2017 <br/>
+ generated: Apr 3, 2019 <br/>
</div>
</div>
diff --git a/content/docs/edgent-getting-started.html
b/content/docs/edgent-getting-started.html
index 898ff4f..c228af2 100644
--- a/content/docs/edgent-getting-started.html
+++ b/content/docs/edgent-getting-started.html
@@ -763,7 +763,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="n">get</span><span class="o">()</span> <span class="o">{</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="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>
@@ -781,7 +781,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="n">main</span><span class="o">(</span><span
class="n">String</span><span class="o">[]</span> <span
class="n">args</span><span class="o">)</span> <span class="kd">throws</span>
<span class="n">Exception</span> <span class="o">{</span>
+ <span class="kd">public</span> <span class="kd">static</span> <span
class="kt">void</span> <span class="nf">main</span><span
class="o">(</span><span class="n">String</span><span class="o">[]</span> <span
class="n">args</span><span class="o">)</span> <span class="kd">throws</span>
<span class="n">Exception</span> <span class="o">{</span>
<span class="n">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>
@@ -873,7 +873,7 @@ $('#toc').on('click', 'a', function() {
<p>Then you can run this application from the command line:</p>
<div class="highlight"><pre><code class="language-sh" data-lang="sh"><span
class="nb">cd</span> <the-unpacked-samples-root-folder>
-<span class="nb">cd </span>topology; ./run-sample.sh TempSensorApplication
+<span class="nb">cd </span>topology<span class="p">;</span> ./run-sample.sh
TempSensorApplication
46.59272336309031
46.681544551652934
...
@@ -913,7 +913,7 @@ Its easiest to use the <code>template</code> project in the
Edgent Samples to ge
<p>To build and run from the command line, see the new project's README.md
(copied in from the template).
In the project's folder (adjust the package name below if appropriate)</p>
<div class="highlight"><pre><code class="language-sh" data-lang="sh">./mvnw
clean package
-./app-run.sh --main com.mycompany.app.TempSensorApplication
+./app-run.sh <span class="nt">--main</span>
com.mycompany.app.TempSensorApplication
46.59272336309031
46.681544551652934
...
@@ -973,7 +973,7 @@ Click on the <code>terminate</code> control in the Console
view to stop the appl
<div class="col-lg-12 footer">
Site last
- generated: Dec 18, 2017 <br/>
+ generated: Apr 3, 2019 <br/>
</div>
</div>
diff --git a/content/docs/edgent_index.html b/content/docs/edgent_index.html
index d364c7b..a72f9ff 100644
--- a/content/docs/edgent_index.html
+++ b/content/docs/edgent_index.html
@@ -750,7 +750,7 @@ $('#toc').on('click', 'a', function() {
<div class="col-lg-12 footer">
Site last
- generated: Dec 18, 2017 <br/>
+ generated: Apr 3, 2019 <br/>
</div>
</div>
diff --git a/content/docs/faq.html b/content/docs/faq.html
index 7361078..9185803 100644
--- a/content/docs/faq.html
+++ b/content/docs/faq.html
@@ -795,7 +795,7 @@ $('#toc').on('click', 'a', function() {
<p>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 r [...]
-<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>
+<h2 id="i-see-references-to-quarks-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.</p>
@@ -830,7 +830,7 @@ $('#toc').on('click', 'a', function() {
<div class="col-lg-12 footer">
Site last
- generated: Dec 18, 2017 <br/>
+ generated: Apr 3, 2019 <br/>
</div>
</div>
diff --git a/content/docs/home.html b/content/docs/home.html
index ea92628..462de7c 100644
--- a/content/docs/home.html
+++ b/content/docs/home.html
@@ -794,7 +794,7 @@ $('#toc').on('click', 'a', function() {
<div class="col-lg-12 footer">
Site last
- generated: Dec 18, 2017 <br/>
+ generated: Apr 3, 2019 <br/>
</div>
</div>
diff --git a/content/docs/old-edgent-getting-started.html
b/content/docs/old-edgent-getting-started.html
index cf79b09..e5ec432 100644
--- a/content/docs/old-edgent-getting-started.html
+++ b/content/docs/old-edgent-getting-started.html
@@ -807,7 +807,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="n">get</span><span class="o">()</span> <span class="o">{</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="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>
@@ -825,7 +825,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="n">main</span><span class="o">(</span><span
class="n">String</span><span class="o">[]</span> <span
class="n">args</span><span class="o">)</span> <span class="kd">throws</span>
<span class="n">Exception</span> <span class="o">{</span>
+ <span class="kd">public</span> <span class="kd">static</span> <span
class="kt">void</span> <span class="nf">main</span><span
class="o">(</span><span class="n">String</span><span class="o">[]</span> <span
class="n">args</span><span class="o">)</span> <span class="kd">throws</span>
<span class="n">Exception</span> <span class="o">{</span>
<span class="n">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>
@@ -943,7 +943,7 @@ $('#toc').on('click', 'a', function() {
<div class="col-lg-12 footer">
Site last
- generated: Dec 18, 2017 <br/>
+ generated: Apr 3, 2019 <br/>
</div>
</div>
diff --git a/content/docs/old-samples.html b/content/docs/old-samples.html
index 9b67987..b556a20 100644
--- a/content/docs/old-samples.html
+++ b/content/docs/old-samples.html
@@ -790,7 +790,7 @@ $('#toc').on('click', 'a', function() {
<div class="col-lg-12 footer">
Site last
- generated: Dec 18, 2017 <br/>
+ generated: Apr 3, 2019 <br/>
</div>
</div>
diff --git a/content/docs/overview.html b/content/docs/overview.html
index 30c06e1..eac31a4 100644
--- a/content/docs/overview.html
+++ b/content/docs/overview.html
@@ -797,7 +797,7 @@ medical device.</li>
<div class="col-lg-12 footer">
Site last
- generated: Dec 18, 2017 <br/>
+ generated: Apr 3, 2019 <br/>
</div>
</div>
diff --git a/content/docs/power-of-edgent.html
b/content/docs/power-of-edgent.html
index a910cf8..01ee260 100644
--- a/content/docs/power-of-edgent.html
+++ b/content/docs/power-of-edgent.html
@@ -706,7 +706,7 @@ and information about full samples and recipies.</p>
<p>Let's start with a complete application that periodically samples a
sensor
and publishes its values to an Enterprise IoT Hub in less than 10 lines of
code</p>
<div class="highlight"><pre><code class="language-java" data-lang="java"><span
class="kd">public</span> <span class="kd">class</span> <span
class="nc">ImpressiveEdgentExample</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="kd">public</span> <span class="kd">static</span> <span
class="kt">void</span> <span class="nf">main</span><span
class="o">(</span><span class="n">String</span><span class="o">[]</span> <span
class="n">args</span><span class="o">)</span> <span class="o">{</span>
<span class="n">DirectProvider</span> <span class="n">provider</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">provider</span><span class="o">.</span><span
class="na">newTopology</span><span class="o">();</span>
@@ -779,7 +779,7 @@ want to pub/sub to an MQTT server? No worries! Use the <a
href="/javadoc/latest
<p>There's a <a
href="/javadoc/latest/index.html?org/apache/edgent/connectors/jdbc/JdbcStreams.html">JdbcStreams</a>
connector too.</p>
<p>Want to sink a <code>TStream</code> to rolling text files? Use the <a
href="/javadoc/latest/index.html?org/apache/edgent/connectors/file/FileStreams.html">FileStreams</a>
connector.</p>
-<div class="highlight"><pre><code class="language-java" data-lang="java">
<span class="k">new</span> <span class="nf">File</span><span
class="p">(</span><span class="s">"/tmp/MY-DEMO-FILES"</span><span
class="o">).</span><span class="na">mkdir</span><span class="o">();</span>
+<div class="highlight"><pre><code class="language-java" data-lang="java">
<span class="k">new</span> <span class="n">File</span><span
class="o">(</span><span class="s">"/tmp/MY-DEMO-FILES"</span><span
class="o">).</span><span class="na">mkdir</span><span class="o">();</span>
<span class="n">FileStreams</span><span class="o">.</span><span
class="na">textFileWriter</span><span class="o">(</span><span
class="n">events</span><span class="o">.</span><span
class="na">asString</span><span class="o">(),</span> <span class="o">()</span>
<span class="o">-></span> <span
class="s">"/tmp/MY-DEMO-FILES/READINGS"</span><span class="o">);</span>
<span class="c1">// tail -f /tmp/MY-DEMO-FILES/.READINGS</span>
@@ -841,7 +841,7 @@ That's just one of the methods defined in <a
href="/javadoc/latest/index.htm
<div class="highlight"><pre><code class="language-java" data-lang="java">
<span class="kd">public</span> <span class="kd">class</span> <span
class="nc">SensorReading</span> <span class="o">{</span>
<span class="kt">double</span> <span class="n">temp</span><span
class="o">;</span>
<span class="kt">double</span> <span class="n">pressure</span><span
class="o">;</span>
- <span class="kd">public</span> <span
class="n">SensorReading</span><span class="o">(</span><span
class="kt">double</span> <span class="n">temp</span><span class="o">,</span>
<span class="kt">double</span> <span class="n">pressure</span><span
class="o">)</span> <span class="o">{</span>
+ <span class="kd">public</span> <span
class="nf">SensorReading</span><span class="o">(</span><span
class="kt">double</span> <span class="n">temp</span><span class="o">,</span>
<span class="kt">double</span> <span class="n">pressure</span><span
class="o">)</span> <span class="o">{</span>
<span class="k">this</span><span class="o">.</span><span
class="na">temp</span> <span class="o">=</span> <span
class="n">temp</span><span class="o">;</span>
<span class="k">this</span><span class="o">.</span><span
class="na">pressure</span> <span class="o">=</span> <span
class="n">pressure</span><span class="o">;</span>
<span class="o">}</span>
@@ -936,10 +936,10 @@ system into an Edgent application.<br>
Imagine a package defined something like:</p>
<div class="highlight"><pre><code class="language-java" data-lang="java">
<span class="kd">public</span> <span class="kd">class</span> <span
class="nc">Model</span> <span class="o">{</span>
<span class="c1">// load model from a File</span>
- <span class="kd">public</span> <span class="n">Model</span><span
class="o">(</span><span class="n">File</span> <span class="n">f</span><span
class="o">)</span> <span class="o">{</span> <span class="o">...</span> <span
class="o">};</span>
+ <span class="kd">public</span> <span class="nf">Model</span><span
class="o">(</span><span class="n">File</span> <span class="n">f</span><span
class="o">)</span> <span class="o">{</span> <span class="o">...</span> <span
class="o">};</span>
<span class="c1">// score String s against the model</span>
<span class="c1">// return a confidence score between 0.0 and 1.0</span>
- <span class="kd">public</span> <span class="n">Double</span> <span
class="n">score</span><span class="o">(</span><span class="n">String</span>
<span class="n">s</span><span class="o">);</span>
+ <span class="kd">public</span> <span class="n">Double</span> <span
class="nf">score</span><span class="o">(</span><span class="n">String</span>
<span class="n">s</span><span class="o">);</span>
<span class="o">}</span>
</code></pre></div>
<p>An Edgent application might use such a model in this manner</p>
@@ -1060,7 +1060,7 @@ material and samples and recipies.</p>
<div class="col-lg-12 footer">
Site last
- generated: Dec 18, 2017 <br/>
+ generated: Apr 3, 2019 <br/>
</div>
</div>
diff --git a/content/docs/quickstart.html b/content/docs/quickstart.html
index 92b3541..e4e46da 100644
--- a/content/docs/quickstart.html
+++ b/content/docs/quickstart.html
@@ -767,7 +767,7 @@ and Edgent provides a <a
href="/javadoc/latest/index.html?org/apache/edgent/conn
<div class="col-lg-12 footer">
Site last
- generated: Dec 18, 2017 <br/>
+ generated: Apr 3, 2019 <br/>
</div>
</div>
diff --git a/content/docs/search.html b/content/docs/search.html
index 2cbe191..23f7f0d 100644
--- a/content/docs/search.html
+++ b/content/docs/search.html
@@ -715,7 +715,7 @@ $('#toc').on('click', 'a', function() {
<div class="col-lg-12 footer">
Site last
- generated: Dec 18, 2017 <br/>
+ generated: Apr 3, 2019 <br/>
</div>
</div>
diff --git a/content/docs/streaming-concepts.html
b/content/docs/streaming-concepts.html
index 973961f..a23af8a 100644
--- a/content/docs/streaming-concepts.html
+++ b/content/docs/streaming-concepts.html
@@ -1476,7 +1476,7 @@ $('#toc').on('click', 'a', function() {
<div class="col-lg-12 footer">
Site last
- generated: Dec 18, 2017 <br/>
+ generated: Apr 3, 2019 <br/>
</div>
</div>
diff --git a/content/docs/tag_collaboration.html
b/content/docs/tag_collaboration.html
index 2618800..67705f4 100644
--- a/content/docs/tag_collaboration.html
+++ b/content/docs/tag_collaboration.html
@@ -828,7 +828,7 @@ $('#toc').on('click', 'a', function() {
<div class="col-lg-12 footer">
Site last
- generated: Dec 18, 2017 <br/>
+ generated: Apr 3, 2019 <br/>
</div>
</div>
diff --git a/content/docs/tag_content_types.html
b/content/docs/tag_content_types.html
index 8dcfa02..e32769a 100644
--- a/content/docs/tag_content_types.html
+++ b/content/docs/tag_content_types.html
@@ -828,7 +828,7 @@ $('#toc').on('click', 'a', function() {
<div class="col-lg-12 footer">
Site last
- generated: Dec 18, 2017 <br/>
+ generated: Apr 3, 2019 <br/>
</div>
</div>
diff --git a/content/docs/tag_formatting.html b/content/docs/tag_formatting.html
index 488eaaf..db0c935 100644
--- a/content/docs/tag_formatting.html
+++ b/content/docs/tag_formatting.html
@@ -828,7 +828,7 @@ $('#toc').on('click', 'a', function() {
<div class="col-lg-12 footer">
Site last
- generated: Dec 18, 2017 <br/>
+ generated: Apr 3, 2019 <br/>
</div>
</div>
diff --git a/content/docs/tag_getting_started.html
b/content/docs/tag_getting_started.html
index 90e33d1..b2fdc9a 100644
--- a/content/docs/tag_getting_started.html
+++ b/content/docs/tag_getting_started.html
@@ -828,7 +828,7 @@ $('#toc').on('click', 'a', function() {
<div class="col-lg-12 footer">
Site last
- generated: Dec 18, 2017 <br/>
+ generated: Apr 3, 2019 <br/>
</div>
</div>
diff --git a/content/docs/tag_mobile.html b/content/docs/tag_mobile.html
index 88fab85..a85da51 100644
--- a/content/docs/tag_mobile.html
+++ b/content/docs/tag_mobile.html
@@ -828,7 +828,7 @@ $('#toc').on('click', 'a', function() {
<div class="col-lg-12 footer">
Site last
- generated: Dec 18, 2017 <br/>
+ generated: Apr 3, 2019 <br/>
</div>
</div>
diff --git a/content/docs/tag_navigation.html b/content/docs/tag_navigation.html
index 4f8b346..7074031 100644
--- a/content/docs/tag_navigation.html
+++ b/content/docs/tag_navigation.html
@@ -828,7 +828,7 @@ $('#toc').on('click', 'a', function() {
<div class="col-lg-12 footer">
Site last
- generated: Dec 18, 2017 <br/>
+ generated: Apr 3, 2019 <br/>
</div>
</div>
diff --git a/content/docs/tag_publishing.html b/content/docs/tag_publishing.html
index f2e2f88..98ffcf5 100644
--- a/content/docs/tag_publishing.html
+++ b/content/docs/tag_publishing.html
@@ -828,7 +828,7 @@ $('#toc').on('click', 'a', function() {
<div class="col-lg-12 footer">
Site last
- generated: Dec 18, 2017 <br/>
+ generated: Apr 3, 2019 <br/>
</div>
</div>
diff --git a/content/docs/tag_single_sourcing.html
b/content/docs/tag_single_sourcing.html
index e28fde9..842fe7b 100644
--- a/content/docs/tag_single_sourcing.html
+++ b/content/docs/tag_single_sourcing.html
@@ -828,7 +828,7 @@ $('#toc').on('click', 'a', function() {
<div class="col-lg-12 footer">
Site last
- generated: Dec 18, 2017 <br/>
+ generated: Apr 3, 2019 <br/>
</div>
</div>
diff --git a/content/docs/tag_special_layouts.html
b/content/docs/tag_special_layouts.html
index 9f84f6a..4b43b4f 100644
--- a/content/docs/tag_special_layouts.html
+++ b/content/docs/tag_special_layouts.html
@@ -828,7 +828,7 @@ $('#toc').on('click', 'a', function() {
<div class="col-lg-12 footer">
Site last
- generated: Dec 18, 2017 <br/>
+ generated: Apr 3, 2019 <br/>
</div>
</div>
diff --git a/content/index.html b/content/index.html
index 69c2067..a677a9f 100644
--- a/content/index.html
+++ b/content/index.html
@@ -180,6 +180,17 @@
<div class="row">
<div class="col-lg-12 col-sm-12">
+
+ <h2 class="section-heading">Talks at Conferences</h2>
+
+ <!--Talk Building IoT jfeinauer-->
+ <iframe
src="//www.slideshare.net/slideshow/embed_code/key/3FU9D9KllR81ZY" width="595"
height="485" frameborder="0" marginwidth="0" marginheight="0" scrolling="no"
style="border:1px solid #CCC; border-width:1px; margin-bottom:5px; max-width:
100%;" allowfullscreen> </iframe> <div style="margin-bottom:5px"> <strong> <a
href="//www.slideshare.net/JulianFeinauer/orientation-in-the-fog-differences-between-stream-processing-in-edge-and-cloud"
title="Orientation in the fog: [...]
+ <h4>Wednesday April 03, 2019 • 2:15pm - 3:00pm CESTT</h4>
+ <h4>Conference: <a
href="https://www.buildingiot.de/";>building iot 2019</a></h4>
+ <h4>Presenter: Julian Feinauer, pragmatic minds GmbH</h4>
+
+ <div class="lead">...</div>
+
<a
href="http://events.linuxfoundation.org/events/apachecon-north-america";><img
src="https://apachecon.com/images/apache/apachecon_na_500x500.png";
style="width: 400px; height: auto;"></a>
<h3><a
href="https://apachecon2017.sched.com/event/9zp4/video-analytics-at-the-edge-fun-with-apache-edgent-opencv-and-a-raspberry-pi-william-marshall-dale-labossiere-ibm?iframe=no&w=&sidebar=yes&bg=no";>Video
Analytics at the Edge: Fun with Apache Edgent, OpenCV and a Raspberry
Pi</a></h3>
diff --git a/content/recipes/recipe_adaptable_deadtime_filter.html
b/content/recipes/recipe_adaptable_deadtime_filter.html
index a410779..8a93870 100644
--- a/content/recipes/recipe_adaptable_deadtime_filter.html
+++ b/content/recipes/recipe_adaptable_deadtime_filter.html
@@ -716,20 +716,20 @@ $('#toc').on('click', 'a', function() {
</code></pre></div>
<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="create-a-deadtime-filtered-stream-mdash-initially-no-deadtime">Create
a deadtime filtered stream—initially no deadtime</h2>
+<h2 id="create-a-deadtime-filtered-streaminitially-no-deadtime">Create a
deadtime filtered stream—initially no deadtime</h2>
<p>In this recipe we'll just filter the direct <code>engineTemp</code>
sensor reading stream. In practice this filtering would be performed after some
analytics stages and used as the input to <code>IotDevice.event()</code> or
some other connector publish operation.</p>
<div class="highlight"><pre><code class="language-java" data-lang="java"><span
class="n">Deadtime</span><span class="o"><</span><span
class="n">Double</span><span class="o">></span> <span
class="n">deadtime</span> <span class="o">=</span> <span class="k">new</span>
<span class="n">Deadtime</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">deadtimeFilteredEngineTemp</span> <span class="o">=</span> <span
class="n">engineTemp</span><span class="o">.</span><span
class="na">filter</span><span class="o">(</span><span
class="n">deadtime</span><span class="o">)</span>
<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="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">perio [...]
+<h2 id="define-a-set-deadtime-period-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">peri [...]
<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>
</code></pre></div>
-<h2 id="process-the-quot-set-deadtime-period-quot-command-stream">Process the
"set deadtime period" command stream</h2>
+<h2 id="process-the-set-deadtime-period-command-stream">Process the "set
deadtime period" command stream</h2>
<p>Our commands are on the <code>TStream<JsonObject> cmds</code> stream.
Each <code>JsonObject</code> tuple is a command with the properties
"period" and "unit".</p>
<div class="highlight"><pre><code class="language-java" data-lang="java"><span
class="n">cmds</span><span class="o">.</span><span class="na">sink</span><span
class="o">(</span><span class="n">json</span> <span class="o">-></span>
<span class="n">setDeadtimePeriod</span><span class="o">(</span><span
class="n">deadtimeFilteredEngineTemp</span><span class="o">,</span>
@@ -767,7 +767,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="n">main</span><span class="o">(</span><span
class="n">String</span><span class="o">[]</span> <span
class="n">args</span><span class="o">)</span> <span class="kd">throws</span>
<span class="n">Exception</span> <span class="o">{</span>
+ <span class="kd">public</span> <span class="kd">static</span> <span
class="kt">void</span> <span class="nf">main</span><span
class="o">(</span><span class="n">String</span><span class="o">[]</span> <span
class="n">args</span><span class="o">)</span> <span class="kd">throws</span>
<span class="n">Exception</span> <span class="o">{</span>
<span class="n">DirectProvider</span> <span class="n">dp</span> <span
class="o">=</span> <span class="k">new</span> <span
class="n">DevelopmentProvider</span><span class="o">();</span>
<span class="n">System</span><span class="o">.</span><span
class="na">out</span><span class="o">.</span><span
class="na">println</span><span class="o">(</span><span class="s">"development
console url: "</span>
@@ -801,12 +801,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="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> <spa [...]
+ <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> <sp [...]
<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="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="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="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>
@@ -859,7 +859,7 @@ $('#toc').on('click', 'a', function() {
<div class="col-lg-12 footer">
Site last
- generated: Dec 18, 2017 <br/>
+ generated: Apr 3, 2019 <br/>
</div>
</div>
diff --git a/content/recipes/recipe_adaptable_filter_range.html
b/content/recipes/recipe_adaptable_filter_range.html
index d5532de..2411d39 100644
--- a/content/recipes/recipe_adaptable_filter_range.html
+++ b/content/recipes/recipe_adaptable_filter_range.html
@@ -710,7 +710,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="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>
+<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>
<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>
@@ -756,7 +756,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="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="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="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>
@@ -766,7 +766,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="n">main</span><span class="o">(</span><span
class="n">String</span><span class="o">[]</span> <span
class="n">args</span><span class="o">)</span> <span class="kd">throws</span>
<span class="n">Exception</span> <span class="o">{</span>
+ <span class="kd">public</span> <span class="kd">static</span> <span
class="kt">void</span> <span class="nf">main</span><span
class="o">(</span><span class="n">String</span><span class="o">[]</span> <span
class="n">args</span><span class="o">)</span> <span class="kd">throws</span>
<span class="n">Exception</span> <span class="o">{</span>
<span class="n">DirectProvider</span> <span class="n">dp</span> <span
class="o">=</span> <span class="k">new</span> <span
class="n">DirectProvider</span><span class="o">();</span>
@@ -833,7 +833,7 @@ $('#toc').on('click', 'a', function() {
<div class="col-lg-12 footer">
Site last
- generated: Dec 18, 2017 <br/>
+ generated: Apr 3, 2019 <br/>
</div>
</div>
diff --git a/content/recipes/recipe_adaptable_polling_source.html
b/content/recipes/recipe_adaptable_polling_source.html
index 7994d3c..d04b008 100644
--- a/content/recipes/recipe_adaptable_polling_source.html
+++ b/content/recipes/recipe_adaptable_polling_source.html
@@ -713,8 +713,8 @@ $('#toc').on('click', 'a', function() {
</code></pre></div>
<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="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</ [...]
+<h2 id="define-a-set-poll-period-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 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>
@@ -727,7 +727,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>
</code></pre></div>
-<h2 id="process-the-quot-set-poll-period-quot-command-stream">Process the
"set poll period" command stream</h2>
+<h2 id="process-the-set-poll-period-command-stream">Process the "set poll
period" command stream</h2>
<p>Our commands are on the <code>TStream<JsonObject> cmds</code> stream.
Each <code>JsonObject</code> tuple is a command with the properties
"period" and "unit".</p>
<div class="highlight"><pre><code class="language-java" data-lang="java"><span
class="n">cmds</span><span class="o">.</span><span class="na">sink</span><span
class="o">(</span><span class="n">json</span> <span class="o">-></span>
<span class="n">setPollPeriod</span><span class="o">(</span><span
class="n">engineTemp</span><span class="o">,</span>
@@ -758,7 +758,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="n">main</span><span class="o">(</span><span
class="n">String</span><span class="o">[]</span> <span
class="n">args</span><span class="o">)</span> <span class="kd">throws</span>
<span class="n">Exception</span> <span class="o">{</span>
+ <span class="kd">public</span> <span class="kd">static</span> <span
class="kt">void</span> <span class="nf">main</span><span
class="o">(</span><span class="n">String</span><span class="o">[]</span> <span
class="n">args</span><span class="o">)</span> <span class="kd">throws</span>
<span class="n">Exception</span> <span class="o">{</span>
<span class="n">DirectProvider</span> <span class="n">dp</span> <span
class="o">=</span> <span class="k">new</span> <span
class="n">DirectProvider</span><span class="o">();</span>
@@ -784,7 +784,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="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 c [...]
+ <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 [...]
<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>
@@ -797,7 +797,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="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="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="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>
@@ -845,7 +845,7 @@ $('#toc').on('click', 'a', function() {
<div class="col-lg-12 footer">
Site last
- generated: Dec 18, 2017 <br/>
+ generated: Apr 3, 2019 <br/>
</div>
</div>
diff --git a/content/recipes/recipe_combining_streams_processing_results.html
b/content/recipes/recipe_combining_streams_processing_results.html
index 9e688b3..77ec272 100644
--- a/content/recipes/recipe_combining_streams_processing_results.html
+++ b/content/recipes/recipe_combining_streams_processing_results.html
@@ -716,7 +716,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="n">HeartMonitorSensor</span><span class="o">()</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="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>
@@ -725,7 +725,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="n">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="nf">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>
@@ -756,7 +756,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="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="kd">public</span> <span class="kd">static</span> <span
class="kt">void</span> <span class="nf">main</span><span
class="o">(</span><span class="n">String</span><span class="o">[]</span> <span
class="n">args</span><span class="o">)</span> <span class="o">{</span>
<span class="n">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>
@@ -781,7 +781,7 @@ $('#toc').on('click', 'a', function() {
<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="/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">ToI [...]
+<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">To [...]
</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>
@@ -964,7 +964,7 @@ EMERGENCY! SEE TO PATIENT IMMEDIATELY!
<div class="col-lg-12 footer">
Site last
- generated: Dec 18, 2017 <br/>
+ generated: Apr 3, 2019 <br/>
</div>
</div>
diff --git a/content/recipes/recipe_concurrent_analytics.html
b/content/recipes/recipe_concurrent_analytics.html
index f19dc41..d78388b 100644
--- a/content/recipes/recipe_concurrent_analytics.html
+++ b/content/recipes/recipe_concurrent_analytics.html
@@ -742,7 +742,7 @@ stream -> |-> isolate(1) -> pipeline2 -> |->
barrier(10) -> co
<p>In this recipe we'll just define some very simple pipelines and use
sleep to simulate some long processing times.</p>
<p>Here's the A3 pipeline builder:</p>
-<div class="highlight"><pre><code class="language-java" data-lang="java"><span
class="kd">static</span> <span class="n">Function</span><span
class="o"><</span><span class="n">TStream</span><span
class="o"><</span><span class="n">Double</span><span
class="o">>,</span><span class="n">TStream</span><span
class="o"><</span><span class="n">String</span><span
class="o">>></span> <span class="n">a3pipeline</span><span
class="o">()</span> <span class="o">{</span>
+<div class="highlight"><pre><code class="language-java" data-lang="java"><span
class="kd">static</span> <span class="n">Function</span><span
class="o"><</span><span class="n">TStream</span><span
class="o"><</span><span class="n">Double</span><span
class="o">>,</span><span class="n">TStream</span><span
class="o"><</span><span class="n">String</span><span
class="o">>></span> <span class="nf">a3pipeline</span><span
class="o">()</span> <span class="o">{</span>
<span class="c1">// simple 3 stage pipeline simulating some amount of work
by sleeping</span>
<span class="k">return</span> <span class="n">stream</span> <span
class="o">-></span> <span class="n">stream</span><span
class="o">.</span><span class="na">map</span><span class="o">(</span><span
class="n">tuple</span> <span class="o">-></span> <span class="o">{</span>
<span class="n">sleep</span><span class="o">(</span><span
class="mi">800</span><span class="o">,</span> <span
class="n">TimeUnit</span><span class="o">.</span><span
class="na">MILLISECONDS</span><span class="o">);</span>
@@ -781,7 +781,7 @@ stream -> |-> isolate(1) -> pipeline2 -> |->
barrier(10) -> co
* Concurrently run a collection of long running independent
* analytic pipelines on each tuple.
*/</span>
- <span class="kd">public</span> <span class="kd">static</span> <span
class="kt">void</span> <span class="n">main</span><span class="o">(</span><span
class="n">String</span><span class="o">[]</span> <span
class="n">args</span><span class="o">)</span> <span class="kd">throws</span>
<span class="n">Exception</span> <span class="o">{</span>
+ <span class="kd">public</span> <span class="kd">static</span> <span
class="kt">void</span> <span class="nf">main</span><span
class="o">(</span><span class="n">String</span><span class="o">[]</span> <span
class="n">args</span><span class="o">)</span> <span class="kd">throws</span>
<span class="n">Exception</span> <span class="o">{</span>
<span class="n">DirectProvider</span> <span class="n">dp</span> <span
class="o">=</span> <span class="k">new</span> <span
class="n">DevelopmentProvider</span><span class="o">();</span>
<span class="n">System</span><span class="o">.</span><span
class="na">out</span><span class="o">.</span><span
class="na">println</span><span class="o">(</span><span class="s">"development
console url: "</span>
@@ -820,7 +820,7 @@ stream -> |-> isolate(1) -> pipeline2 -> |->
barrier(10) -> co
<span class="o">}</span>
<span class="cm">/** Function to create analytic pipeline a1 and add it to
a stream */</span>
- <span class="kd">private</span> <span class="kd">static</span> <span
class="n">Function</span><span class="o"><</span><span
class="n">TStream</span><span class="o"><</span><span
class="n">Double</span><span class="o">>,</span><span
class="n">TStream</span><span class="o"><</span><span
class="n">String</span><span class="o">>></span> <span
class="n">a1pipeline</span><span class="o">()</span> <span class="o">{</span>
+ <span class="kd">private</span> <span class="kd">static</span> <span
class="n">Function</span><span class="o"><</span><span
class="n">TStream</span><span class="o"><</span><span
class="n">Double</span><span class="o">>,</span><span
class="n">TStream</span><span class="o"><</span><span
class="n">String</span><span class="o">>></span> <span
class="nf">a1pipeline</span><span class="o">()</span> <span class="o">{</span>
<span class="c1">// a simple 1 stage pipeline simulating some amount
of work by sleeping</span>
<span class="k">return</span> <span class="n">stream</span> <span
class="o">-></span> <span class="n">stream</span><span
class="o">.</span><span class="na">map</span><span class="o">(</span><span
class="n">tuple</span> <span class="o">-></span> <span class="o">{</span>
<span class="n">sleep</span><span class="o">(</span><span
class="mi">800</span><span class="o">,</span> <span
class="n">TimeUnit</span><span class="o">.</span><span
class="na">MILLISECONDS</span><span class="o">);</span>
@@ -829,7 +829,7 @@ stream -> |-> isolate(1) -> pipeline2 -> |->
barrier(10) -> co
<span class="o">}</span>
<span class="cm">/** Function to create analytic pipeline a2 and add it to
a stream */</span>
- <span class="kd">private</span> <span class="kd">static</span> <span
class="n">Function</span><span class="o"><</span><span
class="n">TStream</span><span class="o"><</span><span
class="n">Double</span><span class="o">>,</span><span
class="n">TStream</span><span class="o"><</span><span
class="n">String</span><span class="o">>></span> <span
class="n">a2pipeline</span><span class="o">()</span> <span class="o">{</span>
+ <span class="kd">private</span> <span class="kd">static</span> <span
class="n">Function</span><span class="o"><</span><span
class="n">TStream</span><span class="o"><</span><span
class="n">Double</span><span class="o">>,</span><span
class="n">TStream</span><span class="o"><</span><span
class="n">String</span><span class="o">>></span> <span
class="nf">a2pipeline</span><span class="o">()</span> <span class="o">{</span>
<span class="c1">// a simple 2 stage pipeline simulating some amount
of work by sleeping</span>
<span class="k">return</span> <span class="n">stream</span> <span
class="o">-></span> <span class="n">stream</span><span
class="o">.</span><span class="na">map</span><span class="o">(</span><span
class="n">tuple</span> <span class="o">-></span> <span class="o">{</span>
<span class="n">sleep</span><span class="o">(</span><span
class="mi">800</span><span class="o">,</span> <span
class="n">TimeUnit</span><span class="o">.</span><span
class="na">MILLISECONDS</span><span class="o">);</span>
@@ -839,7 +839,7 @@ stream -> |-> isolate(1) -> pipeline2 -> |->
barrier(10) -> co
<span class="o">}</span>
<span class="cm">/** Function to create analytic pipeline a3 and add it to
a stream */</span>
- <span class="kd">private</span> <span class="kd">static</span> <span
class="n">Function</span><span class="o"><</span><span
class="n">TStream</span><span class="o"><</span><span
class="n">Double</span><span class="o">>,</span><span
class="n">TStream</span><span class="o"><</span><span
class="n">String</span><span class="o">>></span> <span
class="n">a3pipeline</span><span class="o">()</span> <span class="o">{</span>
+ <span class="kd">private</span> <span class="kd">static</span> <span
class="n">Function</span><span class="o"><</span><span
class="n">TStream</span><span class="o"><</span><span
class="n">Double</span><span class="o">>,</span><span
class="n">TStream</span><span class="o"><</span><span
class="n">String</span><span class="o">>></span> <span
class="nf">a3pipeline</span><span class="o">()</span> <span class="o">{</span>
<span class="c1">// a simple 3 stage pipeline simulating some amount
of work by sleeping</span>
<span class="k">return</span> <span class="n">stream</span> <span
class="o">-></span> <span class="n">stream</span><span
class="o">.</span><span class="na">map</span><span class="o">(</span><span
class="n">tuple</span> <span class="o">-></span> <span class="o">{</span>
<span class="n">sleep</span><span class="o">(</span><span
class="mi">800</span><span class="o">,</span> <span
class="n">TimeUnit</span><span class="o">.</span><span
class="na">MILLISECONDS</span><span class="o">);</span>
@@ -849,11 +849,11 @@ stream -> |-> isolate(1) -> pipeline2 ->
|-> barrier(10) -> co
<span class="o">.</span><span class="na">map</span><span
class="o">(</span><span class="n">Functions</span><span class="o">.</span><span
class="na">identity</span><span class="o">()).</span><span
class="na">tag</span><span class="o">(</span><span
class="s">"a3.stage3"</span><span class="o">);</span>
<span class="o">}</span>
- <span class="kd">private</span> <span class="kd">static</span> <span
class="kt">void</span> <span class="n">sleep</span><span
class="o">(</span><span class="kt">long</span> <span
class="n">period</span><span class="o">,</span> <span class="n">TimeUnit</span>
<span class="n">unit</span><span class="o">)</span> <span
class="kd">throws</span> <span class="n">RuntimeException</span> <span
class="o">{</span>
+ <span class="kd">private</span> <span class="kd">static</span> <span
class="kt">void</span> <span class="nf">sleep</span><span
class="o">(</span><span class="kt">long</span> <span
class="n">period</span><span class="o">,</span> <span class="n">TimeUnit</span>
<span class="n">unit</span><span class="o">)</span> <span
class="kd">throws</span> <span class="n">RuntimeException</span> <span
class="o">{</span>
<span class="k">try</span> <span class="o">{</span>
<span class="n">Thread</span><span class="o">.</span><span
class="na">sleep</span><span class="o">(</span><span class="n">unit</span><span
class="o">.</span><span class="na">toMillis</span><span class="o">(</span><span
class="n">period</span><span class="o">));</span>
<span class="o">}</span> <span class="k">catch</span> <span
class="o">(</span><span class="n">InterruptedException</span> <span
class="n">e</span><span class="o">)</span> <span class="o">{</span>
- <span class="k">throw</span> <span class="k">new</span> <span
class="n">RuntimeException</span><span class="o">(</span><span
class="s">"Interrupted"</span><span class="o">,</span> <span
class="n">e</span><span class="o">);</span>
+ <span class="k">throw</span> <span class="k">new</span> <span
class="nf">RuntimeException</span><span class="o">(</span><span
class="s">"Interrupted"</span><span class="o">,</span> <span
class="n">e</span><span class="o">);</span>
<span class="o">}</span>
<span class="o">}</span>
@@ -891,7 +891,7 @@ stream -> |-> isolate(1) -> pipeline2 -> |->
barrier(10) -> co
<div class="col-lg-12 footer">
Site last
- generated: Dec 18, 2017 <br/>
+ generated: Apr 3, 2019 <br/>
</div>
</div>
diff --git a/content/recipes/recipe_different_processing_against_stream.html
b/content/recipes/recipe_different_processing_against_stream.html
index 1672bac..7f0d6be 100644
--- a/content/recipes/recipe_different_processing_against_stream.html
+++ b/content/recipes/recipe_different_processing_against_stream.html
@@ -729,7 +729,7 @@ $('#toc').on('click', 'a', function() {
*/</span>
<span class="kd">static</span> <span class="kt">double</span> <span
class="n">ROUTE_MILES</span> <span class="o">=</span> <span
class="mi">80</span><span class="o">;</span>
- <span class="kd">public</span> <span class="kd">static</span> <span
class="kt">void</span> <span class="n">main</span><span class="o">(</span><span
class="n">String</span><span class="o">[]</span> <span
class="n">args</span><span class="o">)</span> <span class="kd">throws</span>
<span class="n">Exception</span> <span class="o">{</span>
+ <span class="kd">public</span> <span class="kd">static</span> <span
class="kt">void</span> <span class="nf">main</span><span
class="o">(</span><span class="n">String</span><span class="o">[]</span> <span
class="n">args</span><span class="o">)</span> <span class="kd">throws</span>
<span class="n">Exception</span> <span class="o">{</span>
<span class="n">DirectProvider</span> <span class="n">dp</span> <span
class="o">=</span> <span class="k">new</span> <span
class="n">DevelopmentProvider</span><span class="o">();</span>
@@ -843,7 +843,7 @@ Gallons of gas: 9.1
* gas mileage readings (in miles/gallon). Feed the stream of sensor
* readings to different functions (filter, map, and modify).
*/</span>
- <span class="kd">public</span> <span class="kd">static</span> <span
class="kt">void</span> <span class="n">main</span><span class="o">(</span><span
class="n">String</span><span class="o">[]</span> <span
class="n">args</span><span class="o">)</span> <span class="kd">throws</span>
<span class="n">Exception</span> <span class="o">{</span>
+ <span class="kd">public</span> <span class="kd">static</span> <span
class="kt">void</span> <span class="nf">main</span><span
class="o">(</span><span class="n">String</span><span class="o">[]</span> <span
class="n">args</span><span class="o">)</span> <span class="kd">throws</span>
<span class="n">Exception</span> <span class="o">{</span>
<span class="n">DirectProvider</span> <span class="n">dp</span> <span
class="o">=</span> <span class="k">new</span> <span
class="n">DevelopmentProvider</span><span class="o">();</span>
@@ -913,7 +913,7 @@ Gallons of gas: 9.1
<div class="col-lg-12 footer">
Site last
- generated: Dec 18, 2017 <br/>
+ generated: Apr 3, 2019 <br/>
</div>
</div>
diff --git a/content/recipes/recipe_dynamic_analytic_control.html
b/content/recipes/recipe_dynamic_analytic_control.html
index 9ac8dbc..4cfaa77 100644
--- a/content/recipes/recipe_dynamic_analytic_control.html
+++ b/content/recipes/recipe_dynamic_analytic_control.html
@@ -765,7 +765,7 @@ $('#toc').on('click', 'a', function() {
<div class="col-lg-12 footer">
Site last
- generated: Dec 18, 2017 <br/>
+ generated: Apr 3, 2019 <br/>
</div>
</div>
diff --git a/content/recipes/recipe_external_filter_range.html
b/content/recipes/recipe_external_filter_range.html
index ad00e0e..31db26a 100644
--- a/content/recipes/recipe_external_filter_range.html
+++ b/content/recipes/recipe_external_filter_range.html
@@ -749,7 +749,7 @@ optimalTempRange=[77.0..91.0]
<span class="kd">static</span> <span class="n">Range</span><span
class="o"><</span><span class="n">Double</span><span class="o">></span>
<span class="n">optimalTempRange</span><span class="o">;</span>
<span class="cm">/** Initialize the application's configuration */</span>
- <span class="kd">static</span> <span class="kt">void</span> <span
class="n">initializeConfiguration</span><span class="o">(</span><span
class="n">String</span> <span class="n">configFilePath</span><span
class="o">)</span> <span class="kd">throws</span> <span
class="n">Exception</span> <span class="o">{</span>
+ <span class="kd">static</span> <span class="kt">void</span> <span
class="nf">initializeConfiguration</span><span class="o">(</span><span
class="n">String</span> <span class="n">configFilePath</span><span
class="o">)</span> <span class="kd">throws</span> <span
class="n">Exception</span> <span class="o">{</span>
<span class="c1">// Load the configuration file</span>
<span class="n">Properties</span> <span class="n">props</span> <span
class="o">=</span> <span class="k">new</span> <span
class="n">Properties</span><span class="o">();</span>
<span class="n">props</span><span class="o">.</span><span
class="na">load</span><span class="o">(</span><span class="n">Files</span><span
class="o">.</span><span class="na">newBufferedReader</span><span
class="o">(</span><span class="k">new</span> <span class="n">File</span><span
class="o">(</span><span class="n">configFilePath</span><span
class="o">).</span><span class="na">toPath</span><span class="o">()));</span>
@@ -766,9 +766,9 @@ optimalTempRange=[77.0..91.0]
* temperature readings (in Fahrenheit). Use a simple filter
* to determine when the temperature is out of the optimal range.
*/</span>
- <span class="kd">public</span> <span class="kd">static</span> <span
class="kt">void</span> <span class="n">main</span><span class="o">(</span><span
class="n">String</span><span class="o">[]</span> <span
class="n">args</span><span class="o">)</span> <span class="kd">throws</span>
<span class="n">Exception</span> <span class="o">{</span>
+ <span class="kd">public</span> <span class="kd">static</span> <span
class="kt">void</span> <span class="nf">main</span><span
class="o">(</span><span class="n">String</span><span class="o">[]</span> <span
class="n">args</span><span class="o">)</span> <span class="kd">throws</span>
<span class="n">Exception</span> <span class="o">{</span>
<span class="k">if</span> <span class="o">(</span><span
class="n">args</span><span class="o">.</span><span class="na">length</span>
<span class="o">!=</span> <span class="mi">1</span><span class="o">)</span>
- <span class="k">throw</span> <span class="k">new</span> <span
class="n">Exception</span><span class="o">(</span><span class="s">"missing
pathname to configuration file"</span><span class="o">);</span>
+ <span class="k">throw</span> <span class="k">new</span> <span
class="nf">Exception</span><span class="o">(</span><span class="s">"missing
pathname to configuration file"</span><span class="o">);</span>
<span class="n">String</span> <span class="n">configFilePath</span>
<span class="o">=</span> <span class="n">args</span><span
class="o">[</span><span class="mi">0</span><span class="o">];</span>
<span class="n">DirectProvider</span> <span class="n">dp</span> <span
class="o">=</span> <span class="k">new</span> <span
class="n">DirectProvider</span><span class="o">();</span>
@@ -827,7 +827,7 @@ optimalTempRange=[77.0..91.0]
<div class="col-lg-12 footer">
Site last
- generated: Dec 18, 2017 <br/>
+ generated: Apr 3, 2019 <br/>
</div>
</div>
diff --git a/content/recipes/recipe_hello_edgent.html
b/content/recipes/recipe_hello_edgent.html
index 393be0c..31af852 100644
--- a/content/recipes/recipe_hello_edgent.html
+++ b/content/recipes/recipe_hello_edgent.html
@@ -693,7 +693,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-get [...]
-<div class="highlight"><pre><code class="language-java" data-lang="java"><span
class="kd">public</span> <span class="kd">static</span> <span
class="kt">void</span> <span class="nf">main</span><span
class="p">(</span><span class="n">String</span><span class="o">[]</span> <span
class="n">args</span><span class="o">)</span> <span class="o">{</span>
+<div class="highlight"><pre><code class="language-java" data-lang="java"><span
class="kd">public</span> <span class="kd">static</span> <span
class="kt">void</span> <span class="nf">main</span><span
class="o">(</span><span class="n">String</span><span class="o">[]</span> <span
class="n">args</span><span class="o">)</span> <span class="o">{</span>
<span class="n">DirectProvider</span> <span class="n">dp</span> <span
class="o">=</span> <span class="k">new</span> <span
class="n">DirectProvider</span><span class="o">();</span>
@@ -705,7 +705,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 sim [...]
-<div class="highlight"><pre><code class="language-java" data-lang="java"><span
class="kd">public</span> <span class="kd">static</span> <span
class="kt">void</span> <span class="nf">main</span><span
class="p">(</span><span class="n">String</span><span class="o">[]</span> <span
class="n">args</span><span class="o">)</span> <span class="o">{</span>
+<div class="highlight"><pre><code class="language-java" data-lang="java"><span
class="kd">public</span> <span class="kd">static</span> <span
class="kt">void</span> <span class="nf">main</span><span
class="o">(</span><span class="n">String</span><span class="o">[]</span> <span
class="n">args</span><span class="o">)</span> <span class="o">{</span>
<span class="n">DirectProvider</span> <span class="n">dp</span> <span
class="o">=</span> <span class="k">new</span> <span
class="n">DirectProvider</span><span class="o">();</span>
@@ -719,7 +719,7 @@ $('#toc').on('click', 'a', function() {
<h2 id="printing-to-output">Printing to output</h2>
<p><code>TStream.print()</code> can be used to print the data items of a
stream to standard output by invoking the <code>toString()</code> method of
each data item. In this case the data items are already strings, but in
principle <code>TStream.print()</code> can be called on any stream, regardless
of the datatype carried by the stream.</p>
-<div class="highlight"><pre><code class="language-java" data-lang="java"><span
class="kd">public</span> <span class="kd">static</span> <span
class="kt">void</span> <span class="nf">main</span><span
class="p">(</span><span class="n">String</span><span class="o">[]</span> <span
class="n">args</span><span class="o">)</span> <span class="o">{</span>
+<div class="highlight"><pre><code class="language-java" data-lang="java"><span
class="kd">public</span> <span class="kd">static</span> <span
class="kt">void</span> <span class="nf">main</span><span
class="o">(</span><span class="n">String</span><span class="o">[]</span> <span
class="n">args</span><span class="o">)</span> <span class="o">{</span>
<span class="n">DirectProvider</span> <span class="n">dp</span> <span
class="o">=</span> <span class="k">new</span> <span
class="n">DirectProvider</span><span class="o">();</span>
@@ -733,7 +733,7 @@ $('#toc').on('click', 'a', function() {
<h2 id="submitting-the-application">Submitting the application</h2>
<p>The only remaining step is to submit the application, which is performed by
the <code>DirectProvider</code>. Submitting an Edgent application initializes
the threads which execute the <code>Topology</code>, and begins processing its
data sources.</p>
-<div class="highlight"><pre><code class="language-java" data-lang="java"><span
class="kd">public</span> <span class="kd">static</span> <span
class="kt">void</span> <span class="nf">main</span><span
class="p">(</span><span class="n">String</span><span class="o">[]</span> <span
class="n">args</span><span class="o">)</span> <span class="o">{</span>
+<div class="highlight"><pre><code class="language-java" data-lang="java"><span
class="kd">public</span> <span class="kd">static</span> <span
class="kt">void</span> <span class="nf">main</span><span
class="o">(</span><span class="n">String</span><span class="o">[]</span> <span
class="n">args</span><span class="o">)</span> <span class="o">{</span>
<span class="n">DirectProvider</span> <span class="n">dp</span> <span
class="o">=</span> <span class="k">new</span> <span
class="n">DirectProvider</span><span class="o">();</span>
@@ -781,7 +781,7 @@ Edgent!
<div class="col-lg-12 footer">
Site last
- generated: Dec 18, 2017 <br/>
+ generated: Apr 3, 2019 <br/>
</div>
</div>
diff --git a/content/recipes/recipe_parallel_analytics.html
b/content/recipes/recipe_parallel_analytics.html
index 7087282..3e5dd2e 100644
--- a/content/recipes/recipe_parallel_analytics.html
+++ b/content/recipes/recipe_parallel_analytics.html
@@ -739,7 +739,7 @@ stream -> split(width,splitter) -> |-> isolate(10)
-> pipeline-ch1 -
<p>Many pipelines don't care what channel they're being constructed
for. While the pipeline function typically yields the same pipeline processing
for each channel there is no requirement for it to do so.</p>
<p>In this simple recipe the pipeline receives a
<code>TStream<Double></code> as input and generates a
<code>TStream<String></code> as output.</p>
-<div class="highlight"><pre><code class="language-java" data-lang="java"><span
class="kd">static</span> <span class="n">BiFunction</span><span
class="o"><</span><span class="n">TStream</span><span
class="o"><</span><span class="n">Double</span><span class="o">>,</span>
<span class="n">Integer</span><span class="o">,</span> <span
class="n">TStream</span><span class="o"><</span><span
class="n">String</span><span class="o">>></span> <span
class="n">pipeline</span><span cla [...]
+<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 cl [...]
<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>
@@ -792,7 +792,7 @@ stream -> split(width,splitter) -> |-> isolate(10)
-> pipeline-ch1 -
<span class="cm">/**
* Process several tuples in parallel in a replicated pipeline.
*/</span>
- <span class="kd">public</span> <span class="kd">static</span> <span
class="kt">void</span> <span class="n">main</span><span class="o">(</span><span
class="n">String</span><span class="o">[]</span> <span
class="n">args</span><span class="o">)</span> <span class="kd">throws</span>
<span class="n">Exception</span> <span class="o">{</span>
+ <span class="kd">public</span> <span class="kd">static</span> <span
class="kt">void</span> <span class="nf">main</span><span
class="o">(</span><span class="n">String</span><span class="o">[]</span> <span
class="n">args</span><span class="o">)</span> <span class="kd">throws</span>
<span class="n">Exception</span> <span class="o">{</span>
<span class="n">DirectProvider</span> <span class="n">dp</span> <span
class="o">=</span> <span class="k">new</span> <span
class="n">DevelopmentProvider</span><span class="o">();</span>
<span class="n">System</span><span class="o">.</span><span
class="na">out</span><span class="o">.</span><span
class="na">println</span><span class="o">(</span><span class="s">"development
console url: "</span>
@@ -825,7 +825,7 @@ stream -> split(width,splitter) -> |-> isolate(10)
-> pipeline-ch1 -
<span class="o">}</span>
<span class="cm">/** Function to create analytic pipeline and add it to a
stream */</span>
- <span class="kd">private</span> <span class="kd">static</span> <span
class="n">BiFunction</span><span class="o"><</span><span
class="n">TStream</span><span class="o"><</span><span
class="n">Double</span><span class="o">>,</span><span
class="n">Integer</span><span class="o">,</span><span
class="n">TStream</span><span class="o"><</span><span
class="n">String</span><span class="o">>></span> <span
class="n">pipeline</span><span class="o">()</span> <span class="o">{</span>
+ <span class="kd">private</span> <span class="kd">static</span> <span
class="n">BiFunction</span><span class="o"><</span><span
class="n">TStream</span><span class="o"><</span><span
class="n">Double</span><span class="o">>,</span><span
class="n">Integer</span><span class="o">,</span><span
class="n">TStream</span><span class="o"><</span><span
class="n">String</span><span class="o">>></span> <span
class="nf">pipeline</span><span class="o">()</span> <span class="o">{</span>
<span class="c1">// a simple 3 stage pipeline simulating some amount
of work by sleeping</span>
<span class="k">return</span> <span class="o">(</span><span
class="n">stream</span><span class="o">,</span> <span
class="n">channel</span><span class="o">)</span> <span class="o">-></span>
<span class="o">{</span>
@@ -839,11 +839,11 @@ stream -> split(width,splitter) -> |->
isolate(10) -> pipeline-ch1 -
<span class="o">};</span>
<span class="o">}</span>
- <span class="kd">private</span> <span class="kd">static</span> <span
class="kt">void</span> <span class="n">sleep</span><span
class="o">(</span><span class="kt">long</span> <span
class="n">period</span><span class="o">,</span> <span class="n">TimeUnit</span>
<span class="n">unit</span><span class="o">)</span> <span
class="kd">throws</span> <span class="n">RuntimeException</span> <span
class="o">{</span>
+ <span class="kd">private</span> <span class="kd">static</span> <span
class="kt">void</span> <span class="nf">sleep</span><span
class="o">(</span><span class="kt">long</span> <span
class="n">period</span><span class="o">,</span> <span class="n">TimeUnit</span>
<span class="n">unit</span><span class="o">)</span> <span
class="kd">throws</span> <span class="n">RuntimeException</span> <span
class="o">{</span>
<span class="k">try</span> <span class="o">{</span>
<span class="n">Thread</span><span class="o">.</span><span
class="na">sleep</span><span class="o">(</span><span class="n">unit</span><span
class="o">.</span><span class="na">toMillis</span><span class="o">(</span><span
class="n">period</span><span class="o">));</span>
<span class="o">}</span> <span class="k">catch</span> <span
class="o">(</span><span class="n">InterruptedException</span> <span
class="n">e</span><span class="o">)</span> <span class="o">{</span>
- <span class="k">throw</span> <span class="k">new</span> <span
class="n">RuntimeException</span><span class="o">(</span><span
class="s">"Interrupted"</span><span class="o">,</span> <span
class="n">e</span><span class="o">);</span>
+ <span class="k">throw</span> <span class="k">new</span> <span
class="nf">RuntimeException</span><span class="o">(</span><span
class="s">"Interrupted"</span><span class="o">,</span> <span
class="n">e</span><span class="o">);</span>
<span class="o">}</span>
<span class="o">}</span>
@@ -880,7 +880,7 @@ stream -> split(width,splitter) -> |-> isolate(10)
-> pipeline-ch1 -
<div class="col-lg-12 footer">
Site last
- generated: Dec 18, 2017 <br/>
+ generated: Apr 3, 2019 <br/>
</div>
</div>
diff --git a/content/recipes/recipe_source_function.html
b/content/recipes/recipe_source_function.html
index 1125227..2db9c5c 100644
--- a/content/recipes/recipe_source_function.html
+++ b/content/recipes/recipe_source_function.html
@@ -699,7 +699,7 @@ $('#toc').on('click', 'a', function() {
<div class="alert alert-info" role="alert"><i class="fa fa-info-circle"></i>
<b>Note: </b> Edgent's API provides convenience methods for performing HTTP
requests. For the sake of example we are writing a HTTP data source manually,
but in principle there are easier methods. </div>
<p>One example of a custom data source could be retrieving the contents of a
web page and printing each line to output. For example, the user could be
querying the Yahoo Finance website for the most recent stock price data of Bank
of America, Cabot Oil & Gas, and Freeport-McMoRan Inc.:</p>
-<div class="highlight"><pre><code class="language-java" data-lang="java"><span
class="kd">public</span> <span class="kd">static</span> <span
class="kt">void</span> <span class="nf">main</span><span
class="p">(</span><span class="n">String</span><span class="o">[]</span> <span
class="n">args</span><span class="o">)</span> <span class="kd">throws</span>
<span class="n">Exception</span> <span class="o">{</span>
+<div class="highlight"><pre><code class="language-java" data-lang="java"><span
class="kd">public</span> <span class="kd">static</span> <span
class="kt">void</span> <span class="nf">main</span><span
class="o">(</span><span class="n">String</span><span class="o">[]</span> <span
class="n">args</span><span class="o">)</span> <span class="kd">throws</span>
<span class="n">Exception</span> <span class="o">{</span>
<span class="n">DirectProvider</span> <span class="n">dp</span> <span
class="o">=</span> <span class="k">new</span> <span
class="n">DirectProvider</span><span class="o">();</span>
<span class="n">Topology</span> <span class="n">top</span> <span
class="o">=</span> <span class="n">dp</span><span class="o">.</span><span
class="na">newTopology</span><span class="o">();</span>
@@ -713,7 +713,7 @@ $('#toc').on('click', 'a', function() {
<span class="k">try</span> <span class="o">{</span>
<span class="n">InputStream</span> <span class="n">is</span> <span
class="o">=</span> <span class="n">url</span><span class="o">.</span><span
class="na">openStream</span><span class="o">();</span>
<span class="n">BufferedReader</span> <span class="n">br</span>
<span class="o">=</span> <span class="k">new</span> <span
class="n">BufferedReader</span><span class="o">(</span>
- <span class="k">new</span> <span
class="n">InputStreamReader</span><span class="o">(</span><span
class="n">is</span><span class="o">));</span>
+ <span class="k">new</span> <span
class="nf">InputStreamReader</span><span class="o">(</span><span
class="n">is</span><span class="o">));</span>
<span class="k">for</span><span class="o">(</span><span
class="n">String</span> <span class="n">s</span> <span class="o">=</span> <span
class="n">br</span><span class="o">.</span><span
class="na">readLine</span><span class="o">();</span> <span class="n">s</span>
<span class="o">!=</span> <span class="kc">null</span><span class="o">;</span>
<span class="n">s</span> <span class="o">=</span> <span
class="n">br</span><span class="o">.</span><span
class="na">readLine</span><span c [...]
<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>
@@ -726,7 +726,7 @@ $('#toc').on('click', 'a', function() {
<span class="o">}</span>
</code></pre></div>
<p>When invoking <code>Topology.source()</code>, we can use
<code>queryWebsite</code> to return the required supplier, passing in the
URL.</p>
-<div class="highlight"><pre><code class="language-java" data-lang="java"><span
class="kd">public</span> <span class="kd">static</span> <span
class="kt">void</span> <span class="nf">main</span><span
class="p">(</span><span class="n">String</span><span class="o">[]</span> <span
class="n">args</span><span class="o">)</span> <span class="kd">throws</span>
<span class="n">Exception</span> <span class="o">{</span>
+<div class="highlight"><pre><code class="language-java" data-lang="java"><span
class="kd">public</span> <span class="kd">static</span> <span
class="kt">void</span> <span class="nf">main</span><span
class="o">(</span><span class="n">String</span><span class="o">[]</span> <span
class="n">args</span><span class="o">)</span> <span class="kd">throws</span>
<span class="n">Exception</span> <span class="o">{</span>
<span class="n">DirectProvider</span> <span class="n">dp</span> <span
class="o">=</span> <span class="k">new</span> <span
class="n">DirectProvider</span><span class="o">();</span>
<span class="n">Topology</span> <span class="n">top</span> <span
class="o">=</span> <span class="n">dp</span><span class="o">.</span><span
class="na">newTopology</span><span class="o">();</span>
@@ -747,7 +747,7 @@ $('#toc').on('click', 'a', function() {
<h2 id="polling-source-reading-data-periodically">Polling source: reading data
periodically</h2>
<p>A much more common scenario for a developer is the periodic generation of
data from a source operator — a data source may need to be polled every 5
seconds, 3 hours, or any time frame. To this end, <code>Topology</code> exposes
the <code>poll()</code> method which can be used to call a function at the
frequency of the user's choosing. For example, a user might want to query
Yahoo Finance every two seconds to retrieve the most up to date ticker price
for a stock:</p>
-<div class="highlight"><pre><code class="language-java" data-lang="java"><span
class="kd">public</span> <span class="kd">static</span> <span
class="kt">void</span> <span class="nf">main</span><span
class="p">(</span><span class="n">String</span><span class="o">[]</span> <span
class="n">args</span><span class="o">)</span> <span class="kd">throws</span>
<span class="n">Exception</span> <span class="o">{</span>
+<div class="highlight"><pre><code class="language-java" data-lang="java"><span
class="kd">public</span> <span class="kd">static</span> <span
class="kt">void</span> <span class="nf">main</span><span
class="o">(</span><span class="n">String</span><span class="o">[]</span> <span
class="n">args</span><span class="o">)</span> <span class="kd">throws</span>
<span class="n">Exception</span> <span class="o">{</span>
<span class="n">DirectProvider</span> <span class="n">dp</span> <span
class="o">=</span> <span class="k">new</span> <span
class="n">DirectProvider</span><span class="o">();</span>
<span class="n">Topology</span> <span class="n">top</span> <span
class="o">=</span> <span class="n">dp</span><span class="o">.</span><span
class="na">newTopology</span><span class="o">();</span>
@@ -796,7 +796,7 @@ $('#toc').on('click', 'a', function() {
<div class="col-lg-12 footer">
Site last
- generated: Dec 18, 2017 <br/>
+ generated: Apr 3, 2019 <br/>
</div>
</div>
diff --git a/content/recipes/recipe_value_out_of_range.html
b/content/recipes/recipe_value_out_of_range.html
index b847724..f7e9c10 100644
--- a/content/recipes/recipe_value_out_of_range.html
+++ b/content/recipes/recipe_value_out_of_range.html
@@ -721,7 +721,7 @@ $('#toc').on('click', 'a', function() {
<span class="kd">static</span> <span class="kt">double</span> <span
class="n">OPTIMAL_TEMP_HIGH</span> <span class="o">=</span> <span
class="mf">91.0</span><span class="o">;</span>
<span class="kd">static</span> <span class="n">Range</span><span
class="o"><</span><span class="n">Double</span><span class="o">></span>
<span class="n">optimalTempRange</span> <span class="o">=</span> <span
class="n">Ranges</span><span class="o">.</span><span
class="na">closed</span><span class="o">(</span><span
class="n">OPTIMAL_TEMP_LOW</span><span class="o">,</span> <span
class="n">OPTIMAL_TEMP_HIGH</span><span class="o">);</span>
- <span class="kd">public</span> <span class="kd">static</span> <span
class="kt">void</span> <span class="n">main</span><span class="o">(</span><span
class="n">String</span><span class="o">[]</span> <span
class="n">args</span><span class="o">)</span> <span class="kd">throws</span>
<span class="n">Exception</span> <span class="o">{</span>
+ <span class="kd">public</span> <span class="kd">static</span> <span
class="kt">void</span> <span class="nf">main</span><span
class="o">(</span><span class="n">String</span><span class="o">[]</span> <span
class="n">args</span><span class="o">)</span> <span class="kd">throws</span>
<span class="n">Exception</span> <span class="o">{</span>
<span class="n">DirectProvider</span> <span class="n">dp</span> <span
class="o">=</span> <span class="k">new</span> <span
class="n">DirectProvider</span><span class="o">();</span>
@@ -844,7 +844,7 @@ Temperature may not be optimal! It is 77.5°F!
* and a deadband filter to determine when the temperature
* is out of the optimal range.
*/</span>
- <span class="kd">public</span> <span class="kd">static</span> <span
class="kt">void</span> <span class="n">main</span><span class="o">(</span><span
class="n">String</span><span class="o">[]</span> <span
class="n">args</span><span class="o">)</span> <span class="kd">throws</span>
<span class="n">Exception</span> <span class="o">{</span>
+ <span class="kd">public</span> <span class="kd">static</span> <span
class="kt">void</span> <span class="nf">main</span><span
class="o">(</span><span class="n">String</span><span class="o">[]</span> <span
class="n">args</span><span class="o">)</span> <span class="kd">throws</span>
<span class="n">Exception</span> <span class="o">{</span>
<span class="n">DirectProvider</span> <span class="n">dp</span> <span
class="o">=</span> <span class="k">new</span> <span
class="n">DirectProvider</span><span class="o">();</span>
@@ -909,7 +909,7 @@ Temperature may not be optimal! It is 77.5°F!
<div class="col-lg-12 footer">
Site last
- generated: Dec 18, 2017 <br/>
+ generated: Apr 3, 2019 <br/>
</div>
</div>
diff --git a/content/recipes/recipe_writing_a_connector.html
b/content/recipes/recipe_writing_a_connector.html
index 3cc99b6..9265c4f 100644
--- a/content/recipes/recipe_writing_a_connector.html
+++ b/content/recipes/recipe_writing_a_connector.html
@@ -729,7 +729,7 @@ $('#toc').on('click', 'a', function() {
<div class="col-lg-12 footer">
Site last
- generated: Dec 18, 2017 <br/>
+ generated: Apr 3, 2019 <br/>
</div>
</div>
diff --git a/content/titlepage.html b/content/titlepage.html
index 7787bf5..e8f5bfb 100644
--- a/content/titlepage.html
+++ b/content/titlepage.html
@@ -695,7 +695,7 @@ $('#toc').on('click', 'a', function() {
<div class="printTitleArea">
<div class="printTitle"></div>
<div class="printSubtitle"></div>
- <div class="lastGeneratedDate">Last generated: December 18, 2017</div>
+ <div class="lastGeneratedDate">Last generated: April 03, 2019</div>
<hr />
<div class="printTitleImage">
@@ -742,7 +742,7 @@ $('#toc').on('click', 'a', function() {
<div class="col-lg-12 footer">
Site last
- generated: Dec 18, 2017 <br/>
+ generated: Apr 3, 2019 <br/>
</div>
</div>
diff --git a/content/tocpage.html b/content/tocpage.html
index a261afd..cbf65fa 100644
--- a/content/tocpage.html
+++ b/content/tocpage.html
@@ -946,7 +946,7 @@ $('#toc').on('click', 'a', function() {
<div class="col-lg-12 footer">
Site last
- generated: Dec 18, 2017 <br/>
+ generated: Apr 3, 2019 <br/>
</div>
</div>
![https://apachecon.com/images/apache/apachecon_na_500x500.png"](https://apachecon.com/images/apache/apachecon_na_500x500.png"){kind=link}