如果您在Tablestore裡面的資料有著獨特的結構,希望自訂開發邏輯來處理每一行資料,例如解析特定的JSON字串,可以使用UDF(User Defined Function,即使用者自訂函數)來處理。

操作步驟

  1. 參考MaxCompute Studio文檔,在IntelliJ中安裝MaxCompute-Java/MaxCompute-Studio外掛程式。外掛程式安裝完畢,即可直接開發。

    下圖是一個簡單的UDF定義,將兩個字串串連。MaxCompute支援更複雜的UDF,包括自訂視窗執行邏輯等。更多資訊,請參見開發和調試UDF

  2. 包之後可以上傳到MaxCompute。

    選擇File > Project Structure > Artifacts,輸入NameOutput directory後,單擊+選擇輸出模組。打包後通過ODPS Project Explorer來上傳資源、建立函數,然後就可以在SQL中調用。

    fig_udf_003
  3. 運行bin/odpscmd.bat
    // 選出來1行資料,並將name/name傳入UDF,返回兩個string的累加.
    select cloud_metric_extract_md5(name, name) as udf_test from test_table limit 1;                    

    返回結果如下:

    fig_udf_004