org.apache.hive.spark

Class HiveKryoRegistrator

java.lang.Object

org.apache.hive.spark.HiveKryoRegistrator

All Implemented Interfaces:

org.apache.spark.serializer.KryoRegistrator

public class HiveKryoRegistrator
extends Object
implements org.apache.spark.serializer.KryoRegistrator

Kryo registrator for shuffle data, i.e. HiveKey and BytesWritable. Active use (e.g. reflection to get a class instance) of this class on hive side can cause problems because kryo is relocated in hive-exec.

Constructor Summary

Constructors

Constructor and Description
HiveKryoRegistrator()

Method Summary

Modifier and Type	Method and Description
void	registerClasses(com.esotericsoftware.kryo.Kryo kryo)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

HiveKryoRegistrator

public HiveKryoRegistrator()

Method Detail

registerClasses

public void registerClasses(com.esotericsoftware.kryo.Kryo kryo)

Specified by:

registerClasses in interface org.apache.spark.serializer.KryoRegistrator