spark-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Andras Barjak <andras.bar...@lynxanalytics.com>
Subject Re: registering Array of CompactBuffer to Kryo
Date Thu, 02 Oct 2014 11:27:49 GMT
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 <daniel.darabos@lynxanalytics.com>
:

> How about this?
>
>     Class.forName("[Lorg.apache.spark.util.collection.CompactBuffer;")
>
> On Tue, Sep 30, 2014 at 5:33 PM, Andras Barjak
> <andras.barjak@lynxanalytics.com> 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
>

Mime
View raw message