Thanks for sharing the solution, Punit.
On Fri, Apr 29, 2016 at 1:40 PM, Punit Naik <[email protected]> wrote:
> Anyways, I managed to do it. you should attach the following code block to
> your groupBy
> .reduceGroup {
> (in, out: org.apache.flink.util.Collector[(Map[String,String],
> Int)]) => // Map[String,String] is the data type I want to output along
> with the count as Int in a Tuple
> var v:Int = 0;
> var k:Map[String,String]=Map()
> for (t <- in) {
> v+=1;
> k=t
> }
> out.collect((k,v))
>
> On Fri, Apr 29, 2016 at 3:59 PM, Punit Naik <[email protected]>
> wrote:
>
>> I have a dataset which has maps. I have performed a groupBy on a key and
>> I want to count all the elements in a particular group. How do I do this?
>>
>> --
>> Thank You
>>
>> Regards
>>
>> Punit Naik
>>
>
>
>
> --
> Thank You
>
> Regards
>
> Punit Naik
>
--
BR,
Stefano Baghino
Software Engineer @ Radicalbit
