...
Create Function Statement
CREATE [TEMPORARY|SYSTEM TEMPORARY SYSTEM] FUNCTION [IF NOT EXISTS] [catalog_name.db_name.]function_name AS identifier [LANGUAGE JVMJAVA|SCALA|PYTHON] [USING JAR|FILE|ARCHIVE ‘resource_path’ [, USING JAR|FILE|ARCHIVE ‘path’]*]; |
---|
Drop Function Statement
DROP [TEMPORARY|TEMPORARY SYSTEM] FUNCTION [IF EXISTS] [catalog_name.][db_name.] function_name; |
---|
Alter Function Statement
ALTER [TEMPORARY| TEMPORARY SYSTEM] FUNCTION [IF EXISTS] [catalog_name.][db_name.] function_name RENAME TO new_name; |
---|
...
CREATE [TEMPORARY|TEMPORARY SYSTEM] FUNCTION [IF NOT EXISTS] [catalog_name.db_name.]function_name AS identifier [LANGUAGE JVMJAVA|SCALA|PYTHON]
Drop Function Statement
DROP [TEMPORARY|TEMPORARY SYSTEM] FUNCTION [IF EXISTS] [catalog_name.][db_name.] function_name;
Alter Function Statement
ALTER [TEMPORARY|TEMPORARY SYSTEM] FUNCTION [IF EXISTS] [catalog_name.][db_name.] function_name AS identifier [LANGUAGE JAVA|SCALA|PYTHON];
Show Function Statement
SHOW FUNCTIONS [catalog_name.][db_name]
Basically, we will delivery create function and drop function that is already included in the classpath. For loading function from remote resources, it will be work after the Flink 1.10 release. The sub-tasks include.
...