Esta publicación contiene el paso necesario para crear UDF en Apache Pig. Todas las UDF deben extender una función de filtro y deben contener un método llamado exec, que contiene una tupla. La lógica aplicada aquí es que si la tupla es nula o cero, le dará un valor booleano: Verdadero o Falso. Y 'IsofAge' sirve para comprobar si la edad indicada es correcta o no. La lógica de la función definida por el usuario está escrita en códigos Java, donde se creará el archivo JAR y luego se exportará. El archivo JAR se registra más tarde. Estos archivos JAR se encuentran en los archivos de la biblioteca de Apache Pig en el momento de la carga.
La clase pública IsOfAge extiende FilterFunc { @Anular publicBoolean exec (tupla tupla) throwsIOException { if (tupla == null || tuple.size () == 0) { falso retorno } tratar{ Objeto objeto = tuple.get (0) si (objeto == nulo) { falso retorno } inti = objeto (entero) si (i == 18 || i == 19 || i == 21 || i == 23 || i == 27) { retorno verdadero } más { falso retorno }} catch (ExecExceptione) { thrownewIOException (e) } } }¿Cómo llamar a un cerdo UDF?
Una vez que se crea una UDF, se debe usar el siguiente comando para registrar el archivo JAR.
registrar myudf.jar X = filtro A por IsOfAge (edad)
Pasos para crear UDF en Pig:
Hay varias funciones predefinidas en Apache Pig. También tenemos la característica de crear nuestra propia función que es la función definida por el usuario (UDF). Pig UDF está escrito en Java y esto requiere que Pig Library use las clases predefinidas. La biblioteca de Apache Pig cerdo-0.8.0-cdh3u0-core.jar se puede descargar de Internet.
Haga clic aquí para conocer los pasos para crear un script Pig con UDF en modo HDFS.
Tienes una pregunta para nosotros? Menciónalos en la sección de comentarios y nos pondremos en contacto contigo.
Artículos Relacionados:
tutorial de mysql workbench para principiantes
Script de Apache Pig con UDF en modo HDFS
Operadores en Apache Pig: Parte 1- Operadores relacionales
Operadores en Apache Pig: Parte 2 - Operadores de diagnóstico