hive
Fonctions définies par l'utilisateur pour la ruche (UDF)

Création de la ruche UDF

Pour créer un fichier UDF, nous devons étendre la classe UDF ( org.apache.hadoop.hive.ql.exec.UDF ) et implémenter la méthode d’évaluation.

Une fois le fichier UDF respecté et le fichier JAR généré, nous devons ajouter jar au contexte de la ruche pour créer une fonction temporaire / permanente.

import org.apache.hadoop.hive.ql.exec.UDF;    

class UDFExample extends UDF {
  
  public String evaluate(String input) {
    
    return new String("Hello " + input);
  }
}

hive> ADD JAR <JAR NAME>.jar;
hive> CREATE TEMPORARY FUNCTION helloworld as 'package.name.UDFExample';
hive> select helloworld(name) from test;

Hive UDF pour couper la chaîne donnée.

package MyHiveUDFs;

import org.apache.commons.lang.StringUtils;
import org.apache.hadoop.hive.ql.exec.UDF;
import org.apache.hadoop.io.Text;

public class Strip extends UDF {

private Text result = new Text();
 public Text evaluate(Text str) {
 if(str == null) {
 return null;
 }
 result.set(StringUtils.strip(str.toString()));
 return result;
 }
}

exporter le fichier ci-dessus vers jar

Accédez à l'interface de ligne de commande Hive et ajoutez le fichier JAR UDF

hive> ADD jar /home/cloudera/Hive/hive_udf_trim.jar;

Vérifiez que JAR se trouve dans Hife CLI Classpath

hive> list jars;
/home/cloudera/Hive/hive_udf_trim.jar

Créer une fonction temporaire

hive> CREATE TEMPORARY FUNCTION STRIP AS 'MyHiveUDFs.Strip';

Sortie UDF

 hive> select strip('   hiveUDF ') from dummy;
 OK
 hiveUDF