У меня есть куча файлов протобаффов в GCS, и я хотел бы обработать их через поток данных (java sdk), и я не уверен, как это сделать.
Луч Apache обеспечивает 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?
Заранее спасибо