java - 使用 MessagePack 的 Apache Beam - 如何从 Map 获取值？

Question

在 Apache Beam 转换中，我可以成功地将我从 Google Cloud Pub/Sub 读取的 pub/sub 值(以 MessagePack 格式)转换为 MessagePack Value 对象的映射，如下所示:

    @ProcessElement
    public void processElement(ProcessContext c) 
    {
        Map<Value, Value> map = MessagePack.newDefaultUnpacker(c.element().getPayload()).unpackValue().asMapValue().map();

当我检查 map 时，我可以看到以下内容:

如果我随后尝试获取这样的值，它总是返回 null:

map.get("Tz")

如何获取值？我是否需要以不同的方式转换这些值，或者我是否需要以不同的方式检索它们？

Answer 1

map 是 map ，所以键是一个值对象，但是当您执行 map.get("Tz") 时，您使用的是字符串

您能否使用 Tz 创建一个 Value 对象并尝试基于该 Value 对象获取？