Why the ".keyBy"? I don't want to count tuples by Key. I simply want to count all tuples that are contained in a window.
On Fri, Feb 26, 2016 at 9:14 AM, Till Rohrmann <[email protected]> wrote: > Hi Saiph, > > you can do it the following way: > > input.keyBy(0).timeWindow(Time.seconds(10)).fold(0, new > FoldFunction<Tuple2<Integer, Integer>, Integer>() { > @Override > public Integer fold(Integer integer, Tuple2<Integer, Integer> o) throws > Exception { > return integer + 1; > } > }); > > Cheers, > Till > > > On Thu, Feb 25, 2016 at 7:58 PM, Saiph Kappa <[email protected]> > wrote: > >> Hi, >> >> In Flink Stream what's the best way of counting the number of tuples >> within a window of 10 seconds? Using a map-reduce task? Asking because in >> spark there is the method rawStream.countByWindow(Seconds(x)). >> >> Thanks. >> > >
