org.apache.flink.table.functions.hive

Class HiveFunctionWrapper<UDFType>

java.lang.Object

org.apache.flink.table.functions.hive.HiveFunctionWrapper<UDFType>

Type Parameters:

UDFType - The type of UDF.

All Implemented Interfaces:

Serializable

@Internal
public class HiveFunctionWrapper<UDFType>
extends Object
implements Serializable

A wrapper of Hive functions that instantiate function instances and ser/de functino instance cross process boundary.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static long	serialVersionUID

Constructor Summary

Constructors

Constructor and Description
HiveFunctionWrapper(String className)

Method Summary

Modifier and Type	Method and Description
UDFType	createFunction() Instantiate a Hive function instance.
String	getClassName() Get class name of the Hive function.
Class<UDFType>	getUDFClass() Get class of the Hive function.

Methods inherited from class java.lang.Object

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

Field Detail

serialVersionUID

public static final long serialVersionUID

See Also:

Constant Field Values

Constructor Detail

HiveFunctionWrapper

public HiveFunctionWrapper(String className)

Method Detail

createFunction

public UDFType createFunction()

Instantiate a Hive function instance.

Returns:

a Hive function instance

getClassName

public String getClassName()

Get class name of the Hive function.

Returns:

class name of the Hive function

getUDFClass

public Class<UDFType> getUDFClass()
                           throws ClassNotFoundException

Get class of the Hive function.

Returns:

class of the Hive function

Throws:

ClassNotFoundException - thrown when the class is not found in classpath