You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@flink.apache.org by Attila Bernáth <be...@gmail.com> on 2014/10/16 10:49:43 UTC
how many iterations (supersteps) were made
Dear All,
In an IterativeDataSet I can set the maximum number of iterations to make.
Can I find out how many supersteps were in fact made?
Attila
Re: how many iterations (supersteps) were made
Posted by Fabian Hueske <fh...@apache.org>.
Hi Attila,
you can also call getIterationRuntimeContext.getSuperstepNumber() in any
function that is applied within an iteration.
Best, Fabian
2014-10-16 11:08 GMT+02:00 Fabian Hueske <fh...@gmail.com>:
> Hi Attila,
>
> you can also call getIterationRuntimeContext.getSuperstepNumber() in any
> function that is applied within an iteration.
>
> Best, Fabian
>
> 2014-10-16 11:05 GMT+02:00 Ufuk Celebi <uc...@apache.org>:
>
>> Hey Attila,
>>
>> 1) Yes. Both iterate and deltaIterate take an argument for the maximum
>> number of iterations to be made.
>>
>> 2) Yes. You can use an Accumulator [1] to count the number of iterations.
>> You can also have a look at log output (logged at INFO level).
>>
>> Does this help?
>>
>> – Ufuk
>>
>> [1]
>> http://flink.incubator.apache.org/docs/0.7-incubating/programming_guide.html#accumulators--counters
>>
>> On 16 Oct 2014, at 10:49, Attila Bernáth <be...@gmail.com> wrote:
>>
>> > Dear All,
>> >
>> > In an IterativeDataSet I can set the maximum number of iterations to
>> make.
>> > Can I find out how many supersteps were in fact made?
>> >
>> > Attila
>>
>>
>
Re: how many iterations (supersteps) were made
Posted by Fabian Hueske <fh...@gmail.com>.
Hi Attila,
you can also call getIterationRuntimeContext.getSuperstepNumber() in any
function that is applied within an iteration.
Best, Fabian
2014-10-16 11:05 GMT+02:00 Ufuk Celebi <uc...@apache.org>:
> Hey Attila,
>
> 1) Yes. Both iterate and deltaIterate take an argument for the maximum
> number of iterations to be made.
>
> 2) Yes. You can use an Accumulator [1] to count the number of iterations.
> You can also have a look at log output (logged at INFO level).
>
> Does this help?
>
> – Ufuk
>
> [1]
> http://flink.incubator.apache.org/docs/0.7-incubating/programming_guide.html#accumulators--counters
>
> On 16 Oct 2014, at 10:49, Attila Bernáth <be...@gmail.com> wrote:
>
> > Dear All,
> >
> > In an IterativeDataSet I can set the maximum number of iterations to
> make.
> > Can I find out how many supersteps were in fact made?
> >
> > Attila
>
>
Re: how many iterations (supersteps) were made
Posted by Ufuk Celebi <uc...@apache.org>.
Hey Attila,
1) Yes. Both iterate and deltaIterate take an argument for the maximum number of iterations to be made.
2) Yes. You can use an Accumulator [1] to count the number of iterations. You can also have a look at log output (logged at INFO level).
Does this help?
– Ufuk
[1] http://flink.incubator.apache.org/docs/0.7-incubating/programming_guide.html#accumulators--counters
On 16 Oct 2014, at 10:49, Attila Bernáth <be...@gmail.com> wrote:
> Dear All,
>
> In an IterativeDataSet I can set the maximum number of iterations to make.
> Can I find out how many supersteps were in fact made?
>
> Attila