我有一个问题与自定义项Pig拉丁语。我正在尝试实现一个系统，该系统必须验证本地存储的矩阵和hadoop存储库中存储的一组矩阵之间是否存在“Map”。对于Map，我的意思是如果hadoop中存在一个存储矩阵的行和列的排列，它将矩阵转换为一个与本地存储矩阵相等的矩阵。因为矩阵可以有数百个元素，所以我想在hadoop上执行Map算法来使用并行性。我正在寻找udf pig拉丁语，但我不知道如何将本地矩阵“发送”到udf函数。

public class Mapping extends EvalFunc<String>
 {
private int[][] matrixToMap; //The local matrix i want to map

public String exec(Tuple input) throws IOException { //Here the tuple are the matrix stored in hadoop
  if (input == null || input.size() == 0)
      return null;
  try{
       //HERE THE CODE FOR THE MAPPING
  }

     }
   }

}
考虑到我将使用以下代码，我的问题是如何初始化属性matrixtomap：

REGISTER /Users/myudfs.jar;  
//SOME CODE TO INITIALIZE ATTRIBUTE matrixToMap
records = LOAD 'Sample7.txt' //the matrix stored in hadoop
B = FOREACH records GENERATE myudfs.mapping(records);

假设pig脚本是在java程序中调用的，并且本地矩阵存储在java矩阵中。所以java程序看起来像：

int [][] localMatrix;
pigServer.registerJar("/Users/myudfs.jar");
//Some code to make Mapping.matrixToMap = localMatrix
pigServer.registerQuery("records = LOAD 'Sample7.txt';");
pigServer.registerQuery("B = FOREACH records GENERATE myudfs.Mapping(formula);");

你知道吗？谢谢