自定义 Hive UDF 中的地图列表

Question

我正在编写自定义 UDF 并期待一个 ARRAY<MAP<STRING, STRING>> 参数。然后在我的evaluate 方法中做

@Override
public Object evaluate(DeferredObject[] args) throws HiveException {
    List<?> elements = listObjectInspector.getList(args[0].get());

问题是，elements 现在是有效 Java 映射的列表，还是我仍然需要为 elements 中的每个元素调用 mapObjectInspector.getMap()？

Answer 1

答案是肯定的。首先使用ListObjectInspector，然后为每个元素调用MapObjectInspector。