Realtime Compute for Apache Flink：Mengelola UDF

Mendaftarkan catalog UDF

1. Buka kotak dialog Register UDF Artifact.

   1. Masuk ke Konsol Realtime Compute for Apache Flink.

   2. Temukan ruang kerja yang ingin dikelola dan klik Console di kolom Actions.

   3. Di panel navigasi kiri, klik Development > ETL.

   4. Di sisi kiri halaman SQL Editor, klik tab UDFs.

2. Klik Register UDF Artifact.

3. Di kotak dialog Register UDF Artifact, unggah file JAR UDF.

   Anda dapat menggunakan salah satu metode berikut untuk mengunggah file JAR UDF:

   • Upload a file: Klik Click to select di sebelah Select a file untuk mengunggah file JAR UDF yang diinginkan. Untuk mengunggah file dependensi, klik Click to select di sebelah Dependencies.

     Catatan

     • File JAR UDF akan diunggah dan disimpan di direktori sql-artifacts dari Bucket Object Storage Service (OSS) yang dipilih.

     • Dependensi Java UDF dapat dikemas ke dalam file JAR UDF atau diunggah secara terpisah sebagai file dependensi. Untuk Python UDF, disarankan untuk mengunggah dependensi secara terpisah sebagai file dependensi.

   • External URL: Masukkan URL eksternal. Jika Anda ingin menggunakan file JAR UDF yang digunakan oleh layanan lain, gunakan URL eksternal untuk mendapatkan file UDF.

     Catatan

     Hanya dua jenis URL eksternal berikut yang didukung:

     • Titik akhir Bucket Object Storage Service (OSS) yang ditentukan saat membeli ruang kerja Realtime Compute for Apache Flink. Titik akhir Bucket OSS dapat dilihat dalam pesan Workspace Details di konsol manajemen Realtime Compute for Apache Flink.

     • Titik akhir sistem penyimpanan eksternal lain yang dapat diakses oleh Realtime Compute for Apache Flink. Daftar kontrol akses (ACL) dari sistem penyimpanan eksternal adalah publik-baca atau Realtime Compute for Apache Flink diberi izin untuk mengakses sistem penyimpanan eksternal.

4. Klik Confirm.

5. Di bagian Available Functions dari kotak dialog Kelola Fungsi, pilih satu atau beberapa UDF yang ingin didaftarkan dan klik Create Functions.

   Di konsol Flink yang sepenuhnya dikelola, Flink menguraikan file JAR UDF dan memeriksa apakah kelas UDF, fungsi agregat yang didefinisikan pengguna (UDAF), dan antarmuka fungsi bernilai tabel yang didefinisikan pengguna (UDTF) Flink digunakan dalam file tersebut. Kemudian, Flink secara otomatis mengekstrak nama kelas dan mengisi nama kelas di kolom Nama Fungsi di kotak dialog Kelola Fungsi. Setelah UDF didaftarkan, Anda dapat melihat semua UDF yang telah didaftarkan di panel UDFs di sisi kiri halaman SQL Editor. Karakter fx yang disorot dengan warna kuning akan ditampilkan di sebelah kiri nama setiap UDF yang didaftarkan.

   

   Catatan

   Secara default, versi terbaru Realtime Compute for Apache Flink digunakan untuk penguraian data saat Anda mendaftarkan catalog UDF. Jika Anda menggunakan catalog UDF dalam penyebaran dan memilih versi mesin Realtime Compute for Apache Flink yang lebih lama di bagian Dasar tab Konfigurasi, masalah ketidakcocokan mungkin terjadi. Untuk menyelesaikan masalah ini, implementasikan kode UDF berdasarkan versi mesin yang dibutuhkan oleh penyebaran Anda dan gunakan UDF tingkat penyebaran. Untuk informasi lebih lanjut, lihat Daftarkan UDF tingkat penyebaran.

Mendaftarkan UDF tingkat penyebaran

Untuk mendaftarkan UDF tingkat penyebaran, ikuti langkah-langkah berikut:

1. Unggah file JAR atau Python dari UDF.

   Di panel navigasi kiri, klik Artifacts. Di halaman Artifak, klik Unggah Artifak untuk mengunggah file JAR atau Python dari UDF.

2. Tentukan UDF tingkat penyebaran dalam penyebaran Anda.

   Di tab Konfigurasi halaman SQL Editor, pilih file JAR atau Python dari UDF dari Additional Dependencies.

3. Daftarkan UDF tingkat penyebaran.

   • Java UDF

     CREATE TEMPORARY FUNCTION yourfunctionname;

   • Python UDF

     CREATE TEMPORARY FUNCTION yourfunctionname LANGUAGE Python;