MaxCompute：UDT樣本

UDT運行時內建一個JSON的依賴（2.2.4），可以直接使用JSON。

set odps.sql.type.system.odps2=true;
set odps.sql.session.java.imports=java.util.*,java,com.google.gson.*; --同時匯入多個Package時用逗號隔開。
@a := select new Gson() gson;   --構建Gson對象。
select 
gson.toJson(new ArrayList<Integer>(Arrays.asList(1, 2, 3))), --將任意對象轉成JSON字串。
cast(gson.fromJson('["a","b","c"]', List.class) as List<String>) --還原序列化JSON字串，注意Gson的介面，直接還原序列化後是List<Object>類型，這裡強制轉換成List<String>，方便後續使用。
from @a;

內建類型ARRAY與java.util.List、MAP和java.util.Map存在映射關係。

• Java中實現java.util.List或java.util.Map介面類的對象，都可參與MaxCompute SQL的複雜類型操作。
• MaxCompute中ARRAY或MAP的資料，能夠直接調用List或者MAP的介面。

set odps.sql.type.system.odps2=true;
set odps.sql.session.java.imports=java.util.*;
select
    size(new ArrayList<Integer>()),        --對ArrayList資料調用內建函數Size。
    array(1,2,3).size(),                   --對內建類型ARRAY調用List的Size方法。
    sort_array(new ArrayList<Integer>()),  --對ArrayList的資料進行排序。
    al[1],                                 --雖然Java的List不支援下標操作，但ARRAY支援。
    Objects.toString(a),        --之前不支援將ARRAY類型Cast成STRING，現在有繞過方法了。
    array(1,2,3).subList(1, 2)             --計算subList。
from (select new ArrayList<Integer>(array(1,2,3)) as al, array(1,2,3) as a) t;

樣本如下，計算BigInteger的中位元（由於資料是java.math.BigInteger類型的，所以不能直接用內建函數MEDIAN）。

set odps.sql.session.java.imports=java.math.*;
@test_data := select * from values (1),(2),(3),(5) as t(value);
@a := select collect_list(new BigInteger(value)) values from @test_data;  --先把資料彙總成List。
@b := select sort_array(values) as values, values.size() cnt from @a;  --計算中位元的邏輯，先將資料排序。
@c := select if(cnt % 2 == 1, new BigDecimal(values[cnt div 2]), new BigDecimal(values[cnt div 2 - 1].add(values[cnt div 2])).divide(new BigDecimal(2))) med from @b;
--最終結果。
select med.toString() from @c;

資料表值函式允許輸入多行多列資料，輸出多行多列資料。可以按照如下操作實現：

• 輸入多行多列資料，詳情請參見彙總操作。
• 輸出多行多列資料，可以用UDT方法輸出一個Collection類型的資料（List或者MAP），然後調用Explode函數，將Collections展開成多行。
• UDT可以包含多個資料域，通過調用不同的Getter方法擷取各個域的內容即可展開成多列。

展開一個JSON字串的內容，樣本如下。

@a := select '[{"a":"1","b":"2"},{"a":"1","b":"2"}]' str; --樣本資料。
@b := select new com.google.gson.Gson().fromJson(str, java.util.List.class) l from @a; --還原序列化JSON。
@c := select cast(e as java.util.Map<Object,Object>) m from @b lateral view explode(l) t as e;  --用explode展開成多行。
@d := select m.get('a') as a, m.get('b') as b from @c; --展開成多列。
select a.toString() a, b.toString() b from @d; --最終結果輸出（注意變數d的輸出中a、b兩列是Object類型）。

通過UDT實現函數重載，可以解決上述問題。UDT支援泛型、類繼承和變長參數，為您提供靈活的函數定義方式，樣本如下。

public class UDTClass {
    // 這個函數支援一個數實值型別（可以是TINYINT、SMALLINT、INT、BIGINT、FLOAT、DOUBLE以及任何以Number為基類的UDT），返回DOUBLE。
    public static Double doubleValue(Number input) {
        return input.doubleValue();
    }
    // 這個方法支援一個數實值型別參數和一個任意類型的參數，傳回值類型與第二個參數的類型相同。
    public static <T extends Number, R> R nullOrValue(T a, R b) {
        return a.doubleValue() > 0 ? b : null;
    }
    // 這個方法支援一個任意元素類型的ARRAY或List，返回BIGINT。
    public static Long length(java.util.List<? extends Object> input) {
        return input.size();
    }
    // 注意在不做強制轉換的情況下參數只支援UDT的java.util.Map<Object, Object>對象。如果需要傳入任何MAP對象，例如map<bigint,bigint>可以考慮:
    // 1. 定義函數時使用java.util.Map<? extends Object, ? extends Object>。
    // 2. 調用時做強制轉換，例如UDTClass.mapSize(cast(mapObj as java.util.Map<Object, Object>))。
    public static Long mapSize(java.util.Map<Object, Object> input) {
        return input.size();
    }
}