寫一個protobuf對象給GCS

Question

我正在製作一個將protobuf對象寫入gcs的數據流（java api）。任何人都可以請幫助我如何做到這一點。代碼示例或其他內容會很有幫助。

Answer 1

https://issues.apache.org/jira/browse/BEAM-221對此有一些想法。

裹AvroIO在複合PTransform：

• 阿夫羅架構僅僅是一個單一的字節[]。
• 讀取後，從byte []轉換爲 用戶的原型。
• 在寫入時，從原始轉換爲字節[]。

這樣，ProtoIO只是AvroIO.Read + ParDo（讀取）或ParDo + AvroIO.Write的簡單包裝。