How to register a Tuple3 with KryoSerializer?

2015-12-30 Thread Russ
I need to register with KryoSerializer a Tuple3 that is generated by a call to the sortBy() method that eventually calls collect() from Partitioner.RangePartitioner.sketch(). The IntelliJ Idea debugger indicates that the for the Tuple3 are java.lang.Integer, java.lang.Integer and long[].  So,

Re: How to register a Tuple3 with KryoSerializer?

2015-12-30 Thread Shixiong(Ryan) Zhu
You can use "_", e.g., sparkConf.registerKryoClasses(Array(classOf[scala.Tuple3[_, _, _]])) Best Regards, Shixiong(Ryan) Zhu Software Engineer Databricks Inc. shixi...@databricks.com databricks.com On Wed, Dec 30, 2015 at 10:16 AM, Russ