我有这样的a custom Pig loader:

A = LOAD 'myfile' USING myudf_loader()

((key1, val1), (key2, val2), (key3, val3), ...)

DUMP A;
(("city", "New York City"), ("city", "Boston"),
 ("city", "Washington, D.C."), ("non-city-key", "non-city-value"),
 ("city", "New York City"), ("non-city-key", "non-city-value"))

DUMP B;
("city", "New York City")
("city", "New York City")

最佳答案

我没有完整的 pig 拉丁文字。

但是您可以使用以下思路实现

grouped_records = GROUP records By Key;

filtered_records = FILTER grouped_records By group='CITY'

Dump filtered_records

https://stackoverflow.com/questions/24337117/