Šajā ziņojumā ir ietverts nepieciešamais solis, kas nepieciešams, lai izveidotu UDF Apache Pig. Visam UDF ir jāpaplašina funkcija Filtrs, un tajā jābūt metodei, ko sauc par exec, kurā ir Tuple. Šeit izmantotā loģika ir tāda, ka, ja Tuple ir nulle vai nulle, tas jums piešķirs Būla vērtību: True vai False. ‘IsofAge’ ir paredzēts, lai pārbaudītu, vai norādītais vecums ir pareizs vai nav. Lietotāja definētās funkcijas loģika ir ierakstīta Java kodos, kur tiks izveidots un pēc tam eksportēts JAR fails. JAR fails vēlāk tiek reģistrēts. Šie JAR faili ielādes laikā ir atrodami Apache Pig bibliotēkas failos.
publiskā klase IsOfAge paplašina FilterFunc { @ Pārvarēt publicBoolean exec (Tuple tuple) throwsIOException { ja (tuple == null || tuple.size () == 0) { returnfalse } izmēģināt { Objekta objekts = tuple.get (0) ja (objekts == null) { returnfalse } inti = (Integer) objekts ja (i == 18 || i == 19 || i == 21 || i == 23 || i == 27) { atgriešanās patiesība } cits { returnfalse }} nozveja (ExecExceptione) { thrownwioException (e) }}}Kā izsaukt cūku UDF?
Kad UDF ir izveidots, JAR faila reģistrēšanai jāizmanto šāda komanda.
reģistrēt myudf.jar X = filtrs A pēc IsOfAge (vecums)
Soļi, lai izveidotu UDF Pig:
Apache Pig ir vairākas iepriekš definētas funkcijas. Mums ir arī funkcija izveidot savu funkciju, kas ir lietotāja definēta funkcija (UDF). Cūka UDF ir rakstīts Java valodā, un tam cūku bibliotēkai ir jāizmanto iepriekš definētās klases. Apache Pig bibliotēka cūka-0.8.0-cdh3u0-core.jar var lejupielādēt no interneta.
primārs vs pārslodze c ++
Noklikšķiniet šeit, lai skatītu darbības, kā izveidot Pig skriptu ar UDF HDFS režīmā.
Vai mums ir jautājums? Pieminiet tos komentāru sadaļā, un mēs ar jums sazināsimies.
Saistītās ziņas:
Apache Pig Script ar UDF HDFS režīmā
Apache Pig operatori: 1. daļa - Relāciju operatori
Apache Pig operatori: 2. daļa - diagnostikas operatori
zvans pēc atsauces c ++