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 83D3519F6C for ; Tue, 19 Apr 2016 10:14:52 +0000 (UTC) Received: (qmail 83646 invoked by uid 500); 19 Apr 2016 10:14:52 -0000 Delivered-To: apmail-flink-user-archive@flink.apache.org Received: (qmail 83530 invoked by uid 500); 19 Apr 2016 10:14:52 -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 83521 invoked by uid 99); 19 Apr 2016 10:14:52 -0000 Received: from mail-relay.apache.org (HELO mail-relay.apache.org) (140.211.11.15) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 19 Apr 2016 10:14:52 +0000 Received: from mail-wm0-f53.google.com (mail-wm0-f53.google.com [74.125.82.53]) by mail-relay.apache.org (ASF Mail Server at mail-relay.apache.org) with ESMTPSA id C68D41A012C for ; Tue, 19 Apr 2016 10:14:51 +0000 (UTC) Received: by mail-wm0-f53.google.com with SMTP id n3so21115258wmn.0 for ; Tue, 19 Apr 2016 03:14:51 -0700 (PDT) X-Gm-Message-State: AOPr4FVCIc7e5ub44p21hJmf4a8QzXTMRCX2Z6mDlegKCP5zxzQq9ZhaPnBuPBF9cFHf1bPb+v+BMlYRrGkvSA== MIME-Version: 1.0 X-Received: by 10.28.173.15 with SMTP id w15mr2838334wme.32.1461060890507; Tue, 19 Apr 2016 03:14:50 -0700 (PDT) Received: by 10.194.42.194 with HTTP; Tue, 19 Apr 2016 03:14:50 -0700 (PDT) In-Reply-To: <57153546.5020302@crobox.com> References: <57153546.5020302@crobox.com> Date: Tue, 19 Apr 2016 12:14:50 +0200 X-Gmail-Original-Message-ID: Message-ID: Subject: Re: class java.util.UUID is not a valid POJO type From: Till Rohrmann To: user@flink.apache.org Content-Type: multipart/alternative; boundary=001a114447f45fddc60530d3bf1c --001a114447f45fddc60530d3bf1c Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: quoted-printable Hi Leonard, the UUID class cannot be treated as a POJO by Flink, because it is lacking the public getters and setters for mostSigBits and leastSigBits. However, it should be possible to treat it as a generic type. I think the difference is that you cannot use key expressions and key indices to define join keys. But you can use a KeySelector to define the key. If that should not be your problem, then it would be helpful if you could show me the problematic code which produces the error message. Cheers, Till =E2=80=8B On Mon, Apr 18, 2016 at 9:28 PM, Leonard Wolters wrote= : > Hi, > > Quick question. I'm currently implementing our Machine Learning into > Spark using the Scala interface. > Do I understand correctly that when using scala only, you can only use > primitive types? How can I register > the UUID class in order to get supported for (de)serializing between the > nodes? > > BTW: Would love to see the UUID class get 'native' support. > > Keep on going the good work guys!, > > Leonard > > --001a114447f45fddc60530d3bf1c Content-Type: text/html; charset=UTF-8 Content-Transfer-Encoding: quoted-printable

Hi Leonard,

the UUID class cannot be treated as a POJO by Flink, because it is lacking the pub= lic getters and setters for mostSigBits and leastSigBits. However, it should be possible to treat it a= s a generic type. I think the difference is that you cannot use key express= ions and key indices to define join keys. But you can use a KeySelector to define the key.

If that should not be your prob= lem, then it would be helpful if you could show me the problematic code whi= ch produces the error message.

Cheers,
Till

=E2=80=8B

On Mon, Apr 18, 2016 at 9:28 PM, Leonard Wolters <leonar= d@crobox.com> wrote:
Hi,
Quick question. I'm currently implementing our Machine Learning into Spark using the Scala interface.
Do I understand correctly that when using scala only, you can only use
primitive types? How can I register
the UUID class in order to get supported for (de)serializing between the nodes?

BTW: Would love to see the UUID class get 'native' support.

Keep on going the good work guys!,

Leonard


--001a114447f45fddc60530d3bf1c--