Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- package com.dataminelab.hive.udf;
- import org.apache.hadoop.hive.ql.exec.UDF;
- import org.apache.hadoop.io.Text;
- import java.security.*;
- /**
- * Calculate md5 of the string
- */
- public final class Md5 extends UDF {
- public Text evaluate(final Text s) {
- if (s == null) {
- return null;
- }
- try {
- MessageDigest md = MessageDigest.getInstance("MD5");
- md.update(s.toString().getBytes());
- byte[] md5hash = md.digest();
- StringBuilder builder = new StringBuilder();
- for (byte b : md5hash) {
- builder.append(Integer.toString((b & 0xff) + 0x100, 16).substring(1));
- }
- return new Text(builder.toString());
- } catch (NoSuchAlgorithmException nsae) {
- System.out.println("Cannot find digest algorithm");
- System.exit(1);
- }
- return null;
- }
- }
- javac Md5.java
- Md5.java:2: package org.apache.hadoop.hive.ql.exec does not exist
- import org.apache.hadoop.hive.ql.exec.UDF;
- ^
- Md5.java:3: package org.apache.hadoop.io does not exist
- import org.apache.hadoop.io.Text;
- export CLASSPATH=/usr/lib/hive/lib/hive-exec-0.9.0.15.jar:/usr/lib/hadoop/hadoop-core.jar
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement