Class DefaultExpressionEvaluator
- java.lang.Object
-
- org.apache.flink.table.runtime.functions.DefaultExpressionEvaluator
-
- All Implemented Interfaces:
Serializable
,SpecializedFunction.ExpressionEvaluator
@Internal public class DefaultExpressionEvaluator extends Object implements SpecializedFunction.ExpressionEvaluator
Default runtime implementation forSpecializedFunction.ExpressionEvaluator
.- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description DefaultExpressionEvaluator(GeneratedFunction<RichFunction> generatedClass, Class<?> returnClass, Class<?>[] argClasses, String expressionSummary)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
close()
Closes the runtime implementation for expression evaluation.MethodHandle
open(FunctionContext context)
Creates and initializes runtime implementation for expression evaluation.String
toString()
-
-
-
Constructor Detail
-
DefaultExpressionEvaluator
public DefaultExpressionEvaluator(GeneratedFunction<RichFunction> generatedClass, Class<?> returnClass, Class<?>[] argClasses, String expressionSummary)
-
-
Method Detail
-
open
public MethodHandle open(FunctionContext context)
Description copied from interface:SpecializedFunction.ExpressionEvaluator
Creates and initializes runtime implementation for expression evaluation. The returnedMethodHandle
should be stored in a transient variable and can be invoked viaMethodHandle.invokeExact(Object...)
using the conversion classes previously defined via the passedDataType
s.This method should be called in
UserDefinedFunction.open(FunctionContext)
.- Specified by:
open
in interfaceSpecializedFunction.ExpressionEvaluator
-
close
public void close()
Description copied from interface:SpecializedFunction.ExpressionEvaluator
Closes the runtime implementation for expression evaluation. It performs clean up work.This method should be called in
UserDefinedFunction.close()
.- Specified by:
close
in interfaceSpecializedFunction.ExpressionEvaluator
-
-