Dit bericht bevat de noodzakelijke stap die nodig is om UDF te maken in Apache Pig. Alle UDF's moeten een filterfunctie uitbreiden en moeten een methode bevatten met de naam exec, die een tuple bevat. De hier toegepaste logica is dat als de Tuple nul of nul is, het u een Booleaanse waarde geeft: True of False. En ‘IsofAge’ is om te controleren of de opgegeven leeftijd correct is of niet. De logica van de door de gebruiker gedefinieerde functie is geschreven in Java-codes, waar het JAR-bestand wordt gemaakt en vervolgens wordt geëxporteerd. Het JAR-bestand wordt later geregistreerd. Deze JAR-bestanden zijn te vinden in de bibliotheekbestanden van Apache Pig op het moment van laden.
openbare klasse IsOfAge breidt FilterFunc {uit @Override publicBoolean exec (Tuple tuple) throwsIOException { if (tuple == null || tuple.size () == 0) { returnfalse } proberen{ Object object = tuple.get (0) if (object == null) { returnfalse } inti = (geheel getal) object if (i == 18 || i == 19 || i == 21 || i == 23 || i == 27) { terugkeerwaar } anders { returnfalse }} catch (ExecExceptione) { throwwnewIOException (e) }}}Hoe bel je een varken UDF?
Zodra een UDF is gemaakt, moet de volgende opdracht worden gebruikt om het JAR-bestand te registreren.
registreer myudf.jar X = filter A op IsOfAge (leeftijd)
Stappen om UDF in Pig te maken:
Er zijn meerdere voorgedefinieerde functies in Apache Pig. We hebben ook de functie om onze eigen functie te maken, de door de gebruiker gedefinieerde functie (UDF). Pig UDF is geschreven in Java en dit vereist dat Pig Library de vooraf gedefinieerde klassen gebruikt. De Apache Pig-bibliotheek pig-0.8.0-cdh3u0-core.jar kan worden gedownload van het internet.
Klik hier voor stappen voor het maken van een Pig-script met UDF in HDFS-modus.
statische lidfunctie c ++
Heeft u een vraag voor ons? Noem ze in het opmerkingengedeelte en we nemen contact met u op.
Gerelateerde berichten:
Apache Pig-script met UDF in HDFS-modus
tableau data blending werkt niet
Operators in Apache Pig: Part 1 - Relationele operatoren
Operators in Apache Pig: Deel 2 - Diagnostische operators