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, org.apache.flink.table.functions.FunctionDefinition

@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

Field Summary

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

argTypes, constantArguments, 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.
protected org.apache.flink.table.types.DataType	inferReturnType() Infer return type of this function call.
void	openInternal() See UserDefinedFunction.open(FunctionContext).

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

eval, getTypeInference, isDeterministic, open

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.FunctionDefinition

getRequirements

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

protected org.apache.flink.table.types.DataType inferReturnType()
                                                         throws org.apache.hadoop.hive.ql.exec.UDFArgumentException

Description copied from class: HiveScalarFunction

Infer return type of this function call.

Specified by:

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

Throws:

org.apache.hadoop.hive.ql.exec.UDFArgumentException