You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@flink.apache.org by Alieh <sa...@informatik.uni-leipzig.de> on 2017/09/11 12:57:10 UTC

Bulk Iteration

Hello all,

using Bulk iteration, is there any way to know the number of iterations?


Cheers,
Alieh

Re: Bulk Iteration

Posted by Gábor Gévay <gg...@gmail.com>.

Hello Alieh,

If you set the logging to a more verbose level, then Flink prints a
log msg at every iteration.

If you need the current iteration number inside your code, then you
should create your UDF as an AbstractRichFunction, where you can call
getIterationRuntimeContext(), which has getSuperstepNumber().

Best,
Gabor

On Mon, Sep 11, 2017 at 2:57 PM, Alieh <sa...@informatik.uni-leipzig.de> wrote:
> Hello all,
>
> using Bulk iteration, is there any way to know the number of iterations?
>
>
> Cheers,
> Alieh
>