You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samoa.apache.org by nk...@apache.org on 2016/09/25 20:40:00 UTC
svn commit: r1762231 [3/3] - in /incubator/samoa/site: ./ documentation/
Modified: incubator/samoa/site/documentation/Topology-Builder.html
URL: http://svn.apache.org/viewvc/incubator/samoa/site/documentation/Topology-Builder.html?rev=1762231&r1=1762230&r2=1762231&view=diff
==============================================================================
--- incubator/samoa/site/documentation/Topology-Builder.html (original)
+++ incubator/samoa/site/documentation/Topology-Builder.html Sun Sep 25 20:39:59 2016
@@ -73,35 +73,32 @@
</header>
<article class="post-content">
- <p><code class="highlighter-rouge">TopologyBuilder</code> is a builder class which builds physical units of the topology and assemble them together. Each topology has a name. Following code snippet shows all the steps of creating a topology with one <code class="highlighter-rouge">EntrancePI</code>, two PIs and a few streams.</p>
-
-<p>```
-TopologyBuilder builder = new TopologyBuilder(factory) // ComponentFactory factory
-builder.initTopology(“Parma Topology”); //initiates an empty topology with a name
-//<strong>**</strong><strong>**</strong><strong>**</strong><strong>**</strong><strong>**</strong><strong>Topology building</strong><strong>**</strong><strong>**</strong><strong>**</strong><strong>**</strong><strong>**</strong>***
+ <p><code>TopologyBuilder</code> is a builder class which builds physical units of the topology and assemble them together. Each topology has a name. Following code snippet shows all the steps of creating a topology with one <code>EntrancePI</code>, two PIs and a few streams.</p>
+<div class="highlight"><pre><code class="language-" data-lang="">TopologyBuilder builder = new TopologyBuilder(factory) // ComponentFactory factory
+builder.initTopology("Parma Topology"); //initiates an empty topology with a name
+//********************************Topology building***********************************
StreamSource sourceProcessor = new StreamSource(inputPath,d,sampleSize,fpmGap,epsilon,phi,numSamples);
builder.addEntranceProcessor(sourceProcessor);
Stream sourceDataStream = builder.createStream(sourceProcessor);
sourceProcessor.setDataStream(sourceDataStream);
Stream sourceControlStream = builder.createStream(sourceProcessor);
-sourceProcessor.setControlStream(sourceControlStream);</p>
+sourceProcessor.setControlStream(sourceControlStream);
-<p>Sampler sampler = new Sampler(minFreqPercent,sampleSize,(float)epsilon,outputPath,sampler);
+Sampler sampler = new Sampler(minFreqPercent,sampleSize,(float)epsilon,outputPath,sampler);
builder.addProcessor(sampler, numSamples);
builder.connectInputAllStream(sourceControlStream, sampler);
-builder.connectInputShuffleStream(sourceDataStream, sampler);</p>
+builder.connectInputShuffleStream(sourceDataStream, sampler);
-<p>Stream samplerDataStream = builder.createStream(sampler);
+Stream samplerDataStream = builder.createStream(sampler);
samplerP.setSamplerDataStream(samplerDataStream);
Stream samplerControlStream = builder.createStream(sampler);
-samplerP.setSamplerControlStream(samplerControlStream);</p>
+samplerP.setSamplerControlStream(samplerControlStream);
-<p>Aggregator aggregatorProcessor = new Aggregator(outputPath,(long)numSamples,(long)sampleSize,(long)reqApproxNum,(float)epsilon);
+Aggregator aggregatorProcessor = new Aggregator(outputPath,(long)numSamples,(long)sampleSize,(long)reqApproxNum,(float)epsilon);
builder.addProcessor(aggregatorProcessor, numAggregators);
builder.connectInputKeyStream(samplerDataStream, aggregatorProcessor);
builder.connectInputAllStream(samplerControlStream, aggregatorProcessor);
-```</p>
-
+</code></pre></div>
</article>
<!-- </div> -->
Modified: incubator/samoa/site/index.html
URL: http://svn.apache.org/viewvc/incubator/samoa/site/index.html?rev=1762231&r1=1762230&r2=1762231&view=diff
==============================================================================
--- incubator/samoa/site/index.html (original)
+++ incubator/samoa/site/index.html Sun Sep 25 20:39:59 2016
@@ -14,7 +14,7 @@
<h2>Scalable Advanced Massive Online Analysis</h2>
<h3>Apache SAMOA is currently undergoing incubation at the Apache Software Foundation.
- </br>Latest source release: <a href="https://www.apache.org/dist/incubator/samoa/0.3.0-incubating"> 0.3.0-incubating</a>
+ </br>Latest source release: <a href="https://www.apache.org/dist/incubator/samoa/0.4.0-incubating"> 0.4.0-incubating</a>
</br>View on <a href=" https://github.com/apache/incubator-samoa">GitHub</a>.
</h3>
<div id="slideshow">
@@ -61,6 +61,13 @@
</ul>
</section>
+
+ <section class="tutorial">
+ <h1>News</h1>
+ <h2><a href="http://events.linuxfoundation.org/events/apache-big-data-north-america/program/schedule">Apache Big Data North America, 2016<style="max-width:100%;"></a></h2>
+ <h2><a href="http://events.linuxfoundation.org/events/archive/2015/apache-big-data-europe/program/schedule">Apache Big Data Europe, 2015<style="max-width:100%;"></a></h2>
+ </section>
+
<section class="tutorial">
<h1>Slides</h1>
<h2><a href="https://speakerdeck.com/gdfm/samoa-a-platform-for-mining-big-data-streams-2"><img src="samoa-slides.jpg" alt="SAMOA Slides" data-canonical-src="samoa-slides.jpg" style="max-width:100%;"></a></h2>