MaxCompute：UDF（嵌入式）

您可以通過MaxCompute的代碼嵌入式UDF解決以下代碼實現過程繁瑣，且不方便閱讀和維護的問題：

• 建立UDF並完成代碼開發後，您還需要完成代碼編譯（Java）、建立資源和建立函數操作，過程比較繁瑣。

• SQL指令碼中如果包含UDF，您無法直接查看實現邏輯，或無法擷取到JAR包的源碼，維護不方便。

• 通過UDT使用Java庫函數時，您需要編寫長代碼將Java代碼轉換為運算式，閱讀和維護不方便。另外還會存在Java代碼無法寫為運算式的問題，命令樣本如下。

  Foo f = new Foo();
  f.execute();
  f.getResult();

嵌入式Java代碼使用Janino-compiler編譯器進行編譯，且支援的Java文法只是標準Java JDK的一個子集。嵌入式Java代碼使用限制包含但不限於以下內容：

• 不支援Lambda運算式。

• 不支援Catch多種Exception類型。例如catch(Exception1 | Exception2 e)。

• 不支援自動推導泛型。例如Map map = new HashMap<>();。

• 型別參數的推導會被忽略，必須顯示Cast。例如(String) myMap.get(key)。

• Assert會強制開啟，不受JVM的-ea參數控制。

• 不支援Java 8以上（不包含Java 8）版本的語言功能。

範例程式碼如下。您需要通過指令碼模式提交執行，詳情請參見SQL指令碼模式。

SELECT 
  s, 
  com.mypackage.Foo.extractNumber(s) 
FROM VALUES ('abc123def'),('apple') AS t(s);

#CODE ('lang'='JAVA')
package com.mypackage;
import java.util.regex.Matcher;
import java.util.regex.Pattern;
public class Foo {
  final static Pattern compile = Pattern.compile(".*?([0-9]+).*");
  public static String extractNumber(String input) {
    final Matcher m = compile.matcher(input);
    if (m.find()) {
      return m.group(1);
    }
    return null;
  }
}
#END CODE;

範例程式碼如下。您需要通過指令碼模式提交執行，詳情請參見SQL指令碼模式。

CREATE TEMPORARY FUNCTION foo AS 'com.mypackage.Reverse' USING
#CODE ('lang'='JAVA')
package com.mypackage;
import com.aliyun.odps.udf.UDF;
public class Reverse extends UDF {
  public String evaluate(String input) {
    if (input == null) return null;
    StringBuilder ret = new StringBuilder();
    for (int i = input.toCharArray().length - 1; i >= 0; i--) {
      ret.append(input.toCharArray()[i]);
    }
    return ret.toString();
  }
}
#END CODE;

SELECT foo('abdc');

範例程式碼如下。您需要通過指令碼模式提交執行，詳情請參見SQL指令碼模式。

CREATE TEMPORARY FUNCTION foo AS 'com.mypackage.Reverse' USING 
#CODE ('lang'='JAVA', 'filename'='embedded.jar')
package com.mypackage;

import com.aliyun.odps.udf.UDTF;
import com.aliyun.odps.udf.UDFException;
import com.aliyun.odps.udf.annotation.Resolve;

@Resolve({"string->string,string"})
public class Reverse extends UDTF {
  @Override
  public void process(Object[] objects) throws UDFException {
    String str = (String) objects[0];
    String[] split = str.split(",");
    forward(split[0], split[1]);
  }
}

#END CODE;

SELECT foo('ab,dc') AS (a,b);

範例程式碼如下。您需要通過指令碼模式提交執行，詳情請參見SQL指令碼模式。

CREATE TEMPORARY FUNCTION foo AS 'embedded.UDFTest' USING
#CODE ('lang'='PYTHON', 'filename'='embedded')
from odps.udf import annotate
@annotate("bigint->bigint")
class UDFTest(object):
  def evaluate(self, a):
    return a * a
#END CODE;

SELECT foo(4);