此脚本将为您提供所需的结果：

A = LOAD '/home/cloudera/surender/laurela/balance.txt' USING PigStorage(',') AS(name:chararray,bank:chararray,amt:long,company:chararray);

    B = GROUP A BY (company);
    topResults = FOREACH B {result = TOP(1, 2, A); GENERATE FLATTEN(result);}
    dump topResults;

说明：

首先，我们以公司为基础将a分组，所以a是：
（cts，{（surender，hdfc，60000，cts），（kumar，axis，70000，cts），（remya，axis，40000，cts），（ankur，hdfc，80000，cts），（karthic，hdfc，95000，cts），（sandhya，axis，60000，cts），（amit，sbi，70000，cts）}）
（tcs，{（raja，axis，80000，tcs），（raj，hdfc，70000，tcs），（arun，sbi，30000，tcs），（vimal，sbi，10000，tcs）}）
然后我们说，对于b中的每个元组，根据第2列的值，即amt，从b中找到的关系a生成另一个元组结果，该结果等于前1个记录。列从0开始编号。
注意：首先，您的数据在公司名称后有额外的空格。请删除多余的空格或使用以下数据：

Surender,HDFC,60000,CTS
  Raja,AXIS,80000,TCS
  Raj,HDFC,70000,TCS
  Kumar,AXIS,70000,CTS
  Remya,AXIS,40000,CTS
  Arun,SBI,30000,TCS
  Vimal,SBI,10000,TCS
  Ankur,HDFC,80000,CTS
  Karthic,HDFC,95000,CTS
  Sandhya,AXIS,60000,CTS
  mit,SBI,70000,CTS

您不需要编写自定义项就可以做到这一点，只需使用pig的top函数即可：http://pig.apache.org/docs/r0.11.0/func.html#topx
下面是一个应该工作（未测试）的代码示例：

grouped = GROUP myinput BY company;
result = FOREACH grouped GENERATE company, FLATTEN(TOP(1,2,grouped));