You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by ka...@apache.org on 2016/08/23 01:13:59 UTC
svn commit: r1757294 [2/2] - in /storm/site/publish: ./ releases/0.10.0/
releases/0.10.1/ releases/1.0.0/ releases/1.0.1/ releases/1.0.2/
releases/2.0.0-SNAPSHOT/ releases/current/
Modified: storm/site/publish/releases/current/flux.html
URL: http://svn.apache.org/viewvc/storm/site/publish/releases/current/flux.html?rev=1757294&r1=1757293&r2=1757294&view=diff
==============================================================================
--- storm/site/publish/releases/current/flux.html (original)
+++ storm/site/publish/releases/current/flux.html Tue Aug 23 01:13:59 2016
@@ -253,6 +253,15 @@ recommended).</p>
</dependency>
</code></p>
+<p>Using shell spouts and bolts requires additional Flux Wrappers library:
+<code>xml
+<dependency>
+ <groupId>org.apache.storm</groupId>
+ <artifactId>flux-wrappers</artifactId>
+ <version>${storm.version}</version>
+</dependency>
+</code></p>
+
<h4 id="creating-a-flux-enabled-topology-jar">Creating a Flux-Enabled Topology JAR</h4>
<p>The example below illustrates Flux usage with the Maven shade plugin:</p>
@@ -264,6 +273,12 @@ recommended).</p>
<span class="nt"><artifactId></span>flux-core<span class="nt"></artifactId></span>
<span class="nt"><version></span>${storm.version}<span class="nt"></version></span>
<span class="nt"></dependency></span>
+ <span class="c"><!-- Flux Wrappers include --></span>
+ <span class="nt"><dependency></span>
+ <span class="nt"><groupId></span>org.apache.storm<span class="nt"></groupId></span>
+ <span class="nt"><artifactId></span>flux-wrappers<span class="nt"></artifactId></span>
+ <span class="nt"><version></span>${storm.version}<span class="nt"></version></span>
+ <span class="nt"></dependency></span>
<span class="c"><!-- add user dependencies here... --></span>
@@ -359,9 +374,9 @@ Parsing file: /Users/hsimpson/Projects/d
---------- TOPOLOGY DETAILS ----------
Name: shell-topology
--------------- SPOUTS ---------------
-sentence-spout[1](org.apache.storm.flux.spouts.GenericShellSpout)
+sentence-spout[1](org.apache.storm.flux.wrappers.spouts.FluxShellSpout)
---------------- BOLTS ---------------
-splitsentence[1](org.apache.storm.flux.bolts.GenericShellBolt)
+splitsentence[1](org.apache.storm.flux.wrappers.bolts.FluxShellBolt)
log[1](org.apache.storm.flux.wrappers.bolts.LogInfoBolt)
count[1](org.apache.storm.testing.TestWordCounter)
--------------- STREAMS ---------------
@@ -637,7 +652,7 @@ well.</p>
<p>Shell spout example:</p>
<div class="highlight"><pre><code class="language-yaml" data-lang="yaml"><span class="s">spouts</span><span class="pi">:</span>
<span class="pi">-</span> <span class="s">id</span><span class="pi">:</span> <span class="s2">"</span><span class="s">sentence-spout"</span>
- <span class="s">className</span><span class="pi">:</span> <span class="s2">"</span><span class="s">org.apache.storm.flux.spouts.GenericShellSpout"</span>
+ <span class="s">className</span><span class="pi">:</span> <span class="s2">"</span><span class="s">org.apache.storm.flux.wrappers.spouts.FluxShellSpout"</span>
<span class="c1"># shell spout constructor takes 2 arguments: String[], String[]</span>
<span class="s">constructorArgs</span><span class="pi">:</span>
<span class="c1"># command line</span>
@@ -704,7 +719,7 @@ well.</p>
<div class="highlight"><pre><code class="language-yaml" data-lang="yaml"><span class="c1"># bolt definitions</span>
<span class="s">bolts</span><span class="pi">:</span>
<span class="pi">-</span> <span class="s">id</span><span class="pi">:</span> <span class="s2">"</span><span class="s">splitsentence"</span>
- <span class="s">className</span><span class="pi">:</span> <span class="s2">"</span><span class="s">org.apache.storm.flux.bolts.GenericShellBolt"</span>
+ <span class="s">className</span><span class="pi">:</span> <span class="s2">"</span><span class="s">org.apache.storm.flux.wrappers.bolts.FluxShellBolt"</span>
<span class="s">constructorArgs</span><span class="pi">:</span>
<span class="c1"># command line</span>
<span class="pi">-</span> <span class="pi">[</span><span class="s2">"</span><span class="s">python"</span><span class="pi">,</span> <span class="s2">"</span><span class="s">splitsentence.py"</span><span class="pi">]</span>
@@ -826,7 +841,7 @@ same file. Includes may be either files,
<span class="c1"># spout definitions</span>
<span class="s">spouts</span><span class="pi">:</span>
<span class="pi">-</span> <span class="s">id</span><span class="pi">:</span> <span class="s2">"</span><span class="s">sentence-spout"</span>
- <span class="s">className</span><span class="pi">:</span> <span class="s2">"</span><span class="s">org.apache.storm.flux.spouts.GenericShellSpout"</span>
+ <span class="s">className</span><span class="pi">:</span> <span class="s2">"</span><span class="s">org.apache.storm.flux.wrappers.spouts.FluxShellSpout"</span>
<span class="c1"># shell spout constructor takes 2 arguments: String[], String[]</span>
<span class="s">constructorArgs</span><span class="pi">:</span>
<span class="c1"># command line</span>
@@ -838,7 +853,7 @@ same file. Includes may be either files,
<span class="c1"># bolt definitions</span>
<span class="s">bolts</span><span class="pi">:</span>
<span class="pi">-</span> <span class="s">id</span><span class="pi">:</span> <span class="s2">"</span><span class="s">splitsentence"</span>
- <span class="s">className</span><span class="pi">:</span> <span class="s2">"</span><span class="s">org.apache.storm.flux.bolts.GenericShellBolt"</span>
+ <span class="s">className</span><span class="pi">:</span> <span class="s2">"</span><span class="s">org.apache.storm.flux.wrappers.bolts.FluxShellBolt"</span>
<span class="s">constructorArgs</span><span class="pi">:</span>
<span class="c1"># command line</span>
<span class="pi">-</span> <span class="pi">[</span><span class="s2">"</span><span class="s">python"</span><span class="pi">,</span> <span class="s2">"</span><span class="s">splitsentence.py"</span><span class="pi">]</span>