org.apache.flink.table.functions.hive

Class HiveSimpleUDF

java.lang.Object

org.apache.flink.table.functions.UserDefinedFunction

org.apache.flink.table.functions.ScalarFunction

org.apache.flink.table.functions.hive.HiveScalarFunction<org.apache.hadoop.hive.ql.exec.UDF>

org.apache.flink.table.functions.hive.HiveSimpleUDF

All Implemented Interfaces:

Serializable, FunctionDefinition, HiveFunction<org.apache.hadoop.hive.ql.exec.UDF>

@Internal
public class HiveSimpleUDF
extends HiveScalarFunction<org.apache.hadoop.hive.ql.exec.UDF>

A ScalarFunction implementation that calls Hive's UDF.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.table.functions.hive.HiveFunction

HiveFunction.HiveFunctionInputStrategy, HiveFunction.HiveFunctionOutputStrategy

Field Summary

Fields inherited from class org.apache.flink.table.functions.hive.HiveScalarFunction

arguments, function, hiveFunctionWrapper, returnInspector

Constructor Summary

Constructors

Constructor and Description
HiveSimpleUDF(HiveFunctionWrapper<org.apache.hadoop.hive.ql.exec.UDF> hiveFunctionWrapper, HiveShim hiveShim)

Method Summary

Modifier and Type	Method and Description
Object	evalInternal(Object[] args) Evaluation logical, args will be wrapped when is a single array.
DataType	inferReturnType() Infers the return type of the function.
void	openInternal() See UserDefinedFunction.open(FunctionContext).

Methods inherited from class org.apache.flink.table.functions.hive.HiveScalarFunction

eval, getFunctionWrapper, getTypeInference, isDeterministic, open, setArguments

Methods inherited from class org.apache.flink.table.functions.ScalarFunction

getKind, getParameterTypes, getResultType

Methods inherited from class org.apache.flink.table.functions.UserDefinedFunction

close, functionIdentifier, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.table.functions.hive.HiveFunction

createTypeInference

Methods inherited from interface org.apache.flink.table.functions.FunctionDefinition

getRequirements, supportsConstantFolding

Constructor Detail

HiveSimpleUDF

public HiveSimpleUDF(HiveFunctionWrapper<org.apache.hadoop.hive.ql.exec.UDF> hiveFunctionWrapper,
                     HiveShim hiveShim)

Method Detail

openInternal

public void openInternal()

Description copied from class: HiveScalarFunction

See UserDefinedFunction.open(FunctionContext).

Specified by:

openInternal in class HiveScalarFunction<org.apache.hadoop.hive.ql.exec.UDF>

evalInternal

public Object evalInternal(Object[] args)

Description copied from class: HiveScalarFunction

Evaluation logical, args will be wrapped when is a single array.

Specified by:

evalInternal in class HiveScalarFunction<org.apache.hadoop.hive.ql.exec.UDF>

inferReturnType

public DataType inferReturnType()
                         throws org.apache.hadoop.hive.ql.exec.UDFArgumentException

Description copied from interface: HiveFunction

Infers the return type of the function. This method should be called after HiveFunction.setArguments(CallContext) is called.

Returns:

The inferred return type.

Throws:

org.apache.hadoop.hive.ql.exec.UDFArgumentException - can be thrown if the input arguments are invalid.