Yeah no problem. Its not an optimised solution but I think it gives enough
understanding of how reduceGroup works.
On 29-Apr-2016 5:17 PM, "Stefano Baghino"
wrote:
> Thanks for sharing the solution, Punit.
>
> On Fri, Apr 29, 2016 at 1:40 PM, Punit Naik
> wrote:
>
>> Anyways, I managed to do it.
Thanks for sharing the solution, Punit.
On Fri, Apr 29, 2016 at 1:40 PM, Punit Naik 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
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;
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
