Mailing-List: contact user-help@flink.apache.org; run by ezmlm
Precedence: bulk
Reply-To: user@flink.apache.org
MIME-Version: 1.0
In-Reply-To: <947E9838-FDE6-4C43-AD1E-7BCF39790A67@gmail.com>
References: <947E9838-FDE6-4C43-AD1E-7BCF39790A67@gmail.com>
Date: Thu, 28 Apr 2016 17:50:59 +0200
Message-ID: 
 <CAJZ2dcUUMsWZjdn+Fi2bWQoYcj-jDMcaS01Js3DXXAJudrsyLg@mail.gmail.com>
Subject: Re: aggregation problem
From: Vasiliki Kalavri <vasilikikalavri@gmail.com>
To: user@flink.apache.org
Content-Type: multipart/alternative; boundary=001a11336c961be27305318d7eb2

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

Hi Riccardo,

can you please be a bit more specific? What do you mean by "it didn't
work"? Did it crash? Did it give you a wrong value? Something else?

-Vasia.

On 28 April 2016 at 16:52, Riccardo Diomedi <riccardo.diomedi91@gmail.com>
wrote:

> Hi everybody
>
> In a DeltaIteration I have a DataSet<Tuple3<K, V, HashSet<K>>> where, at =
a
> certain point of the iteration, i need to count the total number of tuple=
s
> and the total number of elements in the HashSet of each tuple, and then
> send both value to the ConvergenceCriterion function.
>
> Example:
>
> this is the content of my DataSet:
> (*1*,2,*[2,3]*)
> (*2*,1,*[3,4]*)
> (*3*,2,[*4,5]*)
>
> i should have:
> first count: *3* (1,2,3)
> second count: *4* (2,3,4,5)
>
> i tried to iterate the dataset through a flatMap and exploit so an
> aggregator, putting an HashSet into it(Aggregator), but it didn=E2=80=99t=
 work!
>
> Do you have any suggestion??
>
> thanks
>
> Riccardo
>

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

<div dir=3D"ltr"><div class=3D"gmail_default" style=3D"font-family:verdana,=
sans-serif;font-size:small;color:#330000">Hi Riccardo,</div><div class=3D"g=
mail_default" style=3D"font-family:verdana,sans-serif;font-size:small;color=
:#330000"><br></div><div class=3D"gmail_default" style=3D"font-family:verda=
na,sans-serif;font-size:small;color:#330000">can you please be a bit more s=
pecific? What do you mean by &quot;it didn&#39;t work&quot;? Did it crash? =
Did it give you a wrong value? Something else?</div><div class=3D"gmail_def=
ault" style=3D"font-family:verdana,sans-serif;font-size:small;color:#330000=
"><br></div><div class=3D"gmail_default" style=3D"font-family:verdana,sans-=
serif;font-size:small;color:#330000">-Vasia.</div></div><div class=3D"gmail=
_extra"><br><div class=3D"gmail_quote">On 28 April 2016 at 16:52, Riccardo =
Diomedi <span dir=3D"ltr">&lt;<a href=3D"mailto:riccardo.diomedi91@gmail.co=
m" target=3D"_blank">riccardo.diomedi91@gmail.com</a>&gt;</span> wrote:<br>=
<blockquote class=3D"gmail_quote" style=3D"margin:0 0 0 .8ex;border-left:1p=
x #ccc solid;padding-left:1ex"><div style=3D"word-wrap:break-word">Hi every=
body<div><br></div><div>In a DeltaIteration I have a DataSet&lt;Tuple3&lt;K=
, V, HashSet&lt;K&gt;&gt;&gt; where, at a certain point of the iteration, i=
 need to count the total number of tuples and the total number of elements =
in the HashSet of each tuple, and then send both value to the ConvergenceCr=
iterion function.</div><div><br></div><div>Example:</div><div><br></div><di=
v>this is the content of my DataSet:</div><div>(<b>1</b>,2,<b>[2,3]</b>)</d=
iv><div>(<b>2</b>,1,<b>[3,4]</b>)</div><div>(<b>3</b>,2,[<b>4,5]</b>)</div>=
<div><br></div><div>i should have:</div><div>first count: <u>3</u> (1,2,3)<=
/div><div>second count: <u>4</u>=C2=A0(2,3,4,5)</div><div><br></div><div>i =
tried to iterate the dataset through a flatMap and exploit so an aggregator=
, putting an HashSet into it(Aggregator), but it didn=E2=80=99t work!</div>=
<div><br></div><div>Do you have any suggestion??</div><div><br></div><div>t=
hanks=C2=A0</div><span class=3D"HOEnZb"><font color=3D"#888888"><div><br></=
div><div>Riccardo</div></font></span></div></blockquote></div><br></div>

--001a11336c961be27305318d7eb2--