Updated on 2023-03-21 GMT+08:00

CREATE FUNCTION

Syntax

CREATE FUNCTION
  [IF NOT EXISTS] function_name
  AS identifier [LANGUAGE JAVA|SCALA]

Function

Create a user-defined function.

For details about how to create a user-defined function, see User-Defined Functions (UDFs).

Description

IF NOT EXISTS

If the function already exists, nothing happens.

LANGUAGE JAVA|SCALA

The language tag is used to instruct Flink runtime how to execute the function. Currently, only JAVA and SCALA language tags are supported, the default language for a function is JAVA.

Example

Create a function named STRINGBACK.

create function STRINGBACK as 'com.dli.StringBack'