hive3.0.0如何自定義函數

這篇文章主要為大家展示了“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如何自定義函數”這篇文章的所有內容，感謝各位的閱讀！相信大家都有了一定的了解，希望分享的內容對大家有所幫助，如果還想學習更多知識，歡迎關注億速云行業資訊頻道！