aggregation problem

Hi everybody In a DeltaIteration I have a DataSet> where, at a certain point of the iteration, i need to count the total number of tuples and the total number of elements in the HashSet of each tuple, and then send both value to the ConvergenceCriterion function.

modify solution set within the delta iteration

I try to explain my situation I’m doing a delta iteration in which my solution set in something like: DataSet> Depending on a different dataset that i retrieve during the iteration, i need to update the hashMap of the solution set in order to keep it up to date. But

Re: Passing two value to the ConvergenceCriterion function

Ok! On 14 Mar 2016, at 10:41, Robert Metzger <rmetz...@apache.org> wrote: > Hi, > > take a look at the "Record" class. That one implements the Value interface > and can have multiple values. > > On Fri, Mar 11, 2016 at 6:01 PM, Riccardo Diomedi > <r

time spent for iteration

Is it possible to add timer for the time spent for iteration when iterate operator or the delta iterate operator is performed? thanks Riccardo