Hello all,
I have written a UDF for hive to extract the number of entries in a table with String type column.
I basically need to find the number of occurrences of the word 'java' and 'ajax' and get the number printed as the output.
when i follow all the steps and execute the udf in the console, i get no errors, but don't get the output either.
All i get is the total number of rows in the table.
Below is the udf code which i used. Please help me to know what wrong am i doing here - "package com.hive.udf; import org.apache.hadoop.hive.ql.exec.UDF;
import org.apache.hadoop.io.Text; public class Test extends UDF
{ Text result = new Text(); public Text evaluate(Text str) {
String word = str.toString(); String[] data = new String[100];
if(word == null )
return null;
else {
int ajax = 0;
int java = 0; String[] worduse = word.split(" "); int len = worduse.length; int pos = 0;
while (pos < len) {
if(worduse[pos].toLowerCase().contains("ajax")) ajax++; if(worduse[pos].toLowerCase().contains("java")) java++;
pos++;
}
data[0] = Integer.toString(ajax); data[1] = Integer.toString(java);
}
result.set(data.toString());
return result;
}
}"
... View more
