如果您在Tablestore裡面的資料有著獨特的結構,希望自訂開發邏輯來處理每一行資料,例如解析特定的JSON字串,可以使用UDF(User Defined Function,即使用者自訂函數)來處理。
操作步驟
- 參考MaxCompute Studio文檔,在IntelliJ中安裝MaxCompute-Java/MaxCompute-Studio外掛程式。外掛程式安裝完畢,即可直接開發。
下圖是一個簡單的UDF定義,將兩個字串串連。MaxCompute支援更複雜的UDF,包括自訂視窗執行邏輯等。更多資訊,請參見開發和調試UDF。
- 包之後可以上傳到MaxCompute。
選擇,輸入Name和Output directory後,單擊+選擇輸出模組。打包後通過ODPS Project Explorer來上傳資源、建立函數,然後就可以在SQL中調用。
- 運行bin/odpscmd.bat。
// 選出來1行資料,並將name/name傳入UDF,返回兩個string的累加.
select cloud_metric_extract_md5(name, name) as udf_test from test_table limit 1;
返回結果如下: