Catatan ini mengandungi langkah yang diperlukan untuk membuat UDF di Apache Pig. Semua UDF harus memperluas fungsi Filter dan harus mengandungi metode yang disebut exec, yang berisi Tuple. Logik yang diterapkan di sini adalah bahawa jika Tuple adalah nol atau sifar, ia akan memberi anda nilai Boolean: Betul atau Salah. Dan ‘IsofAge’ adalah untuk memeriksa sama ada umur yang diberikan betul atau tidak. Logik Fungsi Ditentukan Pengguna ditulis dalam kod Java, di mana fail JAR akan dibuat dan kemudian dieksport. Fail JAR kemudian didaftarkan. Fail JAR ini terdapat di fail perpustakaan Apache Pig pada saat memuatkan.
kelas awam IsOfAge memperluaskan FilterFunc { @Selamat publicBoolean exec (Tuple tuple) throwsIOException { jika (tuple == null || tuple.size () == 0) { kepulangan } cuba { Objek objek = tuple.get (0) jika (objek == null) { kepulangan } objek inti = (Integer) jika (i == 18 || i == 19 || i == 21 || i == 23 || i == 27) { jalan balik } lain { kepulangan }} tangkapan (ExecExceptione) { dilemparkanIOException (e) }}}Bagaimana Memanggil UDF Babi?
Setelah UDF dibuat, arahan berikut harus digunakan untuk mendaftarkan fail JAR.
daftar myudf.jar X = tapis A mengikut IsOfAge (umur)
Langkah Membuat UDF di Babi:
Terdapat beberapa fungsi yang telah ditentukan di Apache Pig. Kami juga mempunyai ciri untuk membuat fungsi kami sendiri iaitu Fungsi Ditetapkan Pengguna (UDF). Babi UDF ditulis dalam Java dan ini memerlukan Pig Library untuk menggunakan kelas yang telah ditentukan. Perpustakaan Apache Babi babi-0.8.0-cdh3u0-core.jar boleh dimuat turun dari internet.
Klik di sini untuk langkah-langkah membuat skrip Babi dengan UDF dalam Mod HDFS.
Ada soalan untuk kami? Sebutkannya di bahagian komen dan kami akan menghubungi anda.
Catatan berkaitan:
tutorial perkhidmatan integrasi pelayan sql
Skrip Babi Apache Dengan UDF dalam Mod HDFS
Pengendali di Apache Pig: Bahagian 1- Relational Operators
Pengendali di Apache Babi: Bahagian 2 - Pengendali Diagnostik