org.apache.spark.sql.hive

Class HiveFunctionWrapper

Object

org.apache.spark.sql.hive.HiveFunctionWrapper

All Implemented Interfaces:

java.io.Externalizable, java.io.Serializable, scala.Equals, scala.Product

public class HiveFunctionWrapper
extends Object
implements java.io.Externalizable, scala.Product, scala.Serializable

This class provides the UDF creation and also the UDF instance serialization and de-serialization cross process boundary.

Detail discussion can be found at https://github.com/apache/spark/pull/3640

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
HiveFunctionWrapper()
HiveFunctionWrapper(String functionClassName)

Method Summary

Methods

Modifier and Type	Method and Description
<UDFType> UDFType	createFunction()
<UDFType> UDFType	deserializePlan(java.io.InputStream is, Class<?> clazz)
String	functionClassName()
void	readExternal(java.io.ObjectInput in)
void	serializePlan(Object function, java.io.OutputStream out)
void	writeExternal(java.io.ObjectOutput out)

Methods inherited from class Object

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

Methods inherited from interface scala.Product

productArity, productElement, productIterator, productPrefix

Methods inherited from interface scala.Equals

canEqual, equals

Constructor Detail

HiveFunctionWrapper

public HiveFunctionWrapper(String functionClassName)

HiveFunctionWrapper

public HiveFunctionWrapper()

Method Detail

functionClassName

public String functionClassName()

deserializePlan

public <UDFType> UDFType deserializePlan(java.io.InputStream is,
                                Class<?> clazz)

serializePlan

public void serializePlan(Object function,
                 java.io.OutputStream out)

writeExternal

public void writeExternal(java.io.ObjectOutput out)

Specified by:

writeExternal in interface java.io.Externalizable

readExternal

public void readExternal(java.io.ObjectInput in)

Specified by:

readExternal in interface java.io.Externalizable

createFunction

public <UDFType> UDFType createFunction()