如何返回ObjectInspector引用的对象

Question

我正在编写一个自定义配置单元UDF来根据属性文件中定义的值解析映射中的键/值对。正在验证的格式(map ，String)。目的是让第一个参数是要计算的映射，第二个参数包含属性文件。

我遇到的问题是，GenericUDF类似乎希望这两个值对查询都是动态的，因为initialize（）函数将参数转换为ObjectInspectors，从外观上看，这没有可能的选项来返回它们所检查的对象。

我希望initialize函数加载属性文件，evaluate函数返回pass/fail。这段代码还不足以涵盖我所尝试的所有内容，但希望它能给那些知道自己在做什么的人一个关于这个问题的好主意：

public ObjectInspector initialize(ObjectInspector[] arguments) throws UDFArgumentException {
  mapOI = (MapObjectInspector) arguments[0];
  StringObjectInspector stringOI = (StringObjectInspector) arguments[1];

  try {
    // Begin Debug
    System.out.println(stringOI.getPrimitiveJavaObject(((DeferredObject) arguments[1]).get()));
    // End Debug

    loadProperties(stringOI.getPrimitiveJavaObject(((DeferredObject) arguments[1]).get()));
  }
  catch (HiveException exception) {
    throw new UDFArgumentTypeException(1, "Failed to cast properties file path for evaluation by loadProperties... What did you do?");
  }

Answer 1

initialize方法只调用一次，因此参数只能被视为描述evaluate方法期望接收的输入类型的元数据。因此，真正可以看到输入值的唯一位置是evaluate方法，该方法可能被调用多次，通常每行调用一次。实际上，您应该只使用initialize函数来验证类型，而不是实际值。也就是说，在您的示例中，检查输入是否为map类型，而原始类别元素为String类型。应在evaluate方法中对实际值进行验证。