Bulk Iteration

classic Classic list List threaded Threaded
2 messages Options
Reply | Threaded
Open this post in threaded view
|

Bulk Iteration

Alieh
Hello all,

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


Cheers,
Alieh

Reply | Threaded
Open this post in threaded view
|

Re: Bulk Iteration

Gábor Gévay
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 <[hidden email]> wrote:
> Hello all,
>
> using Bulk iteration, is there any way to know the number of iterations?
>
>
> Cheers,
> Alieh
>