这符合csv标准化，所以您只需要使用csvloader
支持双引号字段，该字段包含逗号和其他用反斜杠转义的双引号。
使用方法如下：

register file:/home/hadoop/lib/pig/piggybank.jar
DEFINE CSVLoader org.apache.pig.piggybank.storage.CSVLoader();
A = LOAD '/user/root/data/tweets.csv' USING CSVLoader AS (users:chararray, tweets:chararray); 
B = FILTER A by users == '396124436476092416';

可以使用csvloader加载数据
但是，如果您不希望这样做，下面是apache pig本身的解决方法：
--加载数据

A  = LOAD 'your/path/users.csv' USING TextLoader() AS (unparsed:chararray);

--更换您的 " 字符串 | 以便把你的推文分开

B = FOREACH A GENERATE REPLACE(unparsed, '\\"', '|') AS parsed:chararray;

--将临时解析的数据存储到您的位置

STORE B INTO 'your/path/parsed_users.csv' USING PigStorage('|');

--加载解析的数据

C = LOAD 'your/path/parsed_users.csv' USING PigStorage('|') AS (users:chararray, tweets:chararray);

--转储你的数据，无论如何这仍然会包含一个额外的逗号( , )但是你可以用替换函数来替换它。

DUMP C;