flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Till Rohrmann <trohrm...@apache.org>
Subject Re: class java.util.UUID is not a valid POJO type
Date Tue, 19 Apr 2016 10:14:50 GMT
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
‚Äč

On Mon, Apr 18, 2016 at 9:28 PM, Leonard Wolters <leonard@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
>
>

Mime
View raw message