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
