See postitus sisaldab vajalikke samme Uache loomiseks Apache Pigis. Kogu UDF peaks laiendama funktsiooni Filter ja see peab sisaldama meetodit nimega exec, mis sisaldab Tuple'i. Siin rakendatakse loogikat: kui Tuple on null või null, annab see teile Boole'i väärtuse: tõene või vale. Ja ‘IsofAge’ on mõeldud selleks, et kontrollida, kas antud vanus on õige või mitte. Kasutaja määratud funktsiooni loogika on kirjutatud Java-koodidesse, kus luuakse ja seejärel eksporditakse JAR-fail. JAR-fail registreeritakse hiljem. Need JAR-failid on laadimise ajal Apache Pigi teegifailidest.
avalik klass IsOfAge laiendab FilterFunc { @Üle publicBoolean exec (Tuple tuple) viskabIOException { kui (tuple == null || tuple.size () == 0) { returnfalse } proovige { Objekti objekt = tuple.get (0) kui (objekt == null) { returnfalse } inti = (täisarv) objekt kui (i == 18 || i == 19 || i == 21 || i == 23 || i == 27) { tagasitõde } veel { returnfalse }} saak (ExecExceptione) { heita uusIOException (e) }}}Kuidas kutsuda siga UDF?
Kui UDF on loodud, tuleb JAR-faili registreerimiseks kasutada järgmist käsku.
registreeri myudf.jar X = filter A IsOfAge (vanus) järgi
UDF-i loomise sammud sead:
Apache Pigis on mitu etteantud funktsiooni. Samuti on meil võimalus luua oma funktsioon, mis on kasutaja määratud funktsioon (UDF). Pig UDF on kirjutatud Java keeles ja see nõuab Pig Library poolt eelnevalt määratletud klasside kasutamist. Apache Pigi raamatukogu siga-0,8,0-cdh3u0-core.jar saab alla laadida Internetist.
HDFS-režiimis UDF-iga Pig-skripti loomise juhiste saamiseks klõpsake siin.
Kas teil on meile küsimus? Mainige neid kommentaaride jaotises ja võtame teiega ühendust.
luua objektide massiiv Java
Seonduvad postitused:
Apache Pig Script UDF-ga HDFS-režiimis
Apache Pigi operaatorid: 1. osa - suhtlusoperaatorid
Apache Pigi operaatorid: 2. osa - diagnostikaoperaatorid
staatilise ploki näide javas