org.apache.flink.table.catalog.hive.factories

Class HiveFunctionDefinitionFactory

java.lang.Object

org.apache.flink.table.catalog.hive.factories.HiveFunctionDefinitionFactory

All Implemented Interfaces:

FunctionDefinitionFactory

public class HiveFunctionDefinitionFactory
extends Object
implements FunctionDefinitionFactory

A factory to instantiate Hive UDFs as Flink UDFs.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.table.factories.FunctionDefinitionFactory

FunctionDefinitionFactory.Context

Constructor Summary

Constructors

Constructor and Description
HiveFunctionDefinitionFactory(HiveShim hiveShim)

Method Summary

Modifier and Type	Method and Description
FunctionDefinition	createFunctionDefinition(String name, CatalogFunction catalogFunction, FunctionDefinitionFactory.Context context) Creates a FunctionDefinition from given CatalogFunction with the given FunctionDefinitionFactory.Context containing the class loader of the current session, which is useful when it's needed to load class from class name.
FunctionDefinition	createFunctionDefinitionFromFlinkFunction(String name, CatalogFunction catalogFunction, FunctionDefinitionFactory.Context context)
FunctionDefinition	createFunctionDefinitionFromHiveFunction(String name, String functionClassName, FunctionDefinitionFactory.Context context) Create a FunctionDefinition from a Hive function's class name.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.table.factories.FunctionDefinitionFactory

createFunctionDefinition

Constructor Detail

HiveFunctionDefinitionFactory

public HiveFunctionDefinitionFactory(HiveShim hiveShim)

Method Detail

createFunctionDefinition

public FunctionDefinition createFunctionDefinition(String name,
                                                   CatalogFunction catalogFunction,
                                                   FunctionDefinitionFactory.Context context)

Description copied from interface: FunctionDefinitionFactory

Creates a FunctionDefinition from given CatalogFunction with the given FunctionDefinitionFactory.Context containing the class loader of the current session, which is useful when it's needed to load class from class name.

The default implementation will call FunctionDefinitionFactory.createFunctionDefinition(String, CatalogFunction) directly.

Specified by:

createFunctionDefinition in interface FunctionDefinitionFactory

Parameters:

name - name of the CatalogFunction

catalogFunction - the catalog function

context - the FunctionDefinitionFactory.Context for creating function definition

Returns:

a FunctionDefinition

createFunctionDefinitionFromFlinkFunction

public FunctionDefinition createFunctionDefinitionFromFlinkFunction(String name,
                                                                    CatalogFunction catalogFunction,
                                                                    FunctionDefinitionFactory.Context context)

createFunctionDefinitionFromHiveFunction

public FunctionDefinition createFunctionDefinitionFromHiveFunction(String name,
                                                                   String functionClassName,
                                                                   FunctionDefinitionFactory.Context context)

Create a FunctionDefinition from a Hive function's class name. Called directly by HiveModule.