这篇文章主要为大家展示了“hive3.0.0如何自定义函数”，内容简而易懂，条理清晰，希望能够帮助大家解决疑惑，下面让小编带领大家一起研究并学习一下“hive3.0.0如何自定义函数”这篇文章吧。
示例代码
计算
安全
数据库
网络和加速
企业服务
package hello_hive;
import org.apache.hadoop.hive.ql.exec.UDFArgumentException;
import org.apache.hadoop.hive.ql.metadata.HiveException;
import org.apache.hadoop.hive.ql.udf.generic.GenericUDF;
import org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector;
import org.apache.hadoop.hive.serde2.objectinspector.ObjectInspectorFactory;
import org.apache.hadoop.hive.serde2.objectinspector.PrimitiveObjectInspector;
import org.apache.hadoop.hive.serde2.objectinspector.primitive.PrimitiveObjectInspectorFactory;
import org.apache.hadoop.io.Text;
import org.apache.hive.hplsql.Udf;
public class HiveTest extends Udf{
StringBuilder builder = new StringBuilder();
public String evaluate(String invalue) throws HiveException {
int length = invalue.length();
char[] cha = invalue.toCharArray();
for(int i = 0 ;i<length;i++) {
String tmp = String.valueOf(cha[i]);
if(Math.floorMod(i, 2)==0) {
builder.append(tmp.toUpperCase());
}else {
builder.append(tmp.toLowerCase());
}
}
return builder.toString();
}
}
class HiveTest2 extends GenericUDF{
StringBuilder builder = new StringBuilder();
Text tx = new Text();
@Override
//主要逻辑函数
public Object evaluate(DeferredObject[] defer) throws HiveException {
builder.delete(0, builder.length());
if(defer.length<=0) {
return null;
}
else {
int length = defer[0].get().toString().length();
char[] cha = defer[0].get().toString().toCharArray();
for(int i = 0 ;i<length;i++) {
String tmp = String.valueOf(cha[i]);
if(Math.floorMod(i, 2)==0) {
builder.append(tmp.toUpperCase());
}else {
builder.append(tmp.toLowerCase());
}
}
}
tx.set(builder.toString());
return tx;
}
//获取函数帮助信息的函数
@Override
public String getDisplayString(String[] args) {
return getStandardDisplayString("Usage: upd(strs)", args);
}
//判断函数返回值类型的函数
@Override
public ObjectInspector initialize(ObjectInspector[] arg0) throws UDFArgumentException {
ObjectInspector outputOI =PrimitiveObjectInspectorFactory.writableStringObjectInspector;
return outputOI;
}
}以上是“hive3.0.0如何自定义函数”这篇文章的所有内容，感谢各位的阅读！相信大家都有了一定的了解，希望分享的内容对大家有所帮助，如果还想学习更多知识，欢迎关注亿速云行业资讯频道！
亿速云「云服务器」，即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘，价格低至29元/月。点击查看>>
免责声明：本站发布的内容（图片、视频和文字）以原创、转载和分享为主，文章观点不代表本网站立场，如果涉及侵权请联系站长邮箱：is@yisu.com进行举报，并提供相关证据，一经查实，将立刻删除涉嫌侵权内容。
原文链接：http://blog.itpub.net/31506529/viewspace-2213683/
