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