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. Example: this is the content

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 i noticed that i cannot modi

Re: Passing two value to the ConvergenceCriterion function

Ok! On 14 Mar 2016, at 10:41, Robert Metzger 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 > wrote: > Hi &g

Passing two value to the ConvergenceCriterion function

Hi I want to send two value to the ConvergenceCriterion function, so i decided to use an aggregator of Tuple2. But then, when i implement Aggregator, i cannot do that because Tuple2 doesn’t implement Value. So i tried to create a class Tuple2Value that implements Value, but here i get stuck b

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