Realtime Compute for Apache Flink：管理自訂函數（UDF）

全域自訂函數

1. 進入自訂函數註冊入口

   1. 登入Realtime Compute控制台。

   2. 單擊目標工作空間操作列下的控制台。

   3. 單擊資料開發 > ETL。

   4. 單擊左側的函數頁簽。

2. 單擊註冊UDF。

3. 上傳UDF JAR檔案。

   您可以通過以下任何一種方式上傳UDF JAR檔案：

   • 上傳檔案：單擊選擇檔案項右側的選擇檔案後，選擇您的目標UDF Artifact檔案。如果有依賴檔案，單擊依賴檔案項右側的選擇檔案，選擇您的目標UDF Artifact所依賴的檔案。

     說明

     • 您的UDF檔案會被上傳到您選擇的OSS Bucket中的sql-artifacts目錄下。

     • 對於Java類型的UDF，其依賴可以打包到UDF JAR包中，也可以通過依賴檔案項進行上傳；對於Python類型的UDF，其依賴推薦通過的單獨上傳依賴檔案方式上傳。

   • 外部URL：當需要使用其他服務上存在的UDF檔案時，可以使用外部URL功能擷取UDF檔案。

     說明

     僅支援以下兩類外部URL：

     • 開通Flink工作空間時選擇的OSS Bucket地址。您可以在Realtime Compute管理主控台目標工作空間詳情中查看綁定的OSS Bucket。

     • Realtime ComputeFlink版可以訪問且被允許訪問（公用讀取或被授予許可權）的其他外部儲存系統地址。

4. 單擊確定。

5. 在可用函數頁面，選擇需要註冊的UDF後，單擊建立函數。

   Flink開發控制台會解析自訂函數檔案中是否使用了Flink UDF、UDAF和UDTF介面的類，並自動提取類名，填充到Function Name欄位中。註冊成功後，您可以在左側函數列表看到所有註冊成功的UDF，註冊成功的UDF左側會有黃色字型的fx標識。

   

   說明

   全域自訂函數（Catalog Function）在註冊時，預設使用最新的Flink版本解析。如果您在作業中使用全域自訂函數，同時在作業中選中了非最新的Flink版本，則有可能出現不相容的問題。此時，您可以根據作業需要使用的引擎版本來實現UDF代碼，並通過作業級自訂函數的方式解決此問題。詳情請參見作業級自訂函數。

作業級自訂函數

作業級自訂函數的註冊流程如下：

1. 上傳自訂函數JAR或Python包。

   在左側導覽列檔案管理中，上傳自訂函數JAR或Python包。

2. 在作業中指定作業級自訂函數。

   在作業的附加依賴檔案中，指定自訂函數JAR或Python包。

3. 註冊作業級自訂函數。

   • JAVA自訂函數

     CREATE TEMPORARY FUNCTION yourfunctionname;

   • Python自訂函數

     CREATE TEMPORARY FUNCTION yourfunctionname LANGUAGE Python;