flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Vasiliki Kalavri <vasilikikala...@gmail.com>
Subject Re: Fixpoint api
Date Fri, 11 Jul 2014 14:55:53 GMT

thanks for the reply!

My delta iteration doesn't have a convergence criterion (other than the
default empty workset that is).
If I'm not mistaken, one can't define a custom convergence criterion in a
delta iteration.
I think I had opened an issue for this at some point, but it was low
priority and we didn't decide on it.

Even if I do define a custom convergence criterion though, that would mean
that I will need to run at least one delta iteration, even if the maximum
number of iterations has already been reached.

What I am looking for is more something like the following:

int iterationsLeft;

bulkResult = doBulkIterations(parameters, dependencies, stepFunction,
maxIterations); //somehow sets iterationsLeft
if (iterationsLeft > 0 ) {
  doDeltaIterations(bulkResult, dependencies, stepFunction, iterationsLeft);


On 11 July 2014 14:25, Stephan Ewen <sewen@apache.org> wrote:

> Hey Vasia!
> Nice work, it looks really cool!
> Concerning the problem of figuring out the number of iterations:
>  - In the long run we can save this with the incremental rollout that we
> are working on
>  - As a temporary workaround, you could store the number of elapsed
> iterations in a static variable somewhere. You set it from the "open()" or
> "close()" function of one of the UDFs. The convergence criterion for the
> delta iterations can pick it up from there (access the static variable).
> Concerning the edges with / without weights: Can you use a custom data type
> and have the weight "null" when they are not set/used?
> Greetings,
> Stephan

  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message