编程宝库 - 技术改变世界

编程宝库

Search

Pig教程

Pig 示例

Apache Pig LOAD 操作符

Pig UDF(用户定义函数)

为了指定自定义处理，Pig 提供对用户定义函数(UDF) 的支持。因此，Pig 允许我们创建自己的函数。目前，Pig UDF 可以使用以下编程语言实现:：

Java
Python
Jython
JavaScript
Ruby
Groovy

在所有语言中，Pig 为 Java 函数提供了最广泛的支持。但是，对 Python、Jython、JavaScript、Ruby 和 Groovy 等语言的支持有限。

Pig UDF 示例

所有 UDF 必须扩展"org.apache.pig.EvalFunc"
所有函数都必须覆盖"exec"方法。

让我们看一个简单的 EVAL 函数示例，将提供的字符串转换为大写。

UPPER.java

package com.hadoop;
import java.io.IOException;
import org.apache.pig.EvalFunc;
import org.apache.pig.data.Tuple;
public class TestUpper extends EvalFunc<String>   {
	public String exec(Tuple input) throws IOException {  
		if (input == null || input.size() == 0)  
		return null;  
		try{  
		            String str = (String)input.get(0);  
		return str.toUpperCase();  
		}catch(Exception e){  
		throw new IOException("Caught exception processing input row ", e);  
		        }  
		    }
}