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