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 function 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(Class<?> functionClz)
HiveFunctionWrapper(Class<?> functionClz, UDFType serializableInstance) Create a HiveFunctionWrapper with a UDF instance.

Method Summary

Modifier and Type	Method and Description
UDFType	createFunction() Instantiate a Hive function instance.
Class<UDFType>	getUDFClass()
String	getUDFClassName() Get class name 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(Class<?> functionClz)

HiveFunctionWrapper

public HiveFunctionWrapper(Class<?> functionClz,
                           UDFType serializableInstance)

Create a HiveFunctionWrapper with a UDF instance. In this constructor, the instance will be serialized to string and held on in the HiveFunctionWrapper.

Method Detail

createFunction

public UDFType createFunction()

Instantiate a Hive function instance.

Returns:

a Hive function instance

getUDFClassName

public String getUDFClassName()

Get class name of the Hive function.

Returns:

class name of the Hive function

getUDFClass

public Class<UDFType> getUDFClass()