Pig是一种数据流编程语言，由一系列操作和变换构成，每一个操作或者变换都对输入进行处理，然后产生输出结果，整体操作表示一个数据流。Pig的执行环境将数据流翻译为可执行的内部表示，在Pig内部，这些变换操作被转换为一系列的MapReduce作业。
Pig自身有许多个方法，有时候需要我们自己定制特定的处理方法即UDF。
相关阅读：
UDF具体的步骤如下：
第一步，继承计算类或者过滤类或者加载类或者存储类，重写里面的需要实现的方法,将写好的类进行打包生成jar文件。诸如命名为example.jar
第二步，进入Pig的grunt中，利用register将打包的文件注册进入Pig中。进入Pig的grunt中，当前本地路径就是用户输入Pig时候所在的路径。打包文件一定要加上它所在的路径。如register example.jar。
第三步，直接使用该自定义的UDF，在使用的过程中需要加上该类的权限定包名，如果这里example.jar的包结构为com.whut.FilterFunct。则引用的时候就是com.whut.FilterFunct(参数)。注意类的名称就是使用时候的方法名，必须要区分大小写。
第四步，为自己的UDF定义别名，这样使用的时候就不许要加包名了，如
define Goog com.whut.FilterFunct()。这样使用的时候就直接利用Goog了。
自定义过滤UDF：
过滤UDF需要继承FilterFunc。实现其exec方法。该方法返回的是boolean型。在对温度统计的时候，就可以利用过滤UDF来过滤是否正确的气温。
package whut;
import java.io.IOException;
import java.util.ArrayList;
import java.util.List;
import org.apache.pig.FilterFunc;
import org.apache.pig.FuncSpec;
import org.apache.pig.backend.executionengine.ExecException;
import org.apache.pig.data.DataType;
import org.apache.pig.data.Tuple;
import org.apache.pig.impl.logicalLayer.FrontendException;
//删除记录中不符合要求的记录
//pig的自定义函数，过滤函数
public class IsGoodQuality extends FilterFunc{
@Override
public Boolean exec(Tuple tuple) throws IOException {
// TODO Auto-generated method stub
if(tuple ==null ||tuple.size()==0)
return false;
try{
Object obj=tuple.get(0);
if(obj==null)
return false;
//这里强制转换为一个整形
int i=(Integer)obj;
return i==0 ||i==1 || i==2 || i==3;
}catch(ExecException e)
{
throw new IOException(e);
}
}
}
这里的参数是一个元组，可以包含多个输入参数，在方法中直接利用get(索引位置)来直接获取。
自定义加载函数UDF
在Pig中经常会使用到加载外部文件，一般使用Load进行加载，如Load 'input/tempdata' as (a:chararray,b:int) 。这里默认使用了内部加载存储函数，PigStorage。
即Load 'input/tempdata' using PigStorage() as (a:chararray,b:int)。这里PigStorage默认的每一行的字段分割符是制表符，当然也可以传递一个自己的字段分割符号。有时候每一行是一串字符串，想从中取出某一个字段，则就需要自己定义一个加载函数。以下面这个文件为例子。
aaaaa1990aaaaaa0039a
bbbbb1991bbbbbb0045a
ccccc1992cccccc0011c
ddddd1993dddddd0043d
eeeee1994eeeeee0047e
aaaaa1990aaaaaa0037a
bbbbb1991bbbbbb0027a
ccccc1992cccccc0032c
ddddd1993dddddd0090d
eeeee1994eeeeee0091e
aaaaa1980aaaaaa0041a
bbbbb1981bbbbbb0050a
ccccc1992cccccc0020c
ddddd1993dddddd0033d
eeeee1984eeeeee0061e
aaaaa1980aaaaaa0054a
bbbbb1991bbbbbb0075a
ccccc1982cccccc0011c
ddddd1993dddddd0003d
eeeee1974eeeeee0041e
aaaaa1990aaaaaa0039a
bbbbb1961bbbbbb0041a
ccccc1972cccccc0070c
ddddd1993dddddd0042d
eeeee1974eeeeee0043e
aaaaa1990aaaaaa0034a
bbbbb1971bbbbbb0025a
ccccc1992cccccc0056c
ddddd1993dddddd0037d
eeeee1984eeeeee0038e
aaaaa1990aaaaaa0049a
bbbbb1991bbbbbb0011a
ccccc1962cccccc0012c
ddddd1993dddddd0023d
eeeee1984eeeeee0031e
aaaaa1980aaaaaa0094a
bbbbb1971bbbbbb0045a
ccccc1992cccccc0041c
ddddd1993dddddd0003d
eeeee1984eeeeee0081e
aaaaa1960aaaaaa0099a
bbbbb1971bbbbbb0050a
ccccc1952cccccc0055c
ddddd1963dddddd0043d
eeeee1994eeeeee0041e
aaaaa1990aaaaaa0031a
bbbbb1991bbbbbb0020a
ccccc1952cccccc0030c
ddddd1983dddddd0013d
eeeee1974eeeeee0061e
aaaaa1980aaaaaa0071a
bbbbb1961bbbbbb0060a
ccccc1992cccccc0080c
ddddd1953dddddd0033d
eeeee1964eeeeee0051e
aaaaa1960aaaaaa0024a
bbbbb1951bbbbbb0035a
ccccc1952cccccc0048c
ddddd1953dddddd0053d
eeeee1954eeeeee0048e