i used this solution to get the class name correctly at runtime:
kryo.register(ClassTag(Class.forName("org.apache.spark.util.collection.CompactBuffer")).wrap.runtimeClass)
2014-10-02 12:50 GMT+02:00 Daniel Darabos <[email protected]>
:
> How about this?
>
> Class.forName("[Lorg.apache.spark.util.collection.CompactBuffer;")
>
> On Tue, Sep 30, 2014 at 5:33 PM, Andras Barjak
> <[email protected]> wrote:
> > Hi,
> >
> > what is the correct scala code to register an Array of this private spark
> > class to Kryo?
> >
> > "java.lang.IllegalArgumentException: Class is not registered:
> > org.apache.spark.util.collection.CompactBuffer[]
> > Note: To register this class use:
> > kryo.register(org.apache.spark.util.collection.CompactBuffer[].class);"
> >
> > thanks,
> >
> > András Barják
>
