java - 从 Pig 获取字段模式的名称

Question

我正在为 Pig 开发 JsonStorage。一切正常，但至少我需要从 pig 模式中获取字段的名称(即 crdate、名称、位置)。

| A | crdate: bytearray | name: bytearray | positions: bytearray |

实际上我通过 StoreFunc 扩展了我的类，它不提供获取字段名称的函数。

public class PigJsonStorage extends StoreFunc { .. }

谁能帮帮我:)

Answer 1

免责声明:我对自己有点陌生，还没有实现存储类。

在我看来，StoreFunc 有一个方法:StoreFunc.checkSchema(ResourceSchema s) .我认为您可以从中捕获模式以供在写入期间使用。