MaxCompute：UDF dengan Penyematan Kode

UDF dengan penyematan kode dari MaxCompute menyelesaikan masalah berikut terkait implementasi dan pemeliharaan kode:

• Implementasi kode yang rumit: Setelah membuat UDF dan mengembangkan kode, Anda harus mengompilasi kode dalam Java serta membuat sumber daya dan fungsi.

• Pemeliharaan kode yang tidak nyaman: Tidak dapat langsung melihat logika implementasi UDF yang dirujuk dalam skrip SQL atau mendapatkan kode sumber paket JAR.

• Keterbacaan kode yang buruk: Untuk mengimplementasikan fungsi pustaka Java menggunakan tipe yang ditentukan pengguna (UDT), Anda perlu mengonversi kode Java menjadi ekspresi dalam baris kode panjang. Selain itu, beberapa kode Java mungkin gagal ditulis sebagai ekspresi. Contoh:

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

Anda hanya dapat menggunakan Janino-compiler untuk mengompilasi kode Java yang disematkan. Sintaks kode Java yang disematkan harus merupakan subset dari sintaks JDK standar. Berikut adalah batasan kode Java yang disematkan:

• Ekspresi lambda tidak didukung.

• Tidak dapat menentukan beberapa jenis pengecualian dalam satu blok catch. Sebagai contoh, catch(Pengecualian1 | Pengecualian2 e) tidak diizinkan.

• Tidak dapat secara otomatis melakukan inferensi argumen generik. Sebagai contoh, Map map = new HashMap<>(); tidak didukung.

• Ekspresi untuk inferensi argumen tipe diabaikan. Anda harus menggunakan ekspresi cast untuk menentukan tipe argumen, seperti (String) myMap.get(key).

• Aserksi diaktifkan secara paksa, meskipun opsi -ea dari Java virtual machine (JVM) digunakan.

• Kode yang diprogram dalam versi setelah Java 8 tidak didukung.

Contoh kode berikut menunjukkan cara merujuk kode tersemat. Anda perlu mengirimkan pernyataan SQL dalam mode skrip. Untuk informasi lebih lanjut, lihat SQL dalam Mode Skrip.

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;

Contoh kode berikut menunjukkan cara mendefinisikan dan memanggil UDF dengan penyematan kode Java. Anda perlu mengirimkan pernyataan SQL dalam mode skrip. Untuk informasi lebih lanjut, lihat SQL dalam Mode Skrip.

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');

Contoh kode berikut menunjukkan cara mendefinisikan dan memanggil UDTF dengan penyematan kode Java. Anda perlu mengirimkan pernyataan SQL dalam mode skrip. Untuk informasi lebih lanjut, lihat SQL dalam Mode Skrip.

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);

Contoh kode berikut menunjukkan cara mendefinisikan dan memanggil UDF dengan penyematan kode Python. Anda perlu mengirimkan pernyataan SQL dalam mode skrip. Untuk informasi lebih lanjut, lihat SQL dalam Mode Skrip.

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);