Dette innlegget inneholder det nødvendige trinnet som kreves for å opprette UDF i Apache Pig. All UDF skal utvide en filterfunksjon og må inneholde en metode som kalles exec, som inneholder en Tuple. Logikken som brukes her er at hvis Tuple er null eller null, vil det gi deg en boolsk verdi: True eller False. Og ‘IsofAge’ er for å sjekke om alderen gitt er riktig eller ikke. Logikken til den brukerdefinerte funksjonen er skrevet i Java-koder, hvor JAR-filen blir opprettet og deretter eksportert. JAR-filen blir senere registrert. Disse JAR-filene finnes i biblioteksfilene til Apache Pig på tidspunktet for lasting.
offentlig klasse IsOfAge utvider FilterFunc { @Overstyring publicBoolean exec (Tuple tuple) kasterIOException { hvis (tuple == null || tuple.size () == 0) { returfalsk } prøve{ Objektobjekt = tuple.get (0) hvis (objekt == null) { returfalsk } inti = (Heltall) objekt hvis (i == 18 || i == 19 || i == 21 || i == 23 || i == 27) { tilbake } annet { returfalsk }} fangst (ExecExceptione) { throwewIOException (e) }}}Hvordan kalle en gris UDF?
Når en UDF er opprettet, må følgende kommando brukes til å registrere JAR-filen.
registrer myudf.jar X = filter A av IsOfAge (alder)
Fremgangsmåte for å lage UDF i gris:
Det er flere forhåndsdefinerte funksjoner i Apache Pig. Vi har også funksjonen til å lage vår egen funksjon som er User Defined Function (UDF). Pig UDF er skrevet på Java, og dette krever at Pig Library bruker de forhåndsdefinerte klassene. Apache Pig-biblioteket gris-0.8.0-cdh3u0-core.jar kan lastes ned fra internett.
Klikk her for trinn for å lage et griseskript med UDF i HDFS-modus.
Har du et spørsmål til oss? Nevn dem i kommentarfeltet, så kommer vi tilbake til deg.
Relaterte innlegg:
Apache Pig Script med UDF i HDFS-modus
Operatører i Apache Pig: Del 1 - Relasjonsoperatører
hva er marionett og kokk
Operatører i Apache Pig: Del 2 - Diagnostiske operatører