从猪的UDF（Java）返回地图

Question

假设我想从 UDF 返回一个 Map（扩展 EvalFunc）

Map 是 String(Key), Object(value) 。这个对象是一些有 4-5 个字符串字段的类。

我知道为了返回这个复杂的地图，我需要重写 outputSchema。 但我无法弄清楚我将返回什么架构。

public class myUDF extends EvalFunc<Map>{
    public Map exec(Tuple input) throws IOException{
        Map<String, myClass> map = new HashMap<String, myClass>();
        // Create a Map
        return map;
    }

    public Schema outputSchema(Schema input){
        try{
            return new Schema... // How I will define my Schema
        }
        catch(FrontendException e){
            return null;
        }
    }


public myClass{
    String field1; String field2; String field3;
    // getters and Setters

}  

感谢和问候， 阿比纳夫

Answer 1

您无需在此处设置架构。你只返回一个元素，一个map，Pig 会根据exec 方法的签名知道这一点。 Pig 中的映射没有任何进一步的模式，因为键必须是 chararray 类型，而值可以是任何数据类型。所以本质上它们总是Map<String, Object>类型的对象。

如果您使用此 UDF，然后使用您的别名 DESCRIBE，您应该会看到 Pig 知道您返回了一个地图。