Re: Scala: registerAggregationConvergenceCriterion

2015-07-17 Thread Maximilian Alber
Thanks Till! That should work for me. Cheers, Max On Fri, Jul 17, 2015 at 4:13 PM, Till Rohrmann wrote: > Hi Max, > > I’d recommend you to use the DataSet[T].iterateWithTermination method > instead. It has the following syntax: iterationWithTermination(maxIterations: > Int)(stepFunction: (Data

Re: Scala: registerAggregationConvergenceCriterion

2015-07-17 Thread Till Rohrmann
Hi Max, I’d recommend you to use the DataSet[T].iterateWithTermination method instead. It has the following syntax: iterationWithTermination(maxIterations: Int)(stepFunction: (DataSet[T] => (DataSet[T], DataSet[_])): DataSet[T] There you see that your step function has to return a tuple of data s

Scala: registerAggregationConvergenceCriterion

2015-07-17 Thread Maximilian Alber
Hi Flinksters, I try to use BulkIterations with a convergence criterion. Unfortunately, I'm not sure how to use them and I couldn't find a nice example. Here are two code snippets and the resulting error, maybe someone can help. I'm working on the current branch. Example1: if(true){ val d