Cet article contient l'étape nécessaire pour créer UDF dans Apache Pig. Tout UDF doit étendre une fonction Filter et doit contenir une méthode appelée exec, qui contient un Tuple. La logique appliquée ici est que si le Tuple est nul ou nul, il vous donnera une valeur booléenne: True ou False. Et «IsofAge» sert à vérifier si l’âge indiqué est correct ou non. La logique de la fonction définie par l'utilisateur est écrite dans des codes Java, où le fichier JAR sera créé puis exporté. Le fichier JAR est enregistré ultérieurement. Ces fichiers JAR se trouvent dans les fichiers de bibliothèque d'Apache Pig au moment du chargement.
la classe publique IsOfAge étend FilterFunc { @Passer outre publicBoolean exec (tuple tuple) throwsIOException { if (tuple == null || tuple.size () == 0) { retour faux } essayer{ Objet objet = tuple.get (0) if (objet == null) { retour faux } inti = (Integer) objet si (i == 18 || i == 19 || i == 21 || i == 23 || i == 27) { retour vrai } autre{ retour faux }} catch (ExecExceptione) { thrownewIOException (e) }}}Comment appeler un UDF de porc?
Une fois qu'un UDF est créé, la commande suivante doit être utilisée pour enregistrer le fichier JAR.
register myudf.jar X = filtre A par IsOfAge (age)
Étapes pour créer UDF dans Pig:
Il existe plusieurs fonctions prédéfinies dans Apache Pig. Nous avons également la possibilité de créer notre propre fonction qui est la fonction définie par l'utilisateur (UDF). Pig UDF est écrit en Java et cela nécessite que Pig Library utilise les classes prédéfinies. La bibliothèque Apache Pig pig-0.8.0-cdh3u0-core.jar peut être téléchargé à partir d'Internet.
Cliquez ici pour découvrir les étapes de création d'un script Pig avec UDF en mode HDFS.
comment terminer un programme java
Vous avez une question pour nous? Mentionnez-les dans la section commentaires et nous vous recontacterons.
Articles Similaires:
Script Apache Pig avec UDF en mode HDFS
Opérateurs dans Apache Pig: Partie 1 - Opérateurs relationnels
Opérateurs dans Apache Pig: Partie 2 - Opérateurs de diagnostic