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>
