MaxCompute:Gunakan IntelliJ IDEA untuk mengembangkan Java UDF

Prosedur

1. Tulis UDF dalam Java.

   1. Di panel navigasi sisi kiri, klik tab Project. Buka src > main > java, klik kanan java, lalu pilih New > MaxCompute Java.

      

   2. Di kotak dialog Create new MaxCompute java class, klik UDF. Di bidang Name, masukkan nama kelas lalu tekan Enter.

      

      Name menentukan nama kelas Java MaxCompute yang ingin Anda buat. Jika Anda belum membuat package, Anda dapat memasukkan packagename.classname untuk menghasilkan package secara otomatis.

      Catatan: Jika Anda belum membuat package, masukkan nama dalam format packagename.classname. Sistem akan menghasilkan package secara otomatis.

   3. Di file Java yang dihasilkan, implementasikan logika UDF. Contoh berikut menunjukkan UDF yang mengubah string menjadi huruf kecil.

      

      package <packagename>;
      import com.aliyun.odps.udf.UDF;          // Kelas dasar yang wajib untuk semua MaxCompute UDF
      
      public final class Lower extends UDF {   // Harus memperluas UDF untuk fungsi skalar
      
          // evaluate() adalah titik masuk yang dipanggil untuk setiap baris.
          // Tipe parameter dan nilai kembali dipetakan ke tipe MaxCompute SQL (String -> STRING).
          public String evaluate(String s) {
              if (s == null) {                 // Selalu tangani input NULL untuk menghindari error waktu proses
                  return null;
              }
              return s.toLowerCase();
          }
      }

      Catatan: Ganti <packagename> dengan nama package aktual Anda (misalnya, com.example).

2. Debug UDF secara lokal.

   Jalankan UDF secara lokal terhadap tabel MaxCompute untuk memverifikasi logika sebelum penerapan.

   1. Di direktori java, klik kanan file Java lalu pilih Run.

   2. Di kotak dialog Run/Debug Configurations, konfigurasikan bidang-bidang berikut.

      

      • MaxCompute project: Proyek MaxCompute tempat UDF dijalankan. Pilih local dari daftar drop-down untuk menjalankan secara lokal tanpa mengirim ke kluster.

      • MaxCompute table: Nama tabel MaxCompute yang menyediakan data masukan untuk eksekusi lokal.

      • Table columns: Kolom-kolom di tabel MaxCompute tempat UDF dioperasikan.

   3. Klik OK. UDF dijalankan secara lokal dan hasil kembaliannya muncul di panel output.

      Tips: Eksekusi lokal yang berhasil mengonfirmasi bahwa metode evaluate() Anda menangani tipe input dan nilai NULL dengan benar. Perbaiki semua error sebelum melanjutkan ke tahap penerapan.

3. Terapkan UDF ke MaxCompute.

   Setelah pengujian lokal berhasil, kemas dan daftarkan UDF agar tersedia dalam SQL.

   1. Klik kanan file Java UDF lalu pilih Deploy to Server....

   2. Di kotak dialog Package a jar, submit resource and register function, konfigurasikan bidang-bidang berikut.

      

      • MaxCompute project: Proyek tujuan penerapan. Nilai default mencerminkan proyek yang Anda hubungkan saat menulis UDF. Pertahankan nilai default kecuali Anda menargetkan proyek berbeda.

      • Resource file: Jalur file resource JAR. Pertahankan nilai default.

      • Resource name: Nama resource sebagaimana didaftarkan di MaxCompute. Pertahankan nilai default.

      • Function name: Nama yang digunakan untuk memanggil UDF dalam pernyataan SQL. Masukkan Lower_test.

      Peringatan: Nilai di Function name adalah nama yang akan Anda gunakan dalam kueri SQL. Hindari nama yang bentrok dengan fungsi bawaan MaxCompute. Jika terjadi bentrok, UDF kustom Anda mungkin menimpa atau gagal menggantikan fungsi bawaan tersebut.

   3. Klik OK. MaxCompute Studio mengemas kode ke dalam JAR, mengunggahnya sebagai resource, dan mendaftarkan Lower_test sebagai fungsi di proyek yang dipilih.

4. Panggil UDF dalam SQL.

   1. Di panel navigasi sisi kiri, buka tab Project Explorer.

   2. Klik kanan proyek MaxCompute Anda lalu pilih Open in Console.

   3. Di konsol, masukkan pernyataan SQL berikut lalu tekan Enter.

      select Lower_test('ALIYUN');

      

   4. Verifikasi output. Hasil berikut dikembalikan, menunjukkan bahwa UDF Java Lower_test berfungsi dengan benar.

      Expected output:
      +------------+
      | _c0        |
      +------------+
      | aliyun     |
      +------------+