Mailing-List: contact user-help@storm.incubator.apache.org; run by ezmlm
Precedence: bulk
Reply-To: user@storm.incubator.apache.org
Received-SPF: pass (athena.apache.org: domain of saisaigraph@gmail.com
 designates 209.85.217.181 as permitted sender)
MIME-Version: 1.0
Date: Tue, 22 Jul 2014 03:41:19 -0400
Message-ID: 
 <CAGRmS-GEOzMqfF4YBJ8Lt0SEi6rhNvOG=GW-Or6OgMqqcKvpPw@mail.gmail.com>
Subject: Storm Nub questions.
From: Sai SaiGraph <saisaigraph@gmail.com>
To: user@storm.incubator.apache.org
Content-Type: multipart/alternative; boundary=001a11346d5c6ebf7c04fec359be

--001a11346d5c6ebf7c04fec359be
Content-Type: text/plain; charset=UTF-8

Hi
I m trying to understand parellism in Storm a few questions about it:

1. Lets say i have only a single file i am trying to test
with a single line L1
Now if i use 2 spouts, will there be 2 spouts created
or is it only 1 spout which will b created as there is only a line.

2. Is parallelism hint mean that it is not for sure
that multiple objects are created and it is upto
storm to create them based on the size of the data.

3. In a single node this will create 1 spout that is 1 object in 1 thread:

builder.setBolt(SPLIT_BOLT_ID, splitBolt, 1)
    .shuffleGrouping(SENTENCE_SPOUT_ID);

and In a single node this will create 2 spouts  that is 2 objects in 1
thread:

builder.setBolt(SPLIT_BOLT_ID, splitBolt, 2)
    .shuffleGrouping(SENTENCE_SPOUT_ID);

My questions is, is this really parallelism.
Is it true to say this is parallelism at a thread level
in a single node will this really help achieve the parallelism.

The reason i ask is because in hadoop we achieve parallelisn
at a process level which is easy to digest
that we are achieving parallelism, but in storm i am
confused. Can some one pls pour some light.
Thanks
Sai

--001a11346d5c6ebf7c04fec359be
Content-Type: text/html; charset=UTF-8
Content-Transfer-Encoding: quoted-printable

<div dir=3D"ltr"><div><div>Hi<br>I m trying to understand parellism in Stor=
m a few questions about it:<br><br>1. Lets say i have only a single file i =
am trying to test<br>with a single line L1<br>Now if i use 2 spouts, will t=
here be 2 spouts created<br>
or is it only 1 spout which will b created as there is only a line.<br><br>=
2. Is parallelism hint mean that it is not for sure<br>that multiple object=
s are created and it is upto<br>storm to create them based on the size of t=
he data.<br>
<br>3. In a single node this will create 1 spout that is 1 object in 1 thre=
ad:<br>=C2=A0=C2=A0=C2=A0 <br>builder.setBolt(SPLIT_BOLT_ID, splitBolt, 1)<=
br>=C2=A0=C2=A0=C2=A0 .shuffleGrouping(SENTENCE_SPOUT_ID);<br>=C2=A0=C2=A0=
=C2=A0=C2=A0=C2=A0=C2=A0 <br>and In a single node this will create 2 spouts=
=C2=A0 that is 2 objects in 1 thread:<br>
=C2=A0=C2=A0=C2=A0 <br>builder.setBolt(SPLIT_BOLT_ID, splitBolt, 2)<br>=C2=
=A0=C2=A0=C2=A0 .shuffleGrouping(SENTENCE_SPOUT_ID);<br><br>My questions is=
, is this really parallelism.<br>Is it true to say this is parallelism at a=
 thread level<br>in a single node will this really help achieve the paralle=
lism.<br>
<br>The reason i ask is because in hadoop we achieve parallelisn <br>at a p=
rocess level which is easy to digest<br>that we are achieving parallelism, =
but in storm i am <br>confused. Can some one pls pour some light.<br></div>
Thanks<br></div>Sai<br></div>

--001a11346d5c6ebf7c04fec359be--