flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Robert Metzger <rmetz...@apache.org>
Subject Re: Passing two value to the ConvergenceCriterion function
Date Mon, 14 Mar 2016 09:41:12 GMT

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 <
riccardo.diomedi91@gmail.com> wrote:

> 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<Tuple2>, 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 because i don’t know how to do it in a proper way.
> Any suggestions?
> Is there an alternative (and easy) way to pass two values to the
> convergenceCriterion function?
> Thank you
> Riccardo!

View raw message