lmt=limitdata10; 只获取指定条数的数据，不能保证每次得到的结果一致，先执行order再limit可以保证一致。 输入数据全部载入。 会触发reduce阶段 a=load'a.txt';b=groupaall;c=foreachbgenerateCOUNT(a)as...

jnd=joinabyf1,bbyf2; join操作默认的是内连接，只有两边都匹配才会保留 需要用null补位的那边需要知道它的模式：如果是左外连接，需要知道右边的数据集的模式，不匹配的字段用null补位如果是右外连接，需要知道左边的数据集的模式，不匹配的字段用null补位如果是全外连接，需要知道...

dst=distinctdata； DISTINCT只能对整个记录（整行）去重，不能在字段级别去重。 触发reduce阶段 data=load'data';distinctdata;　　 ...

   group语句可以把具有相同键值的数据聚合在一起，与SQL中的group操作有着本质的区别，在SQL中groupby字句创建的组必须直接注入一个或多个聚合函数。在PigLatin中group和聚合函数之间没有直接的关系。   group关键字正如它字面所...

sorted=orderdataby$0; 数值类型按照数值大小比较chararray类型按照字符的字典顺序比较bytearray按照字节的字典顺序比较复杂类型（map、tuple、bag）不能比较null是最小的 触发reduce阶段sorted=orderdataby$0;sorted=orde...

store：将数据存储到HDFS等文件系统里 将数据保存到/data目录storedatainto'/data';　　 以逗号为分隔符storedatainto'/data'usingPigStorage(','); ...

filter：过滤数据，只有符合特定条件的数据才会被保留下来，然后进入下一个数据流。 1）等值比较filterdataby$0==1filterdataby$0!=1 2）字符串正则匹配 JAVA的正则表达式字符串以CM开头filterdataby$0matches'CM.*';字符串包含...

foreach：一行一行的遍历数据，处理一行的数据，然后返回一个tuple。users=load'/users.data'; 1）别名引用f=foreachusersgeneratename,age;　　 2）位置引用f=foreachusersgenerate$0,$1;　　 3）字段区...

users=load'/users.data'usingPigStorage()as(name:chararray,age:int,address:chararray); load'xx'：  1）xx可以是文件，也可以是文件夹。如果是文件夹，则文件夹下的所有文件（包括子文件夹）都作为输入...

总体来说Pig是“强类型”的，但Pig又允许用户不指定输入数据的类型，而可以自己根据用户的使用方式进行推测。称Pig是“轻类型”的更合适，它确实对类型有严格的要求，但是如果没有明确定义类型也是可以处理的。...

users.data的内容如下：lisg2875dengsl2488　　强制类型转换users=load'/users.data'fehed=foreachusersgenerate(int)$1asage;　　 隐式类型转换users=load'/users.data'fehed=foreachusersg...

Pig中的模式可以是用户显示声明的，也可以是Pig通过用户的使用方式猜测的。Pig对模式的认知在PigLatin脚本执行的不同阶段可能是不同的。  下面的语句，用户显示声明了模式：3个字段，分别是name、age、address，它们的类型也确定了。data=load'data'as(name:ch...

int、long、float、double、chararray、bytearray、datatime、boolean、biginteger、bigdecimalmap、tuple、bagNULL map['key1'#value1,'key2'#value2]key-value键值对，key是chararra...

在pig的grunt环境下，按TAB键可以自动补全命令，用户可以添加自己的补全信息。在conf目录下创建autocomplete文件，添加如下内容：hdfs://vm1:8020/ 在grunt环境下输入hd，然后按TAB，就可以自动补全hdfs://vm1:8020了。 /conf/autocom...

   pig脚本就是一个文件，保存了多条pig命令，通常后缀是.pig（不强制）。   多行注释：/**/  单行注释：--   下面是一个名字是test.pig的脚本的例子：/*test.pig测试脚本*/d...