Return-Path: X-Original-To: apmail-flink-user-archive@minotaur.apache.org Delivered-To: apmail-flink-user-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 0080019C04 for ; Mon, 14 Mar 2016 09:41:38 +0000 (UTC) Received: (qmail 29331 invoked by uid 500); 14 Mar 2016 09:41:34 -0000 Delivered-To: apmail-flink-user-archive@flink.apache.org Received: (qmail 29216 invoked by uid 500); 14 Mar 2016 09:41:34 -0000 Mailing-List: contact user-help@flink.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: user@flink.apache.org Delivered-To: mailing list user@flink.apache.org Received: (qmail 29116 invoked by uid 99); 14 Mar 2016 09:41:34 -0000 Received: from mail-relay.apache.org (HELO mail-relay.apache.org) (140.211.11.15) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 14 Mar 2016 09:41:34 +0000 Received: from mail-lb0-f182.google.com (mail-lb0-f182.google.com [209.85.217.182]) by mail-relay.apache.org (ASF Mail Server at mail-relay.apache.org) with ESMTPSA id CF8861A0040 for ; Mon, 14 Mar 2016 09:41:33 +0000 (UTC) Received: by mail-lb0-f182.google.com with SMTP id xr8so225528351lbb.1 for ; Mon, 14 Mar 2016 02:41:33 -0700 (PDT) X-Gm-Message-State: AD7BkJIo1hXigmv1ujAcOMfZZjYcMzAMG7U+/A209J84FbhBtyFysN7pekJnaUNz4NMwuC1Fyq+qyBFpujQ0pA== X-Received: by 10.25.33.1 with SMTP id h1mr7689034lfh.151.1457948492412; Mon, 14 Mar 2016 02:41:32 -0700 (PDT) MIME-Version: 1.0 Received: by 10.112.190.67 with HTTP; Mon, 14 Mar 2016 02:41:12 -0700 (PDT) In-Reply-To: <3B29C8B9-1E8C-4E82-A85C-D52D39165A8B@gmail.com> References: <3B29C8B9-1E8C-4E82-A85C-D52D39165A8B@gmail.com> From: Robert Metzger Date: Mon, 14 Mar 2016 10:41:12 +0100 X-Gmail-Original-Message-ID: Message-ID: Subject: Re: Passing two value to the ConvergenceCriterion function To: "user@flink.apache.org" Content-Type: multipart/alternative; boundary=001a1140245afdc559052dff15d6 --001a1140245afdc559052dff15d6 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: quoted-printable 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 < 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, i cannot do that because Tuple2 doesn=E2=80=99t imple= ment Value. > So i tried to create a class Tuple2Value that implements Value, but here = i > get stuck because i don=E2=80=99t 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! --001a1140245afdc559052dff15d6 Content-Type: text/html; charset=UTF-8 Content-Transfer-Encoding: quoted-printable

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 <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<T= uple2>, i cannot do that because Tuple2 doesn=E2=80=99t implement Value.=
So i tried to create a class Tuple2Value that implements Value, but here i = get stuck because i don=E2=80=99t know how to do it in a proper way.
Any suggestions?
Is there an alternative (and easy) way to pass two values to the convergenc= eCriterion function?

Thank you

Riccardo!

--001a1140245afdc559052dff15d6--