Uache loomise sammud Apache Pigis

Apache Pigil on mitu etteantud funktsiooni. Postitus sisaldab selgeid samme Uache loomiseks Apache Pigis. Siin on koodid kirjutatud Java-vormingus ja need vajavad sea raamatukogu

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