Use Count windows and keep emitting results say every 1000 elements and do
a sum. Or do without windows something like this which has the disadvantage
that it emits a new updated result for each new element (not a good thing
if your volume is high)-
https://github.com/sameeraxiomine/flinkinaction/
Hello all,
If anyone had idea, what could be the probable way to count the elements of
a current instance of the datastream. Is it possible?
DataStream> pointsWithGridCoordinates;
Regards,
Subash Basnet
Correction: dataset*
On Wed, Aug 17, 2016 at 4:39 PM, subash basnet wrote:
> Hello all,
>
> There is *count()* function in database to count the number of elements
> in the dataset. But it's not there in case of datastream. What could be the
> way to count the number of elements in case of datas
Hello all,
There is *count()* function in database to count the number of elements in
the dataset. But it's not there in case of datastream. What could be the
way to count the number of elements in case of datastream.
Best Regards,
Subash Basnet
