Hi Andres
Does something like this solve what you're trying to achieve?
https://github.com/apache/flink/pull/918/files
Regards
Sachin
On Sep 4, 2015 6:24 PM, "Stephan Ewen" wrote:
> I think you can do this with the current interface. The convergence
> criterion object stays around, so you should
I think you can do this with the current interface. The convergence
criterion object stays around, so you should be able to simply store the
current aggregator value in a field (when the check is invoked). Any round
but the first could compare against that field.
On Fri, Sep 4, 2015 at 2:25 PM, An
Hi,
I trying to implement some machine learning algorithms that involve
several iterations until convergence (to a fixed point).
My idea is to use a IterativeDataSet with an Aggregator which produces
the result (i.e. a set of parameters defining the model).
>From the interface "ConvergenceCrite
