在猪中转储字符串或(字符串,整数)元组

Question

我有一个简单的猪脚本,我能够读取数据并转储数据.但是,我无法转储字符串或(string,int)元组.只是想知道我在这里失踪了什么？非常感谢!

---

dataset = LOAD '/Users/me/input' USING PigStorage() AS (id:chararray,data:chararray);

dataset_GROUP = GROUP dataset ALL;
dataset_COUNT = FOREACH dataset_GROUP GENERATE COUNT(dataset);

DUMP "record_count = ";                 <-- this does not work
DUMP dataset_COUNT;                     <-- this works 
DUMP "record_count = ", dataset_COUNT;  <-- this does not work

Answer 1

你可以使用CONCAT()Apache Pig的功能将你的字符串连接到结果,如下所示:

dataset = LOAD '/Users/me/input' USING PigStorage() AS (id:chararray,data:chararray);

dataset_GROUP = GROUP dataset ALL;
dataset_COUNT = FOREACH dataset_GROUP GENERATE CONCAT('record_count = ', COUNT(dataset));

DUMP dataset_COUNT;

有关的CONCAT()的详细信息Apache的猪0.13.0你可以检查在这里

如果您使用较旧的Pig版本,则可以编写用户定义函数(UDF),它将执行连接操作并返回结果.有关更多详细信息,请参阅UDF上的猪文档