http://git-wip-us.apache.org/repos/asf/incubator-edgent-website/blob/9b42cd73/content/recipes/recipe_adaptable_filter_range.html ---------------------------------------------------------------------- diff --git a/content/recipes/recipe_adaptable_filter_range.html b/content/recipes/recipe_adaptable_filter_range.html index 4b46357..06a8655 100644 --- a/content/recipes/recipe_adaptable_filter_range.html +++ b/content/recipes/recipe_adaptable_filter_range.html @@ -160,12 +160,6 @@ - <li><a href="samples">Samples</a></li> - - - - - <li><a href="faq">FAQ</a></li> @@ -315,6 +309,26 @@ window.location.href = uri; + <li><a href="../docs/home.html">Edgent Overview</a></li> + + + + + + + + + + <li><a href="../docs/power-of-edgent.html">The Power of Edgent</a></li> + + + + + + + + + <li><a href="../docs/faq.html">FAQ</a></li> @@ -342,7 +356,37 @@ window.location.href = uri; - <li><a href="../docs/edgent-getting-started.html">Getting started guide</a></li> + <li><a href="../docs/edgent-getting-started.html">Getting Started Guide</a></li> + + + + + + + + + + <li><a href="../docs/edgent-getting-started-samples.html">Quickstart with Edgent Samples</a></li> + + + + + + + + + + <li><a href="../docs/application-development.html">Understanding App Development</a></li> + + + + + + + + + + <li><a href="../docs/quickstart.html">Quickstart IBM Watson IoT Platform</a></li> @@ -510,33 +554,6 @@ window.location.href = uri; - <li><a href="#">Sample Programs</a> - <ul> - - - - - <li><a href="../docs/samples.html">Samples</a></li> - - - - - - - - - - <li><a href="../docs/quickstart.html">Quickstart IBM Watson IoT Platform</a></li> - - - - - - - </ul> - - - <li><a href="#">Using the Console</a> <ul> @@ -681,7 +698,7 @@ $('#toc').on('click', 'a', function() { <span class="k">new</span> <span class="n">AtomicReference</span><span class="o"><>(</span><span class="n">DEFAULT_TEMP_RANGE</span><span class="o">);</span> </code></pre></div> <h2 id="define-a-method-to-change-the-range">Define a method to change the range</h2> -<div class="highlight"><pre><code class="language-java" data-lang="java"><span class="kd">static</span> <span class="kt">void</span> <span class="nf">setOptimalTempRange</span><span class="o">(</span><span class="n">Range</span><span class="o"><</span><span class="n">Double</span><span class="o">></span> <span class="n">range</span><span class="o">)</span> <span class="o">{</span> +<div class="highlight"><pre><code class="language-java" data-lang="java"><span class="kd">static</span> <span class="kt">void</span> <span class="nf">setOptimalTempRange</span><span class="p">(</span><span class="n">Range</span><span class="o"><</span><span class="n">Double</span><span class="o">></span> <span class="n">range</span><span class="o">)</span> <span class="o">{</span> <span class="n">System</span><span class="o">.</span><span class="na">out</span><span class="o">.</span><span class="na">println</span><span class="o">(</span><span class="s">"Using optimal temperature range: "</span> <span class="o">+</span> <span class="n">range</span><span class="o">);</span> <span class="n">optimalTempRangeRef</span><span class="o">.</span><span class="na">set</span><span class="o">(</span><span class="n">range</span><span class="o">);</span> <span class="o">}</span> @@ -727,7 +744,7 @@ $('#toc').on('click', 'a', function() { <span class="kd">static</span> <span class="n">AtomicReference</span><span class="o"><</span><span class="n">Range</span><span class="o"><</span><span class="n">Double</span><span class="o">>></span> <span class="n">optimalTempRangeRef</span> <span class="o">=</span> <span class="k">new</span> <span class="n">AtomicReference</span><span class="o"><>(</span><span class="n">DEFAULT_TEMP_RANGE</span><span class="o">);</span> - <span class="kd">static</span> <span class="kt">void</span> <span class="nf">setOptimalTempRange</span><span class="o">(</span><span class="n">Range</span><span class="o"><</span><span class="n">Double</span><span class="o">></span> <span class="n">range</span><span class="o">)</span> <span class="o">{</span> + <span class="kd">static</span> <span class="kt">void</span> <span class="n">setOptimalTempRange</span><span class="o">(</span><span class="n">Range</span><span class="o"><</span><span class="n">Double</span><span class="o">></span> <span class="n">range</span><span class="o">)</span> <span class="o">{</span> <span class="n">System</span><span class="o">.</span><span class="na">out</span><span class="o">.</span><span class="na">println</span><span class="o">(</span><span class="s">"Using optimal temperature range: "</span> <span class="o">+</span> <span class="n">range</span><span class="o">);</span> <span class="n">optimalTempRangeRef</span><span class="o">.</span><span class="na">set</span><span class="o">(</span><span class="n">range</span><span class="o">);</span> <span class="o">}</span> @@ -737,7 +754,7 @@ $('#toc').on('click', 'a', function() { * temperature readings (in Fahrenheit). Use a simple filter * to determine when the temperature is out of the optimal range. */</span> - <span class="kd">public</span> <span class="kd">static</span> <span class="kt">void</span> <span class="nf">main</span><span class="o">(</span><span class="n">String</span><span class="o">[]</span> <span class="n">args</span><span class="o">)</span> <span class="kd">throws</span> <span class="n">Exception</span> <span class="o">{</span> + <span class="kd">public</span> <span class="kd">static</span> <span class="kt">void</span> <span class="n">main</span><span class="o">(</span><span class="n">String</span><span class="o">[]</span> <span class="n">args</span><span class="o">)</span> <span class="kd">throws</span> <span class="n">Exception</span> <span class="o">{</span> <span class="n">DirectProvider</span> <span class="n">dp</span> <span class="o">=</span> <span class="k">new</span> <span class="n">DirectProvider</span><span class="o">();</span> @@ -804,7 +821,7 @@ $('#toc').on('click', 'a', function() { <div class="col-lg-12 footer"> Site last - generated: May 15, 2017 <br/> + generated: Dec 15, 2017 <br/> </div> </div>
http://git-wip-us.apache.org/repos/asf/incubator-edgent-website/blob/9b42cd73/content/recipes/recipe_adaptable_polling_source.html ---------------------------------------------------------------------- diff --git a/content/recipes/recipe_adaptable_polling_source.html b/content/recipes/recipe_adaptable_polling_source.html index 1a78126..0aaa434 100644 --- a/content/recipes/recipe_adaptable_polling_source.html +++ b/content/recipes/recipe_adaptable_polling_source.html @@ -160,12 +160,6 @@ - <li><a href="samples">Samples</a></li> - - - - - <li><a href="faq">FAQ</a></li> @@ -315,6 +309,26 @@ window.location.href = uri; + <li><a href="../docs/home.html">Edgent Overview</a></li> + + + + + + + + + + <li><a href="../docs/power-of-edgent.html">The Power of Edgent</a></li> + + + + + + + + + <li><a href="../docs/faq.html">FAQ</a></li> @@ -342,7 +356,37 @@ window.location.href = uri; - <li><a href="../docs/edgent-getting-started.html">Getting started guide</a></li> + <li><a href="../docs/edgent-getting-started.html">Getting Started Guide</a></li> + + + + + + + + + + <li><a href="../docs/edgent-getting-started-samples.html">Quickstart with Edgent Samples</a></li> + + + + + + + + + + <li><a href="../docs/application-development.html">Understanding App Development</a></li> + + + + + + + + + + <li><a href="../docs/quickstart.html">Quickstart IBM Watson IoT Platform</a></li> @@ -510,33 +554,6 @@ window.location.href = uri; - <li><a href="#">Sample Programs</a> - <ul> - - - - - <li><a href="../docs/samples.html">Samples</a></li> - - - - - - - - - - <li><a href="../docs/quickstart.html">Quickstart IBM Watson IoT Platform</a></li> - - - - - - - </ul> - - - <li><a href="#">Using the Console</a> <ul> @@ -684,8 +701,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-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><span class="o">,</span> <span class="n">TimeUnit</span> <span class="n">unit</span><span class="o">)</span> <span class="o">{</span> +<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</span><span class="o">,</span> <span class="n">TimeUnit</span> <span class="n">unit</span><span class="o">)</span> <span class="o">{</span> <span class="c1">// get the topology's runtime ControlService service</span> <span class="n">ControlService</span> <span class="n">cs</span> <span class="o">=</span> <span class="n">pollStream</span><span class="o">.</span><span class="na">topology</span><span class="o">().</span><span class="na">getRuntimeServiceSupplier</span><span class="o">()</span> <span class="o">.</span><span class="na">get</span><span class="o">().</span><span class="na">getService</span><span class="o">(</span><span class="n">ControlService</span><span class="o">.</span><span class="na">class</span><span class="o">);</span> @@ -698,7 +715,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-set-poll-period-command-stream">Process the "set poll period" command stream</h2> +<h2 id="process-the-quot-set-poll-period-quot-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> @@ -729,7 +746,7 @@ $('#toc').on('click', 'a', function() { * Poll a temperature sensor to periodically obtain temperature readings. * Respond to a simulated command stream to change the poll period. */</span> - <span class="kd">public</span> <span class="kd">static</span> <span class="kt">void</span> <span class="nf">main</span><span class="o">(</span><span class="n">String</span><span class="o">[]</span> <span class="n">args</span><span class="o">)</span> <span class="kd">throws</span> <span class="n">Exception</span> <span class="o">{</span> + <span class="kd">public</span> <span class="kd">static</span> <span class="kt">void</span> <span class="n">main</span><span class="o">(</span><span class="n">String</span><span class="o">[]</span> <span class="n">args</span><span class="o">)</span> <span class="kd">throws</span> <span class="n">Exception</span> <span class="o">{</span> <span class="n">DirectProvider</span> <span class="n">dp</span> <span class="o">=</span> <span class="k">new</span> <span class="n">DirectProvider</span><span class="o">();</span> @@ -755,7 +772,7 @@ $('#toc').on('click', 'a', function() { <span class="n">dp</span><span class="o">.</span><span class="na">submit</span><span class="o">(</span><span class="n">top</span><span class="o">);</span> <span class="o">}</span> - <span class="kd">static</span> <span class="o"><</span><span class="n">T</span><span class="o">></span> <span class="kt">void</span> <span class="nf">setPollPeriod</span><span class="o">(</span><span class="n">TStream</span><span class="o"><</span><span class="n">T</span><span class="o">></span> <span class="n">pollStream</span><span class="o">,</span> <span class="kt">long</span> <span class="n">period</span><span class="o">,</span> <span class="n">TimeUnit</span> <span class="n">unit</span><span class="o">)</span> <span class="o">{</span> + <span class="kd">static</span> <span class="o"><</span><span class="n">T</span><span class="o">></span> <span class="kt">void</span> <span class="n">setPollPeriod</span><span class="o">(</span><span class="n">TStream</span><span class="o"><</span><span class="n">T</span><span class="o">></span> <span class="n">pollStream</span><span class="o">,</span> <span class="kt">long</span> <span class="n">period</span><span class="o">,</span> <span class="n">TimeUnit</span> <span class="n">unit</span><span class="o">)</span> <span class="o">{</span> <span class="c1">// get the topology's runtime ControlService service</span> <span class="n">ControlService</span> <span class="n">cs</span> <span class="o">=</span> <span class="n">pollStream</span><span class="o">.</span><span class="na">topology</span><span class="o">().</span><span class="na">getRuntimeServiceSupplier</span><span class="o">()</span> <span class="o">.</span><span class="na">get</span><span class="o">().</span><span class="na">getService</span><span class="o">(</span><span class="n">ControlService</span><span class="o">.</span><span class="na">class</span><span class="o">);</span> @@ -768,7 +785,7 @@ $('#toc').on('click', 'a', function() { <span class="n">control</span><span class="o">.</span><span class="na">setPeriod</span><span class="o">(</span><span class="n">period</span><span class="o">,</span> <span class="n">unit</span><span class="o">);</span> <span class="o">}</span> - <span class="kd">static</span> <span class="n">TStream</span><span class="o"><</span><span class="n">JsonObject</span><span class="o">></span> <span class="nf">simulatedSetPollPeriodCmds</span><span class="o">(</span><span class="n">Topology</span> <span class="n">top</span><span class="o">)</span> <span class="o">{</span> + <span class="kd">static</span> <span class="n">TStream</span><span class="o"><</span><span class="n">JsonObject</span><span class="o">></span> <span class="n">simulatedSetPollPeriodCmds</span><span class="o">(</span><span class="n">Topology</span> <span class="n">top</span><span class="o">)</span> <span class="o">{</span> <span class="n">AtomicInteger</span> <span class="n">lastPeriod</span> <span class="o">=</span> <span class="k">new</span> <span class="n">AtomicInteger</span><span class="o">(</span><span class="mi">1</span><span class="o">);</span> <span class="n">TStream</span><span class="o"><</span><span class="n">JsonObject</span><span class="o">></span> <span class="n">cmds</span> <span class="o">=</span> <span class="n">top</span><span class="o">.</span><span class="na">poll</span><span class="o">(()</span> <span class="o">-></span> <span class="o">{</span> <span class="c1">// toggle between 1 and 2 sec period</span> @@ -816,7 +833,7 @@ $('#toc').on('click', 'a', function() { <div class="col-lg-12 footer"> Site last - generated: May 15, 2017 <br/> + generated: Dec 15, 2017 <br/> </div> </div> http://git-wip-us.apache.org/repos/asf/incubator-edgent-website/blob/9b42cd73/content/recipes/recipe_combining_streams_processing_results.html ---------------------------------------------------------------------- diff --git a/content/recipes/recipe_combining_streams_processing_results.html b/content/recipes/recipe_combining_streams_processing_results.html index de155b0..a2f8614 100644 --- a/content/recipes/recipe_combining_streams_processing_results.html +++ b/content/recipes/recipe_combining_streams_processing_results.html @@ -160,12 +160,6 @@ - <li><a href="samples">Samples</a></li> - - - - - <li><a href="faq">FAQ</a></li> @@ -315,6 +309,26 @@ window.location.href = uri; + <li><a href="../docs/home.html">Edgent Overview</a></li> + + + + + + + + + + <li><a href="../docs/power-of-edgent.html">The Power of Edgent</a></li> + + + + + + + + + <li><a href="../docs/faq.html">FAQ</a></li> @@ -342,7 +356,37 @@ window.location.href = uri; - <li><a href="../docs/edgent-getting-started.html">Getting started guide</a></li> + <li><a href="../docs/edgent-getting-started.html">Getting Started Guide</a></li> + + + + + + + + + + <li><a href="../docs/edgent-getting-started-samples.html">Quickstart with Edgent Samples</a></li> + + + + + + + + + + <li><a href="../docs/application-development.html">Understanding App Development</a></li> + + + + + + + + + + <li><a href="../docs/quickstart.html">Quickstart IBM Watson IoT Platform</a></li> @@ -510,33 +554,6 @@ window.location.href = uri; - <li><a href="#">Sample Programs</a> - <ul> - - - - - <li><a href="../docs/samples.html">Samples</a></li> - - - - - - - - - - <li><a href="../docs/quickstart.html">Quickstart IBM Watson IoT Platform</a></li> - - - - - - - </ul> - - - <li><a href="#">Using the Console</a> <ul> @@ -687,7 +704,7 @@ $('#toc').on('click', 'a', function() { <span class="kd">public</span> <span class="n">Integer</span> <span class="n">currentDiastolic</span> <span class="o">=</span> <span class="mi">75</span><span class="o">;</span> <span class="n">Random</span> <span class="n">rand</span><span class="o">;</span> - <span class="kd">public</span> <span class="nf">HeartMonitorSensor</span><span class="o">()</span> <span class="o">{</span> + <span class="kd">public</span> <span class="n">HeartMonitorSensor</span><span class="o">()</span> <span class="o">{</span> <span class="n">rand</span> <span class="o">=</span> <span class="k">new</span> <span class="n">Random</span><span class="o">();</span> <span class="o">}</span> @@ -696,7 +713,7 @@ $('#toc').on('click', 'a', function() { * pressure and a random diastolic pressure. */</span> <span class="nd">@Override</span> - <span class="kd">public</span> <span class="n">Map</span><span class="o"><</span><span class="n">String</span><span class="o">,</span> <span class="n">Integer</span><span class="o">></span> <span class="nf">get</span><span class="o">()</span> <span class="o">{</span> + <span class="kd">public</span> <span class="n">Map</span><span class="o"><</span><span class="n">String</span><span class="o">,</span> <span class="n">Integer</span><span class="o">></span> <span class="n">get</span><span class="o">()</span> <span class="o">{</span> <span class="c1">// Change the current pressure by some random amount between -2 and 2</span> <span class="n">Integer</span> <span class="n">newSystolic</span> <span class="o">=</span> <span class="n">rand</span><span class="o">.</span><span class="na">nextInt</span><span class="o">(</span><span class="mi">2</span> <span class="o">+</span> <span class="mi">1</span> <span class="o">+</span> <span class="mi">2</span><span class="o">)</span> <span class="o">-</span> <span class="mi">2</span> <span class="o">+</span> <span class="n">currentSystolic</span><span class="o">;</span> <span class="n">currentSystolic</span> <span class="o">=</span> <span class="n">newSystolic</span><span class="o">;</span> @@ -727,7 +744,7 @@ $('#toc').on('click', 'a', function() { <span class="kn">import</span> <span class="nn">org.apache.edgent.topology.Topology</span><span class="o">;</span> <span class="kd">public</span> <span class="kd">class</span> <span class="nc">CombiningStreamsProcessingResults</span> <span class="o">{</span> - <span class="kd">public</span> <span class="kd">static</span> <span class="kt">void</span> <span class="nf">main</span><span class="o">(</span><span class="n">String</span><span class="o">[]</span> <span class="n">args</span><span class="o">)</span> <span class="o">{</span> + <span class="kd">public</span> <span class="kd">static</span> <span class="kt">void</span> <span class="n">main</span><span class="o">(</span><span class="n">String</span><span class="o">[]</span> <span class="n">args</span><span class="o">)</span> <span class="o">{</span> <span class="n">HeartMonitorSensor</span> <span class="n">monitor</span> <span class="o">=</span> <span class="k">new</span> <span class="n">HeartMonitorSensor</span><span class="o">();</span> <span class="n">DirectProvider</span> <span class="n">dp</span> <span class="o">=</span> <span class="k">new</span> <span class="n">DevelopmentProvider</span><span class="o">();</span> @@ -752,7 +769,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="nf">split</span><span class="o">(</span><span class="kt">int</span> <span class="n">n</span><span class="o">,</span> <span class="n">ToIntFunction</span><span class="o"><</span><span class="n">T</span><span class="o">></span> <span class="n">splitter</span><span class="o">)</span> +<div class="highlight"><pre><code class="language-java" data-lang="java"><span class="n">java</span><span class="o">.</span><span class="na">util</span><span class="o">.</span><span class="na">List</span><span class="o"><</span><span class="n">TStream</span><span class="o"><</span><span class="n">T</span><span class="o">>></span> <span class="n">split</span><span class="o">(</span><span class="kt">int</span> <span class="n">n</span><span class="o">,</span> <span class="n">ToIntFunction</span><span class="o"><</span><span class="n">T</span><span class="o">></span> <span class="n">splitter</span><span class="o">)</span> </code></pre></div> <p><code>split</code> returns a <code>List</code> of <code>TStream</code> objects, where each item in the list is one of the resulting output streams. In this case, one stream in the list will contain a flow of tuples where the blood pressure reading belongs to one of the five blood pressure categories. Another stream will contain a flow of tuples where the blood pressure reading belongs to a different blood pressure category, and so on.</p> @@ -935,7 +952,7 @@ EMERGENCY! SEE TO PATIENT IMMEDIATELY! <div class="col-lg-12 footer"> Site last - generated: May 15, 2017 <br/> + generated: Dec 15, 2017 <br/> </div> </div> http://git-wip-us.apache.org/repos/asf/incubator-edgent-website/blob/9b42cd73/content/recipes/recipe_concurrent_analytics.html ---------------------------------------------------------------------- diff --git a/content/recipes/recipe_concurrent_analytics.html b/content/recipes/recipe_concurrent_analytics.html index 898a1e3..cc581f0 100644 --- a/content/recipes/recipe_concurrent_analytics.html +++ b/content/recipes/recipe_concurrent_analytics.html @@ -160,12 +160,6 @@ - <li><a href="samples">Samples</a></li> - - - - - <li><a href="faq">FAQ</a></li> @@ -315,6 +309,26 @@ window.location.href = uri; + <li><a href="../docs/home.html">Edgent Overview</a></li> + + + + + + + + + + <li><a href="../docs/power-of-edgent.html">The Power of Edgent</a></li> + + + + + + + + + <li><a href="../docs/faq.html">FAQ</a></li> @@ -342,7 +356,37 @@ window.location.href = uri; - <li><a href="../docs/edgent-getting-started.html">Getting started guide</a></li> + <li><a href="../docs/edgent-getting-started.html">Getting Started Guide</a></li> + + + + + + + + + + <li><a href="../docs/edgent-getting-started-samples.html">Quickstart with Edgent Samples</a></li> + + + + + + + + + + <li><a href="../docs/application-development.html">Understanding App Development</a></li> + + + + + + + + + + <li><a href="../docs/quickstart.html">Quickstart IBM Watson IoT Platform</a></li> @@ -510,33 +554,6 @@ window.location.href = uri; - <li><a href="#">Sample Programs</a> - <ul> - - - - - <li><a href="../docs/samples.html">Samples</a></li> - - - - - - - - - - <li><a href="../docs/quickstart.html">Quickstart IBM Watson IoT Platform</a></li> - - - - - - - </ul> - - - <li><a href="#">Using the Console</a> <ul> @@ -713,7 +730,7 @@ stream -> |-> isolate(1) -> pipeline2 -> |-> barrier(10) -> co <p>In this recipe we'll just define some very simple pipelines and use sleep to simulate some long processing times.</p> <p>Here's the A3 pipeline builder:</p> -<div class="highlight"><pre><code class="language-java" data-lang="java"><span class="kd">static</span> <span class="n">Function</span><span class="o"><</span><span class="n">TStream</span><span class="o"><</span><span class="n">Double</span><span class="o">>,</span><span class="n">TStream</span><span class="o"><</span><span class="n">String</span><span class="o">>></span> <span class="nf">a3pipeline</span><span class="o">()</span> <span class="o">{</span> +<div class="highlight"><pre><code class="language-java" data-lang="java"><span class="kd">static</span> <span class="n">Function</span><span class="o"><</span><span class="n">TStream</span><span class="o"><</span><span class="n">Double</span><span class="o">>,</span><span class="n">TStream</span><span class="o"><</span><span class="n">String</span><span class="o">>></span> <span class="n">a3pipeline</span><span class="o">()</span> <span class="o">{</span> <span class="c1">// simple 3 stage pipeline simulating some amount of work by sleeping</span> <span class="k">return</span> <span class="n">stream</span> <span class="o">-></span> <span class="n">stream</span><span class="o">.</span><span class="na">map</span><span class="o">(</span><span class="n">tuple</span> <span class="o">-></span> <span class="o">{</span> <span class="n">sleep</span><span class="o">(</span><span class="mi">800</span><span class="o">,</span> <span class="n">TimeUnit</span><span class="o">.</span><span class="na">MILLISECONDS</span><span class="o">);</span> @@ -752,7 +769,7 @@ stream -> |-> isolate(1) -> pipeline2 -> |-> barrier(10) -> co * Concurrently run a collection of long running independent * analytic pipelines on each tuple. */</span> - <span class="kd">public</span> <span class="kd">static</span> <span class="kt">void</span> <span class="nf">main</span><span class="o">(</span><span class="n">String</span><span class="o">[]</span> <span class="n">args</span><span class="o">)</span> <span class="kd">throws</span> <span class="n">Exception</span> <span class="o">{</span> + <span class="kd">public</span> <span class="kd">static</span> <span class="kt">void</span> <span class="n">main</span><span class="o">(</span><span class="n">String</span><span class="o">[]</span> <span class="n">args</span><span class="o">)</span> <span class="kd">throws</span> <span class="n">Exception</span> <span class="o">{</span> <span class="n">DirectProvider</span> <span class="n">dp</span> <span class="o">=</span> <span class="k">new</span> <span class="n">DevelopmentProvider</span><span class="o">();</span> <span class="n">System</span><span class="o">.</span><span class="na">out</span><span class="o">.</span><span class="na">println</span><span class="o">(</span><span class="s">"development console url: "</span> @@ -791,7 +808,7 @@ stream -> |-> isolate(1) -> pipeline2 -> |-> barrier(10) -> co <span class="o">}</span> <span class="cm">/** Function to create analytic pipeline a1 and add it to a stream */</span> - <span class="kd">private</span> <span class="kd">static</span> <span class="n">Function</span><span class="o"><</span><span class="n">TStream</span><span class="o"><</span><span class="n">Double</span><span class="o">>,</span><span class="n">TStream</span><span class="o"><</span><span class="n">String</span><span class="o">>></span> <span class="nf">a1pipeline</span><span class="o">()</span> <span class="o">{</span> + <span class="kd">private</span> <span class="kd">static</span> <span class="n">Function</span><span class="o"><</span><span class="n">TStream</span><span class="o"><</span><span class="n">Double</span><span class="o">>,</span><span class="n">TStream</span><span class="o"><</span><span class="n">String</span><span class="o">>></span> <span class="n">a1pipeline</span><span class="o">()</span> <span class="o">{</span> <span class="c1">// a simple 1 stage pipeline simulating some amount of work by sleeping</span> <span class="k">return</span> <span class="n">stream</span> <span class="o">-></span> <span class="n">stream</span><span class="o">.</span><span class="na">map</span><span class="o">(</span><span class="n">tuple</span> <span class="o">-></span> <span class="o">{</span> <span class="n">sleep</span><span class="o">(</span><span class="mi">800</span><span class="o">,</span> <span class="n">TimeUnit</span><span class="o">.</span><span class="na">MILLISECONDS</span><span class="o">);</span> @@ -800,7 +817,7 @@ stream -> |-> isolate(1) -> pipeline2 -> |-> barrier(10) -> co <span class="o">}</span> <span class="cm">/** Function to create analytic pipeline a2 and add it to a stream */</span> - <span class="kd">private</span> <span class="kd">static</span> <span class="n">Function</span><span class="o"><</span><span class="n">TStream</span><span class="o"><</span><span class="n">Double</span><span class="o">>,</span><span class="n">TStream</span><span class="o"><</span><span class="n">String</span><span class="o">>></span> <span class="nf">a2pipeline</span><span class="o">()</span> <span class="o">{</span> + <span class="kd">private</span> <span class="kd">static</span> <span class="n">Function</span><span class="o"><</span><span class="n">TStream</span><span class="o"><</span><span class="n">Double</span><span class="o">>,</span><span class="n">TStream</span><span class="o"><</span><span class="n">String</span><span class="o">>></span> <span class="n">a2pipeline</span><span class="o">()</span> <span class="o">{</span> <span class="c1">// a simple 2 stage pipeline simulating some amount of work by sleeping</span> <span class="k">return</span> <span class="n">stream</span> <span class="o">-></span> <span class="n">stream</span><span class="o">.</span><span class="na">map</span><span class="o">(</span><span class="n">tuple</span> <span class="o">-></span> <span class="o">{</span> <span class="n">sleep</span><span class="o">(</span><span class="mi">800</span><span class="o">,</span> <span class="n">TimeUnit</span><span class="o">.</span><span class="na">MILLISECONDS</span><span class="o">);</span> @@ -810,7 +827,7 @@ stream -> |-> isolate(1) -> pipeline2 -> |-> barrier(10) -> co <span class="o">}</span> <span class="cm">/** Function to create analytic pipeline a3 and add it to a stream */</span> - <span class="kd">private</span> <span class="kd">static</span> <span class="n">Function</span><span class="o"><</span><span class="n">TStream</span><span class="o"><</span><span class="n">Double</span><span class="o">>,</span><span class="n">TStream</span><span class="o"><</span><span class="n">String</span><span class="o">>></span> <span class="nf">a3pipeline</span><span class="o">()</span> <span class="o">{</span> + <span class="kd">private</span> <span class="kd">static</span> <span class="n">Function</span><span class="o"><</span><span class="n">TStream</span><span class="o"><</span><span class="n">Double</span><span class="o">>,</span><span class="n">TStream</span><span class="o"><</span><span class="n">String</span><span class="o">>></span> <span class="n">a3pipeline</span><span class="o">()</span> <span class="o">{</span> <span class="c1">// a simple 3 stage pipeline simulating some amount of work by sleeping</span> <span class="k">return</span> <span class="n">stream</span> <span class="o">-></span> <span class="n">stream</span><span class="o">.</span><span class="na">map</span><span class="o">(</span><span class="n">tuple</span> <span class="o">-></span> <span class="o">{</span> <span class="n">sleep</span><span class="o">(</span><span class="mi">800</span><span class="o">,</span> <span class="n">TimeUnit</span><span class="o">.</span><span class="na">MILLISECONDS</span><span class="o">);</span> @@ -820,11 +837,11 @@ stream -> |-> isolate(1) -> pipeline2 -> |-> barrier(10) -> co <span class="o">.</span><span class="na">map</span><span class="o">(</span><span class="n">Functions</span><span class="o">.</span><span class="na">identity</span><span class="o">()).</span><span class="na">tag</span><span class="o">(</span><span class="s">"a3.stage3"</span><span class="o">);</span> <span class="o">}</span> - <span class="kd">private</span> <span class="kd">static</span> <span class="kt">void</span> <span class="nf">sleep</span><span class="o">(</span><span class="kt">long</span> <span class="n">period</span><span class="o">,</span> <span class="n">TimeUnit</span> <span class="n">unit</span><span class="o">)</span> <span class="kd">throws</span> <span class="n">RuntimeException</span> <span class="o">{</span> + <span class="kd">private</span> <span class="kd">static</span> <span class="kt">void</span> <span class="n">sleep</span><span class="o">(</span><span class="kt">long</span> <span class="n">period</span><span class="o">,</span> <span class="n">TimeUnit</span> <span class="n">unit</span><span class="o">)</span> <span class="kd">throws</span> <span class="n">RuntimeException</span> <span class="o">{</span> <span class="k">try</span> <span class="o">{</span> <span class="n">Thread</span><span class="o">.</span><span class="na">sleep</span><span class="o">(</span><span class="n">unit</span><span class="o">.</span><span class="na">toMillis</span><span class="o">(</span><span class="n">period</span><span class="o">));</span> <span class="o">}</span> <span class="k">catch</span> <span class="o">(</span><span class="n">InterruptedException</span> <span class="n">e</span><span class="o">)</span> <span class="o">{</span> - <span class="k">throw</span> <span class="k">new</span> <span class="nf">RuntimeException</span><span class="o">(</span><span class="s">"Interrupted"</span><span class="o">,</span> <span class="n">e</span><span class="o">);</span> + <span class="k">throw</span> <span class="k">new</span> <span class="n">RuntimeException</span><span class="o">(</span><span class="s">"Interrupted"</span><span class="o">,</span> <span class="n">e</span><span class="o">);</span> <span class="o">}</span> <span class="o">}</span> @@ -862,7 +879,7 @@ stream -> |-> isolate(1) -> pipeline2 -> |-> barrier(10) -> co <div class="col-lg-12 footer"> Site last - generated: May 15, 2017 <br/> + generated: Dec 15, 2017 <br/> </div> </div> http://git-wip-us.apache.org/repos/asf/incubator-edgent-website/blob/9b42cd73/content/recipes/recipe_different_processing_against_stream.html ---------------------------------------------------------------------- diff --git a/content/recipes/recipe_different_processing_against_stream.html b/content/recipes/recipe_different_processing_against_stream.html index 5372ac6..49e3ed6 100644 --- a/content/recipes/recipe_different_processing_against_stream.html +++ b/content/recipes/recipe_different_processing_against_stream.html @@ -160,12 +160,6 @@ - <li><a href="samples">Samples</a></li> - - - - - <li><a href="faq">FAQ</a></li> @@ -315,6 +309,26 @@ window.location.href = uri; + <li><a href="../docs/home.html">Edgent Overview</a></li> + + + + + + + + + + <li><a href="../docs/power-of-edgent.html">The Power of Edgent</a></li> + + + + + + + + + <li><a href="../docs/faq.html">FAQ</a></li> @@ -342,7 +356,37 @@ window.location.href = uri; - <li><a href="../docs/edgent-getting-started.html">Getting started guide</a></li> + <li><a href="../docs/edgent-getting-started.html">Getting Started Guide</a></li> + + + + + + + + + + <li><a href="../docs/edgent-getting-started-samples.html">Quickstart with Edgent Samples</a></li> + + + + + + + + + + <li><a href="../docs/application-development.html">Understanding App Development</a></li> + + + + + + + + + + <li><a href="../docs/quickstart.html">Quickstart IBM Watson IoT Platform</a></li> @@ -510,33 +554,6 @@ window.location.href = uri; - <li><a href="#">Sample Programs</a> - <ul> - - - - - <li><a href="../docs/samples.html">Samples</a></li> - - - - - - - - - - <li><a href="../docs/quickstart.html">Quickstart IBM Watson IoT Platform</a></li> - - - - - - - </ul> - - - <li><a href="#">Using the Console</a> <ul> @@ -700,7 +717,7 @@ $('#toc').on('click', 'a', function() { */</span> <span class="kd">static</span> <span class="kt">double</span> <span class="n">ROUTE_MILES</span> <span class="o">=</span> <span class="mi">80</span><span class="o">;</span> - <span class="kd">public</span> <span class="kd">static</span> <span class="kt">void</span> <span class="nf">main</span><span class="o">(</span><span class="n">String</span><span class="o">[]</span> <span class="n">args</span><span class="o">)</span> <span class="kd">throws</span> <span class="n">Exception</span> <span class="o">{</span> + <span class="kd">public</span> <span class="kd">static</span> <span class="kt">void</span> <span class="n">main</span><span class="o">(</span><span class="n">String</span><span class="o">[]</span> <span class="n">args</span><span class="o">)</span> <span class="kd">throws</span> <span class="n">Exception</span> <span class="o">{</span> <span class="n">DirectProvider</span> <span class="n">dp</span> <span class="o">=</span> <span class="k">new</span> <span class="n">DevelopmentProvider</span><span class="o">();</span> @@ -814,7 +831,7 @@ Gallons of gas: 9.1 * gas mileage readings (in miles/gallon). Feed the stream of sensor * readings to different functions (filter, map, and modify). */</span> - <span class="kd">public</span> <span class="kd">static</span> <span class="kt">void</span> <span class="nf">main</span><span class="o">(</span><span class="n">String</span><span class="o">[]</span> <span class="n">args</span><span class="o">)</span> <span class="kd">throws</span> <span class="n">Exception</span> <span class="o">{</span> + <span class="kd">public</span> <span class="kd">static</span> <span class="kt">void</span> <span class="n">main</span><span class="o">(</span><span class="n">String</span><span class="o">[]</span> <span class="n">args</span><span class="o">)</span> <span class="kd">throws</span> <span class="n">Exception</span> <span class="o">{</span> <span class="n">DirectProvider</span> <span class="n">dp</span> <span class="o">=</span> <span class="k">new</span> <span class="n">DevelopmentProvider</span><span class="o">();</span> @@ -884,7 +901,7 @@ Gallons of gas: 9.1 <div class="col-lg-12 footer"> Site last - generated: May 15, 2017 <br/> + generated: Dec 15, 2017 <br/> </div> </div> http://git-wip-us.apache.org/repos/asf/incubator-edgent-website/blob/9b42cd73/content/recipes/recipe_dynamic_analytic_control.html ---------------------------------------------------------------------- diff --git a/content/recipes/recipe_dynamic_analytic_control.html b/content/recipes/recipe_dynamic_analytic_control.html index 701f559..54e6846 100644 --- a/content/recipes/recipe_dynamic_analytic_control.html +++ b/content/recipes/recipe_dynamic_analytic_control.html @@ -160,12 +160,6 @@ - <li><a href="samples">Samples</a></li> - - - - - <li><a href="faq">FAQ</a></li> @@ -315,6 +309,26 @@ window.location.href = uri; + <li><a href="../docs/home.html">Edgent Overview</a></li> + + + + + + + + + + <li><a href="../docs/power-of-edgent.html">The Power of Edgent</a></li> + + + + + + + + + <li><a href="../docs/faq.html">FAQ</a></li> @@ -342,7 +356,37 @@ window.location.href = uri; - <li><a href="../docs/edgent-getting-started.html">Getting started guide</a></li> + <li><a href="../docs/edgent-getting-started.html">Getting Started Guide</a></li> + + + + + + + + + + <li><a href="../docs/edgent-getting-started-samples.html">Quickstart with Edgent Samples</a></li> + + + + + + + + + + <li><a href="../docs/application-development.html">Understanding App Development</a></li> + + + + + + + + + + <li><a href="../docs/quickstart.html">Quickstart IBM Watson IoT Platform</a></li> @@ -510,33 +554,6 @@ window.location.href = uri; - <li><a href="#">Sample Programs</a> - <ul> - - - - - <li><a href="../docs/samples.html">Samples</a></li> - - - - - - - - - - <li><a href="../docs/quickstart.html">Quickstart IBM Watson IoT Platform</a></li> - - - - - - - </ul> - - - <li><a href="#">Using the Console</a> <ul> @@ -736,7 +753,7 @@ $('#toc').on('click', 'a', function() { <div class="col-lg-12 footer"> Site last - generated: May 15, 2017 <br/> + generated: Dec 15, 2017 <br/> </div> </div> http://git-wip-us.apache.org/repos/asf/incubator-edgent-website/blob/9b42cd73/content/recipes/recipe_external_filter_range.html ---------------------------------------------------------------------- diff --git a/content/recipes/recipe_external_filter_range.html b/content/recipes/recipe_external_filter_range.html index a61c6d0..81449a1 100644 --- a/content/recipes/recipe_external_filter_range.html +++ b/content/recipes/recipe_external_filter_range.html @@ -160,12 +160,6 @@ - <li><a href="samples">Samples</a></li> - - - - - <li><a href="faq">FAQ</a></li> @@ -315,6 +309,26 @@ window.location.href = uri; + <li><a href="../docs/home.html">Edgent Overview</a></li> + + + + + + + + + + <li><a href="../docs/power-of-edgent.html">The Power of Edgent</a></li> + + + + + + + + + <li><a href="../docs/faq.html">FAQ</a></li> @@ -342,7 +356,37 @@ window.location.href = uri; - <li><a href="../docs/edgent-getting-started.html">Getting started guide</a></li> + <li><a href="../docs/edgent-getting-started.html">Getting Started Guide</a></li> + + + + + + + + + + <li><a href="../docs/edgent-getting-started-samples.html">Quickstart with Edgent Samples</a></li> + + + + + + + + + + <li><a href="../docs/application-development.html">Understanding App Development</a></li> + + + + + + + + + + <li><a href="../docs/quickstart.html">Quickstart IBM Watson IoT Platform</a></li> @@ -510,33 +554,6 @@ window.location.href = uri; - <li><a href="#">Sample Programs</a> - <ul> - - - - - <li><a href="../docs/samples.html">Samples</a></li> - - - - - - - - - - <li><a href="../docs/quickstart.html">Quickstart IBM Watson IoT Platform</a></li> - - - - - - - </ul> - - - <li><a href="#">Using the Console</a> <ul> @@ -720,7 +737,7 @@ optimalTempRange=[77.0..91.0] <span class="kd">static</span> <span class="n">Range</span><span class="o"><</span><span class="n">Double</span><span class="o">></span> <span class="n">optimalTempRange</span><span class="o">;</span> <span class="cm">/** Initialize the application's configuration */</span> - <span class="kd">static</span> <span class="kt">void</span> <span class="nf">initializeConfiguration</span><span class="o">(</span><span class="n">String</span> <span class="n">configFilePath</span><span class="o">)</span> <span class="kd">throws</span> <span class="n">Exception</span> <span class="o">{</span> + <span class="kd">static</span> <span class="kt">void</span> <span class="n">initializeConfiguration</span><span class="o">(</span><span class="n">String</span> <span class="n">configFilePath</span><span class="o">)</span> <span class="kd">throws</span> <span class="n">Exception</span> <span class="o">{</span> <span class="c1">// Load the configuration file</span> <span class="n">Properties</span> <span class="n">props</span> <span class="o">=</span> <span class="k">new</span> <span class="n">Properties</span><span class="o">();</span> <span class="n">props</span><span class="o">.</span><span class="na">load</span><span class="o">(</span><span class="n">Files</span><span class="o">.</span><span class="na">newBufferedReader</span><span class="o">(</span><span class="k">new</span> <span class="n">File</span><span class="o">(</span><span class="n">configFilePath</span><span class="o">).</span><span class="na">toPath</span><span class="o">()));</span> @@ -737,9 +754,9 @@ optimalTempRange=[77.0..91.0] * temperature readings (in Fahrenheit). Use a simple filter * to determine when the temperature is out of the optimal range. */</span> - <span class="kd">public</span> <span class="kd">static</span> <span class="kt">void</span> <span class="nf">main</span><span class="o">(</span><span class="n">String</span><span class="o">[]</span> <span class="n">args</span><span class="o">)</span> <span class="kd">throws</span> <span class="n">Exception</span> <span class="o">{</span> + <span class="kd">public</span> <span class="kd">static</span> <span class="kt">void</span> <span class="n">main</span><span class="o">(</span><span class="n">String</span><span class="o">[]</span> <span class="n">args</span><span class="o">)</span> <span class="kd">throws</span> <span class="n">Exception</span> <span class="o">{</span> <span class="k">if</span> <span class="o">(</span><span class="n">args</span><span class="o">.</span><span class="na">length</span> <span class="o">!=</span> <span class="mi">1</span><span class="o">)</span> - <span class="k">throw</span> <span class="k">new</span> <span class="nf">Exception</span><span class="o">(</span><span class="s">"missing pathname to configuration file"</span><span class="o">);</span> + <span class="k">throw</span> <span class="k">new</span> <span class="n">Exception</span><span class="o">(</span><span class="s">"missing pathname to configuration file"</span><span class="o">);</span> <span class="n">String</span> <span class="n">configFilePath</span> <span class="o">=</span> <span class="n">args</span><span class="o">[</span><span class="mi">0</span><span class="o">];</span> <span class="n">DirectProvider</span> <span class="n">dp</span> <span class="o">=</span> <span class="k">new</span> <span class="n">DirectProvider</span><span class="o">();</span> @@ -798,7 +815,7 @@ optimalTempRange=[77.0..91.0] <div class="col-lg-12 footer"> Site last - generated: May 15, 2017 <br/> + generated: Dec 15, 2017 <br/> </div> </div> http://git-wip-us.apache.org/repos/asf/incubator-edgent-website/blob/9b42cd73/content/recipes/recipe_hello_edgent.html ---------------------------------------------------------------------- diff --git a/content/recipes/recipe_hello_edgent.html b/content/recipes/recipe_hello_edgent.html index 9b05221..aed6b4e 100644 --- a/content/recipes/recipe_hello_edgent.html +++ b/content/recipes/recipe_hello_edgent.html @@ -160,12 +160,6 @@ - <li><a href="samples">Samples</a></li> - - - - - <li><a href="faq">FAQ</a></li> @@ -315,6 +309,26 @@ window.location.href = uri; + <li><a href="../docs/home.html">Edgent Overview</a></li> + + + + + + + + + + <li><a href="../docs/power-of-edgent.html">The Power of Edgent</a></li> + + + + + + + + + <li><a href="../docs/faq.html">FAQ</a></li> @@ -342,7 +356,37 @@ window.location.href = uri; - <li><a href="../docs/edgent-getting-started.html">Getting started guide</a></li> + <li><a href="../docs/edgent-getting-started.html">Getting Started Guide</a></li> + + + + + + + + + + <li><a href="../docs/edgent-getting-started-samples.html">Quickstart with Edgent Samples</a></li> + + + + + + + + + + <li><a href="../docs/application-development.html">Understanding App Development</a></li> + + + + + + + + + + <li><a href="../docs/quickstart.html">Quickstart IBM Watson IoT Platform</a></li> @@ -510,33 +554,6 @@ window.location.href = uri; - <li><a href="#">Sample Programs</a> - <ul> - - - - - <li><a href="../docs/samples.html">Samples</a></li> - - - - - - - - - - <li><a href="../docs/quickstart.html">Quickstart IBM Watson IoT Platform</a></li> - - - - - - - </ul> - - - <li><a href="#">Using the Console</a> <ul> @@ -664,7 +681,7 @@ $('#toc').on('click', 'a', function() { <a target="_blank" href="https://github.com/apache/incubator-edgent-website/blob/master/site/recipes/recipe_hello_edgent.md"; class="btn btn-default githubEditButton" role="button"><i class="fa fa-github fa-lg"></i> Edit me</a> <p>Edgent's pure Java implementation is a powerful feature which allows it to be run on the majority of JVM-compatible systems. It also has the added benefit of enabling the developer to develop applications entirely within the Eclipse and IntelliJ ecosystems. For the purposes of this recipe, it will be assumed that the developer is using Eclipse. To begin the Hello Edgent recipe, create a new project and import the necessary libraries as outlined in the <a href="../docs/edgent-getting-started">Getting started guide</a>. Next, write the following template application:</p> -<div class="highlight"><pre><code class="language-java" data-lang="java"><span class="kd">public</span> <span class="kd">static</span> <span class="kt">void</span> <span class="nf">main</span><span class="o">(</span><span class="n">String</span><span class="o">[]</span> <span class="n">args</span><span class="o">)</span> <span class="o">{</span> +<div class="highlight"><pre><code class="language-java" data-lang="java"><span class="kd">public</span> <span class="kd">static</span> <span class="kt">void</span> <span class="nf">main</span><span class="p">(</span><span class="n">String</span><span class="o">[]</span> <span class="n">args</span><span class="o">)</span> <span class="o">{</span> <span class="n">DirectProvider</span> <span class="n">dp</span> <span class="o">=</span> <span class="k">new</span> <span class="n">DirectProvider</span><span class="o">();</span> @@ -676,7 +693,7 @@ $('#toc').on('click', 'a', function() { <h2 id="using-topology-strings">Using <code>Topology.strings()</code></h2> <p>The primary abstraction in Edgent is the <code>TStream</code>. A <em><code>TStream</code></em> represents the flow of data in an Edgent application; for example, the periodic floating point readings from a temperature sensor. The data items which are sent through a <code>TStream</code> are Java objects — in the "Hello Edgent!" example, we are sending two strings. There are a number of ways to create a <code>TStream</code>, and <code>Topology.strings()</code> is the simplest. The user specifies a number of strings which will be used as the stream's data items.</p> -<div class="highlight"><pre><code class="language-java" data-lang="java"><span class="kd">public</span> <span class="kd">static</span> <span class="kt">void</span> <span class="nf">main</span><span class="o">(</span><span class="n">String</span><span class="o">[]</span> <span class="n">args</span><span class="o">)</span> <span class="o">{</span> +<div class="highlight"><pre><code class="language-java" data-lang="java"><span class="kd">public</span> <span class="kd">static</span> <span class="kt">void</span> <span class="nf">main</span><span class="p">(</span><span class="n">String</span><span class="o">[]</span> <span class="n">args</span><span class="o">)</span> <span class="o">{</span> <span class="n">DirectProvider</span> <span class="n">dp</span> <span class="o">=</span> <span class="k">new</span> <span class="n">DirectProvider</span><span class="o">();</span> @@ -690,7 +707,7 @@ $('#toc').on('click', 'a', function() { <h2 id="printing-to-output">Printing to output</h2> <p><code>TStream.print()</code> can be used to print the data items of a stream to standard output by invoking the <code>toString()</code> method of each data item. In this case the data items are already strings, but in principle <code>TStream.print()</code> can be called on any stream, regardless of the datatype carried by the stream.</p> -<div class="highlight"><pre><code class="language-java" data-lang="java"><span class="kd">public</span> <span class="kd">static</span> <span class="kt">void</span> <span class="nf">main</span><span class="o">(</span><span class="n">String</span><span class="o">[]</span> <span class="n">args</span><span class="o">)</span> <span class="o">{</span> +<div class="highlight"><pre><code class="language-java" data-lang="java"><span class="kd">public</span> <span class="kd">static</span> <span class="kt">void</span> <span class="nf">main</span><span class="p">(</span><span class="n">String</span><span class="o">[]</span> <span class="n">args</span><span class="o">)</span> <span class="o">{</span> <span class="n">DirectProvider</span> <span class="n">dp</span> <span class="o">=</span> <span class="k">new</span> <span class="n">DirectProvider</span><span class="o">();</span> @@ -704,7 +721,7 @@ $('#toc').on('click', 'a', function() { <h2 id="submitting-the-application">Submitting the application</h2> <p>The only remaining step is to submit the application, which is performed by the <code>DirectProvider</code>. Submitting an Edgent application initializes the threads which execute the <code>Topology</code>, and begins processing its data sources.</p> -<div class="highlight"><pre><code class="language-java" data-lang="java"><span class="kd">public</span> <span class="kd">static</span> <span class="kt">void</span> <span class="nf">main</span><span class="o">(</span><span class="n">String</span><span class="o">[]</span> <span class="n">args</span><span class="o">)</span> <span class="o">{</span> +<div class="highlight"><pre><code class="language-java" data-lang="java"><span class="kd">public</span> <span class="kd">static</span> <span class="kt">void</span> <span class="nf">main</span><span class="p">(</span><span class="n">String</span><span class="o">[]</span> <span class="n">args</span><span class="o">)</span> <span class="o">{</span> <span class="n">DirectProvider</span> <span class="n">dp</span> <span class="o">=</span> <span class="k">new</span> <span class="n">DirectProvider</span><span class="o">();</span> @@ -752,7 +769,7 @@ Edgent! <div class="col-lg-12 footer"> Site last - generated: May 15, 2017 <br/> + generated: Dec 15, 2017 <br/> </div> </div> http://git-wip-us.apache.org/repos/asf/incubator-edgent-website/blob/9b42cd73/content/recipes/recipe_parallel_analytics.html ---------------------------------------------------------------------- diff --git a/content/recipes/recipe_parallel_analytics.html b/content/recipes/recipe_parallel_analytics.html index fdd53f9..b4a18fe 100644 --- a/content/recipes/recipe_parallel_analytics.html +++ b/content/recipes/recipe_parallel_analytics.html @@ -160,12 +160,6 @@ - <li><a href="samples">Samples</a></li> - - - - - <li><a href="faq">FAQ</a></li> @@ -315,6 +309,26 @@ window.location.href = uri; + <li><a href="../docs/home.html">Edgent Overview</a></li> + + + + + + + + + + <li><a href="../docs/power-of-edgent.html">The Power of Edgent</a></li> + + + + + + + + + <li><a href="../docs/faq.html">FAQ</a></li> @@ -342,7 +356,37 @@ window.location.href = uri; - <li><a href="../docs/edgent-getting-started.html">Getting started guide</a></li> + <li><a href="../docs/edgent-getting-started.html">Getting Started Guide</a></li> + + + + + + + + + + <li><a href="../docs/edgent-getting-started-samples.html">Quickstart with Edgent Samples</a></li> + + + + + + + + + + <li><a href="../docs/application-development.html">Understanding App Development</a></li> + + + + + + + + + + <li><a href="../docs/quickstart.html">Quickstart IBM Watson IoT Platform</a></li> @@ -510,33 +554,6 @@ window.location.href = uri; - <li><a href="#">Sample Programs</a> - <ul> - - - - - <li><a href="../docs/samples.html">Samples</a></li> - - - - - - - - - - <li><a href="../docs/quickstart.html">Quickstart IBM Watson IoT Platform</a></li> - - - - - - - </ul> - - - <li><a href="#">Using the Console</a> <ul> @@ -710,7 +727,7 @@ stream -> split(width,splitter) -> |-> isolate(10) -> pipeline-ch1 - <p>Many pipelines don't care what channel they're being constructed for. While the pipeline function typically yields the same pipeline processing for each channel there is no requirement for it to do so.</p> <p>In this simple recipe the pipeline receives a <code>TStream<Double></code> as input and generates a <code>TStream<String></code> as output.</p> -<div class="highlight"><pre><code class="language-java" data-lang="java"><span class="kd">static</span> <span class="n">BiFunction</span><span class="o"><</span><span class="n">TStream</span><span class="o"><</span><span class="n">Double</span><span class="o">>,</span> <span class="n">Integer</span><span class="o">,</span> <span class="n">TStream</span><span class="o"><</span><span class="n">String</span><span class="o">>></span> <span class="nf">pipeline</span><span class="o">()</span> <span class="o">{</span> +<div class="highlight"><pre><code class="language-java" data-lang="java"><span class="kd">static</span> <span class="n">BiFunction</span><span class="o"><</span><span class="n">TStream</span><span class="o"><</span><span class="n">Double</span><span class="o">>,</span> <span class="n">Integer</span><span class="o">,</span> <span class="n">TStream</span><span class="o"><</span><span class="n">String</span><span class="o">>></span> <span class="n">pipeline</span><span class="o">()</span> <span class="o">{</span> <span class="c1">// a simple 4 stage pipeline simulating some amount of work by sleeping</span> <span class="k">return</span> <span class="o">(</span><span class="n">stream</span><span class="o">,</span> <span class="n">channel</span><span class="o">)</span> <span class="o">-></span> <span class="o">{</span> @@ -763,7 +780,7 @@ stream -> split(width,splitter) -> |-> isolate(10) -> pipeline-ch1 - <span class="cm">/** * Process several tuples in parallel in a replicated pipeline. */</span> - <span class="kd">public</span> <span class="kd">static</span> <span class="kt">void</span> <span class="nf">main</span><span class="o">(</span><span class="n">String</span><span class="o">[]</span> <span class="n">args</span><span class="o">)</span> <span class="kd">throws</span> <span class="n">Exception</span> <span class="o">{</span> + <span class="kd">public</span> <span class="kd">static</span> <span class="kt">void</span> <span class="n">main</span><span class="o">(</span><span class="n">String</span><span class="o">[]</span> <span class="n">args</span><span class="o">)</span> <span class="kd">throws</span> <span class="n">Exception</span> <span class="o">{</span> <span class="n">DirectProvider</span> <span class="n">dp</span> <span class="o">=</span> <span class="k">new</span> <span class="n">DevelopmentProvider</span><span class="o">();</span> <span class="n">System</span><span class="o">.</span><span class="na">out</span><span class="o">.</span><span class="na">println</span><span class="o">(</span><span class="s">"development console url: "</span> @@ -796,7 +813,7 @@ stream -> split(width,splitter) -> |-> isolate(10) -> pipeline-ch1 - <span class="o">}</span> <span class="cm">/** Function to create analytic pipeline and add it to a stream */</span> - <span class="kd">private</span> <span class="kd">static</span> <span class="n">BiFunction</span><span class="o"><</span><span class="n">TStream</span><span class="o"><</span><span class="n">Double</span><span class="o">>,</span><span class="n">Integer</span><span class="o">,</span><span class="n">TStream</span><span class="o"><</span><span class="n">String</span><span class="o">>></span> <span class="nf">pipeline</span><span class="o">()</span> <span class="o">{</span> + <span class="kd">private</span> <span class="kd">static</span> <span class="n">BiFunction</span><span class="o"><</span><span class="n">TStream</span><span class="o"><</span><span class="n">Double</span><span class="o">>,</span><span class="n">Integer</span><span class="o">,</span><span class="n">TStream</span><span class="o"><</span><span class="n">String</span><span class="o">>></span> <span class="n">pipeline</span><span class="o">()</span> <span class="o">{</span> <span class="c1">// a simple 3 stage pipeline simulating some amount of work by sleeping</span> <span class="k">return</span> <span class="o">(</span><span class="n">stream</span><span class="o">,</span> <span class="n">channel</span><span class="o">)</span> <span class="o">-></span> <span class="o">{</span> @@ -810,11 +827,11 @@ stream -> split(width,splitter) -> |-> isolate(10) -> pipeline-ch1 - <span class="o">};</span> <span class="o">}</span> - <span class="kd">private</span> <span class="kd">static</span> <span class="kt">void</span> <span class="nf">sleep</span><span class="o">(</span><span class="kt">long</span> <span class="n">period</span><span class="o">,</span> <span class="n">TimeUnit</span> <span class="n">unit</span><span class="o">)</span> <span class="kd">throws</span> <span class="n">RuntimeException</span> <span class="o">{</span> + <span class="kd">private</span> <span class="kd">static</span> <span class="kt">void</span> <span class="n">sleep</span><span class="o">(</span><span class="kt">long</span> <span class="n">period</span><span class="o">,</span> <span class="n">TimeUnit</span> <span class="n">unit</span><span class="o">)</span> <span class="kd">throws</span> <span class="n">RuntimeException</span> <span class="o">{</span> <span class="k">try</span> <span class="o">{</span> <span class="n">Thread</span><span class="o">.</span><span class="na">sleep</span><span class="o">(</span><span class="n">unit</span><span class="o">.</span><span class="na">toMillis</span><span class="o">(</span><span class="n">period</span><span class="o">));</span> <span class="o">}</span> <span class="k">catch</span> <span class="o">(</span><span class="n">InterruptedException</span> <span class="n">e</span><span class="o">)</span> <span class="o">{</span> - <span class="k">throw</span> <span class="k">new</span> <span class="nf">RuntimeException</span><span class="o">(</span><span class="s">"Interrupted"</span><span class="o">,</span> <span class="n">e</span><span class="o">);</span> + <span class="k">throw</span> <span class="k">new</span> <span class="n">RuntimeException</span><span class="o">(</span><span class="s">"Interrupted"</span><span class="o">,</span> <span class="n">e</span><span class="o">);</span> <span class="o">}</span> <span class="o">}</span> @@ -851,7 +868,7 @@ stream -> split(width,splitter) -> |-> isolate(10) -> pipeline-ch1 - <div class="col-lg-12 footer"> Site last - generated: May 15, 2017 <br/> + generated: Dec 15, 2017 <br/> </div> </div>
