郵便番号データをPigで処理してみる

gistfile1.txt

set pig.exec.mapPartAgg true;

A = load 'KEN_ALL_ROME.CSV'
 using PigStorage(',')
 as (
  org_code:chararray,
  postcode:chararray,
  choiki_name:chararray,
  choson_name:chararray,
  todoufuken_name:chararray
);
 
B = group A by todoufuken_name;
X = foreach B generate group, COUNT(A);
dump X;