org.apache.flink.cdc.common.udf

接口 UserDefinedFunction

@PublicEvolving
public interface UserDefinedFunction

Base interface for creating a UDF in transform projection and filtering expressions. You should define at least one eval method.

方法概要

限定符和类型	方法和说明
default void	close() This will be invoked before a UDF got destroyed.
default DataType	getReturnType()
default void	open() 已过时。
default void	open(UserDefinedFunctionContext context) This will be invoked every time when a UDF got created.

方法详细资料

getReturnType

default DataType getReturnType()

open

@Deprecated
default void open()
                       throws Exception

已过时。

This will be invoked every time when a UDF got created.

this method is Deprecated, please use open(UserDefinedFunctionContext) instead.

抛出:

Exception

open

default void open(UserDefinedFunctionContext context)
           throws Exception

This will be invoked every time when a UDF got created.

抛出:

Exception

close

default void close()
            throws Exception

This will be invoked before a UDF got destroyed.

抛出:

Exception