org.apache.flink.table.module.hive

Class HiveModule

java.lang.Object

org.apache.flink.table.module.hive.HiveModule

All Implemented Interfaces:

Module

public class HiveModule
extends Object
implements Module

Module to provide Hive built-in metadata.

Constructor Summary

Constructors

Constructor and Description
HiveModule()
HiveModule(String hiveVersion)
HiveModule(String hiveVersion, ClassLoader classLoader)
HiveModule(String hiveVersion, ReadableConfig config, ClassLoader classLoader)

Method Summary

Modifier and Type	Method and Description
Optional<FunctionDefinition>	getFunctionDefinition(String name) Get an optional of FunctionDefinition by a given name.
String	getHiveVersion()
Set<String>	listFunctions() List names of all functions in this module.

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.module.Module

getTableSinkFactory, getTableSourceFactory, listFunctions

Constructor Detail

HiveModule

@VisibleForTesting
public HiveModule()

HiveModule

@VisibleForTesting
public HiveModule(String hiveVersion)

HiveModule

public HiveModule(String hiveVersion,
                  ClassLoader classLoader)

HiveModule

public HiveModule(String hiveVersion,
                  ReadableConfig config,
                  ClassLoader classLoader)

Method Detail

listFunctions

public Set<String> listFunctions()

Description copied from interface: Module

List names of all functions in this module. It excludes internal functions.

Specified by:

listFunctions in interface Module

Returns:

a set of function names

getFunctionDefinition

public Optional<FunctionDefinition> getFunctionDefinition(String name)

Description copied from interface: Module

Get an optional of FunctionDefinition by a given name.

It includes hidden functions even though not listed in Module.listFunctions().

Specified by:

getFunctionDefinition in interface Module

Parameters:

name - name of the FunctionDefinition.

Returns:

an optional function definition

getHiveVersion

public String getHiveVersion()