protocol-buffers - 读取 Apache Beam 中的协议缓冲区文件

Question

我在 GCS 中有一堆 protobuff 文件，我想通过数据流（java sdk）处理它们，但我不知道该怎么做。

Apache Beam 提供 AvroIO 来读取 avro 文件

 Schema schema = new Schema.Parser().parse(new File("schema.avsc"));
 PCollection<GenericRecord> records =
     p.apply(AvroIO.readGenericRecords(schema)
                .from("gs://my_bucket/path/to/records-*.avro"));

读取 protobuff 文件有什么类似的吗？

提前致谢