Această postare conține pasul necesar pentru a crea UDF în Apache Pig. Toate UDF ar trebui să extindă o funcție de filtrare și trebuie să conțină o metodă numită exec, care conține un tuplu. Logica aplicată aici este că, dacă tuplul este nul sau zero, acesta vă va oferi o valoare booleană: Adevărat sau Fals. Și „IsofAge” este pentru verificarea dacă vârsta dată este corectă sau nu. Logica funcției definite de utilizator este scrisă în coduri Java, unde fișierul JAR va fi creat și apoi exportat. Fișierul JAR este înregistrat ulterior. Aceste fișiere JAR se găsesc în fișierele bibliotecii Apache Pig în momentul încărcării.
clasa publică IsOfAge extinde FilterFunc { @Trece peste publicBoolean exec (Tuple tuple) throwsIOException { if (tuplu == nul || tuplu.size () == 0) { returnfalse } încerca{ Obiect obiect = tuple.get (0) if (obiect == nul) { returnfalse } inti = (Integer) obiect if (i == 18 || i == 19 || i == 21 || i == 23 || i == 27) { returntrue } altceva { returnfalse }} catch (ExecExceptione) { thrownewIOException (e) }}}Cum să apelați un porc UDF?
Odată ce un UDF este creat, următoarea comandă trebuie utilizată pentru a înregistra fișierul JAR.
Înregistrează myudf.jar X = filtrul A după IsOfAge (vârstă)
Pași pentru a crea UDF în Pig:
Există mai multe funcții predefinite în Apache Pig. De asemenea, avem funcția de a crea propria noastră funcție, care este Funcția Definită de Utilizator (UDF). UDF Pig este scris în Java și acest lucru necesită Pig Library pentru a utiliza clasele predefinite. Biblioteca Apache Pig porc-0.8.0-cdh3u0-core.jar poate fi descărcat de pe internet.
sare vs bucătar vs marionetă
Faceți clic aici pentru pașii pentru crearea unui script Pig cu UDF în modul HDFS.
Ai o întrebare pentru noi? Menționați-le în secțiunea de comentarii și vă vom răspunde.
Postări asemănatoare:
cum se găsește lungimea matricei în javascript
Script Apache Pig cu UDF în modul HDFS
când să utilizați acest java
Operatori în Apache Pig: Partea 1 - Operatori relaționali
Operatori în Apache Pig: Partea 2 - Operatori de diagnosticare