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

Question

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

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

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

public class PigJsonStorage extends StoreFunc { .. }

有谁能够帮我 ：）

Answer 1

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

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

Answer 2

有一个返回ResourceSchema的类JsonMetadata ，它有一个返回字段数组的方法。