hadoop - Pig 用户定义的函数不理解什么是 eval function()

Question

我正在尝试分析以下代码，但无法弄清楚什么是 Evalfunction() 以及它的实际作用:

package myudfs;
  import java.io.IOException;
  import org.apache.pig.EvalFunc;
  import org.apache.pig.data.Tuple;

  public class UPPER extends EvalFunc<String>
  {
    public String exec(Tuple input) throws IOException {
        if (input == null || input.size() == 0)
            return null;
        try{
            String str = (String)input.get(0);
           return str.toUpperCase();
        }catch(Exception e){
            throw new IOException("Caught exception processing input row ", e);
        }
    }
  }

有人可以向我解释一下这个功能吗？

Answer 1

进行预检查以确保输入有效 - 如果无效则返回 null，否则它获取输入的第一个字符，并将第一个字母大写并仅返回大写字符。 try catch 纯粹用于转换，以防输入不是字符串类型。