Šiame įraše yra būtinas žingsnis, reikalingas norint sukurti UDF „Apache Pig“. Visi UDF turėtų išplėsti filtro funkciją ir turėti metodą, vadinamą exec, kuriame yra Tuple. Čia taikoma logika: jei „Tuple“ yra nulis arba nulis, tai jums suteiks loginę reikšmę: „True“ arba „False“. „IsofAge“ yra skirtas patikrinti, ar nurodytas amžius teisingas, ar ne. Vartotojo nustatytos funkcijos logika yra parašyta „Java“ kodais, kur bus sukurtas ir eksportuojamas JAR failas. JAR byla vėliau užregistruojama. Šie JAR failai įkėlimo metu yra „Apache Pig“ bibliotekos failuose.
viešoji klasė „IsOfAge“ praplečia „FilterFunc“ { @ Nepaisyti publicBoolean exec (Tuple tuple) metimaiIOException { jei (tuple == null || tuple.size () == 0) { returnfalse } bandyti{ Objekto objektas = tuple.get (0) jei (objektas == nulis) { returnfalse } inti = (Sveikasis) objektas jei (i == 18 || i == 19 || i == 21 || i == 23 || i == 27) { grįžtamoji tiesa } Kitas{ returnfalse }} sugauti (ExecExceptione) { thronewIOException (e) }}}Kaip paskambinti kiaulei UDF?
Sukūrus UDF, JAR failui užregistruoti reikia naudoti šią komandą.
registruok myudf.jar X = filtras A pagal IsOfAge (amžius)
Veiksmai, kaip sukurti UDF „Pig“:
„Apache Pig“ yra kelios iš anksto nustatytos funkcijos. Mes taip pat turime galimybę sukurti savo funkciją, kuri yra vartotojo apibrėžta funkcija (UDF). „Pig UDF“ yra parašytas „Java“ ir tam „Pig Library“ reikia naudoti iš anksto nustatytas klases. Apache Pig biblioteka pig-0.8.0-cdh3u0-core.jar galima atsisiųsti iš interneto.
Spustelėkite čia, kad sukurtumėte „Pig“ scenarijų su UDF HDFS režimu.
Turite mums klausimą? Paminėkite juos komentarų skiltyje ir mes susisieksime su jumis.
Susijusios žinutės:
„Apache Pig“ scenarijus su UDF HDFS režimu
„Apache Pig“ operatoriai: 1 dalis. Ryšio operatoriai
SQL serverio datos duomenų tipas
„Apache Pig“ operatoriai: 2 dalis - diagnostikos operatoriai