本文介紹自定義SQL算子的使用方法和注意事項。
用途
當系統提供的內置算子無法滿足需求時，用戶可以通過編寫SQL語句實現自己特定的業務邏輯。
適用場景
計算鏈路 | 計算引擎 | 是否支持 |
離線 | MaxCompute | 是 |
Hive | 是 | |
HiveStorage | 是 | |
RDS/MySQL | 是 |
使用說明
輸入節點
上游節點的輸出表信息，包括“表名標識符”和“字段名稱”。
表名標識符
表名標識符在sql中作為占位符使用，在運行時此展位符會替換成上游節點輸出表的實際表名。
說明
表名標識符使用${}方式在sql中使用，例如
Select date -- 日期 ,sales -- 銷量 From ${table} Where sales >= 60
SQL腳本設置
編寫具體的SQL腳本，示例如下：
說明
腳本僅支持select語句，select語句的查詢結果將自動寫入一張臨時表。請勿使用create、alter、insert等語句，否則將運行失敗。
示例中的${table}在運行時將會自動替換為上游輸入表的真實表名。
輸出字段
配置該算子的輸出字段，可手動編輯也可通過解析sql語句自動生成。
自動解析的sql格式如圖所示：
這兩個行將解析出如下兩個字段信息：
文檔內容是否對您有幫助？