标签:
users = load ‘/users.data‘ using PigStorage() as (name:chararray, age:int, address:chararray);
load ‘xx‘:
1)xx可以是文件,也可以是文件夹。如果是文件夹,则文件夹下的所有文件(包括子文件夹)都作为输入文件。
LOAD ‘/mydata/20110423{00,01,02,03,04,05,06,07,08,09,{10..23}}00//part ‘
using PigStorage:
1)可以添加分隔符参数,using PigStorage(‘,‘);
2)可以是其他加载函数,using HbaseStorage()
as (name:chararray, age:int, address:chararray):
1)可以只指定字段名, as(name, age, address),字段的类型将交由Pig自己推测。
Pig load 用法举例
标签:
原文地址:http://www.cnblogs.com/lishouguang/p/4559287.html