class java.util.UUID is not a valid POJO type

[Leonard Wolters <le...@crobox.com>]

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

Re: class java.util.UUID is not a valid POJO type

[Till Rohrmann <tr...@apache.org>]

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 <le...@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
>
>