Ta objava vsebuje potreben korak za ustvarjanje UDF v Apache Pig. Vsi UDF bi morali razširiti funkcijo Filter in vsebovati metodo, imenovano exec, ki vsebuje Tuple. Tu uporabljena logika je, da če je Tuple nič ali nič, vam bo dal logično vrednost: True ali False. In „IsofAge“ je namenjen preverjanju, ali je navedena starost pravilna ali ne. Logika uporabniško določene funkcije je zapisana v kodah Java, kjer bo datoteka JAR ustvarjena in nato izvožena. Datoteka JAR je pozneje registrirana. Te datoteke JAR najdete v knjižničnih datotekah Apache Pig v času nalaganja.
javni razred IsOfAge razširja FilterFunc { @Override publicBoolean exec (Tuple tuple) throwsIOException { if (tuple == null || tuple.size () == 0) { returnfalse } poskusite { Objekt objekt = tuple.get (0) if (object == null) { returnfalse } inti = (Integer) objekt če (i == 18 || i == 19 || i == 21 || i == 23 || i == 27) { povratnik } še { returnfalse }} ulov (ExecExceptione) { thrownewIOException (e) }}}Kako poklicati prašičje UDF?
Ko je UDF ustvarjen, je treba za registracijo datoteke JAR uporabiti naslednji ukaz.
java niz predmetov primer
registriraj myudf.jar X = filter A po IsOfAge (starost)
Koraki za ustvarjanje UDF v Pig:
V Apache Pig je več vnaprej določenih funkcij. Imamo tudi funkcijo za ustvarjanje lastne funkcije, ki je uporabniško določena funkcija (UDF). Pig UDF je napisan v Javi, zato zahteva, da Pig Library uporablja vnaprej določene razrede. Knjižnica Apache Pig prašič-0.8.0-cdh3u0-core.jar lahko prenesete z interneta.
Kliknite tukaj za korake za ustvarjanje Pig skripta z UDF v načinu HDFS.
Imate vprašanje za nas? Omenite jih v oddelku za komentarje in javili se vam bomo.
Sorodne objave:
dobite dolžino polja javascript
Apache Pig Script z UDF v načinu HDFS
Operaterji v Apache Pig: 1. del - Relacijski operaterji
Operaterji v Apache Pig: 2. del - Diagnostični operaterji